Home
last modified time | relevance | path

Searched refs:correlation_id (Results 1 – 25 of 336) sorted by relevance

12345678910>>...14

/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/protocol/
H A Dparser.py41 def send_request(self, request, correlation_id=None): argument
54 if correlation_id is None:
55 correlation_id = self._next_correlation_id()
57 correlation_id=correlation_id,
64 ifr = (correlation_id, request)
66 return correlation_id
146 correlation_id != 0 and
153 elif correlation_id != recv_correlation_id:
157 % (correlation_id, recv_correlation_id))
168 correlation_id, request.RESPONSE_TYPE,
[all …]
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/kafka_ex/
H A Dserver_0_p_10_and_later.ex106 state.correlation_id,
115 correlation_id: correlation_id,
163 correlation_id: correlation_id
175 state.correlation_id
180 {:reply, response, %{state | correlation_id: state.correlation_id + 1}}
224 {response, %{state | correlation_id: state.correlation_id + 1}}
273 {response, %{state | correlation_id: state.correlation_id + 1}}
298 %State{consumer_group: consumer_group, correlation_id: correlation_id} =
304 correlation_id
316 correlation_id: state.correlation_id + 1
[all …]
H A Dserver.ex34 correlation_id: 0,
387 correlation_id = state.correlation_id + 1
415 correlation_id,
558 state = %{state | correlation_id: state.correlation_id + 1}
578 correlation_id: correlation_id
613 correlation_id: correlation_id + 1
620 correlation_id,
627 correlation_id,
650 correlation_id,
767 correlation_id: correlation_id,
[all …]
H A Dserver_0_p_8_p_2.ex75 {correlation_id, metadata} =
81 correlation_id: correlation_id,
135 OffsetFetch.create_request(state.correlation_id, @client_id, offset_fetch)
159 {response, %{state | correlation_id: state.correlation_id + 1}}
225 %State{consumer_group: consumer_group, correlation_id: correlation_id} =
231 correlation_id
242 correlation_id: state.correlation_id + 1
249 %{state | correlation_id: state.correlation_id + 1},
298 state.correlation_id,
314 {response, %{state | correlation_id: state.correlation_id + 1}}
H A Dserver_0_p_9_p_0.ex101 {correlation_id, metadata} =
107 correlation_id: correlation_id,
202 state_out = %{state | correlation_id: state.correlation_id + 1}
208 state.correlation_id,
261 %State{consumer_group: consumer_group, correlation_id: correlation_id} =
267 correlation_id
279 correlation_id: state.correlation_id + 1
287 %{state | correlation_id: state.correlation_id + 1},
/dports/net/kamailio/kamailio-5.4.5/src/modules/sipcapture/sql/
H A Dschema_data.sql13 `correlation_id` varchar(256) NOT NULL DEFAULT '',
25 KEY `correlationid` (`correlation_id`(255))
44 `correlation_id` varchar(256) NOT NULL DEFAULT '',
56 KEY `correlationid` (`correlation_id`(255))
75 `correlation_id` varchar(256) NOT NULL DEFAULT '',
87 KEY `correlationid` (`correlation_id`(255))
138 `correlation_id` varchar(256) NOT NULL DEFAULT '',
206 `correlation_id` varchar(256) NOT NULL DEFAULT '',
274 `correlation_id` varchar(256) NOT NULL DEFAULT '',
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/src/trace_processor/importers/fuchsia/
H A Dfuchsia_trace_parser.cc362 int64_t correlation_id; in ParseTracePacket() local
363 if (!cursor.ReadInt64(&correlation_id)) { in ParseTracePacket()
368 name, correlation_id); in ParseTracePacket()
376 int64_t correlation_id; in ParseTracePacket() local
377 if (!cursor.ReadInt64(&correlation_id)) { in ParseTracePacket()
382 name, correlation_id); in ParseTracePacket()
395 int64_t correlation_id; in ParseTracePacket() local
401 name, correlation_id); in ParseTracePacket()
406 uint64_t correlation_id; in ParseTracePacket() local
419 uint64_t correlation_id; in ParseTracePacket() local
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/lib/api/entities/
H A Dproject_import_status_spec.rb25 …e(:project, :import_scheduled, import_type: 'import_type', import_correlation_id: correlation_id) }
31 expect(subject[:correlation_id]).to eq(correlation_id)
38 …te(:project, :import_finished, import_type: 'import_type', import_correlation_id: correlation_id) }
46 correlation_id_value: correlation_id,
56 expect(subject[:correlation_id]).to eq(correlation_id)
69 …, :import_failed, import_type: 'import_type', import_correlation_id: correlation_id, import_last_e…
75 expect(subject[:correlation_id]).to eq(correlation_id)
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/kafka_ex/protocol/
H A Dapi_versions.ex44 correlation_id,
49 def create_request(correlation_id, client_id, 1),
50 do: create_request(correlation_id, client_id, 0)
52 def create_request(correlation_id, client_id, 2),
53 do: create_request(correlation_id, client_id, 0)
55 def create_request(correlation_id, client_id, 0) do
56 Protocol.create_request(:api_versions, correlation_id, client_id)
H A Dmetadata.ex149 correlation_id,
155 def create_request(correlation_id, client_id, nil, api_version) do
156 create_request(correlation_id, client_id, "", api_version)
159 def create_request(correlation_id, client_id, "", api_version) do
164 correlation_id,
170 def create_request(correlation_id, client_id, topic, api_version)
172 create_request(correlation_id, client_id, [topic], api_version)
175 def create_request(correlation_id, client_id, topics, api_version)
179 correlation_id,
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/lib/
H A Dmarginalia_spec.rb39 let(:recorded) { ActiveRecord::QueryRecorder.new { make_request(correlation_id) } }
45 "correlation_id" => correlation_id,
61 "correlation_id" => correlation_id,
143 def make_request(correlation_id) argument
146 ::Labkit::Correlation::CorrelationId.use_id(correlation_id) do
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/models/
H A Dimport_failure_spec.rb9 … { create(:import_failure, :hard_failure, project: project, correlation_id_value: correlation_id) }
10 … { create(:import_failure, :soft_failure, project: project, correlation_id_value: correlation_id) }
14 expect(ImportFailure.hard_failures_by_correlation_id(correlation_id)).to eq([hard_failure])
22 …expect(ImportFailure.hard_failures_by_correlation_id(correlation_id)).to eq([hard_failure, older_f…
H A Dproject_import_state_spec.rb7 …_it_be(:import_state, refind: true) { create(:import_state, correlation_id_value: correlation_id) }
39 …allow(Labkit::Correlation::CorrelationId).to receive(:current_or_new_id).and_return(correlation_id)
44 expect(import_state.correlation_id).to eq(correlation_id)
49 …t_failure, 2, :hard_failure, project: import_state.project, correlation_id_value: correlation_id) }
/dports/net/py-kombu/kombu-4.6.11/examples/rpc-tut6/
H A Drpc_client.py14 if message.properties['correlation_id'] == self.correlation_id:
19 self.correlation_id = uuid()
27 correlation_id=self.correlation_id,
/dports/net/pecl-amqp/amqp-1.10.2/tests/
H A Damqpbasicproperties.phpt21 "correlation_id",
49 ["correlation_id":"AMQPBasicProperties":private]=>
113 ["correlation_id":"AMQPBasicProperties":private]=>
114 string(14) "correlation_id"
147 string(14) "correlation_id"
/dports/devel/py-taskflow/taskflow-4.6.3/taskflow/tests/unit/worker_based/
H A Dtest_server.py160 correlation_id=self.task_uuid)
185 correlation_id=self.task_uuid),
189 correlation_id=self.task_uuid),
193 correlation_id=self.task_uuid),
196 correlation_id=self.task_uuid)
209 correlation_id=self.task_uuid),
212 correlation_id=self.task_uuid)
244 correlation_id=self.task_uuid)
265 correlation_id=self.task_uuid)
287 correlation_id=self.task_uuid)
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gitlab.com/gitlab-org/labkit/log/
H A Dlogger_test.go21 matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=\n$`,
26 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456\n$…
59 matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=\n$`,
65 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456 fi…
71 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456 fi…
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/amqp_client/src/
H A Damqp_rpc_client.erl29 correlation_id = 0}).
98 correlation_id = CorrelationId,
101 Props = #'P_basic'{correlation_id = EncodedCorrelationId,
109 State#state{correlation_id = CorrelationId + 1,
166 #amqp_msg{props = #'P_basic'{correlation_id = Id},
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/gitlab.com/gitlab-org/labkit/log/
H A Dlogger_test.go21 matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=\n$`,
26 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456\n$…
59 matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=\n$`,
65 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456 fi…
71 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456 fi…
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gitlab.com/gitlab-org/labkit/log/
H A Dlogger_test.go21 matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=\n$`,
26 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456\n$…
59 matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=\n$`,
65 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456 fi…
71 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456 fi…
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/gitlab.com/gitlab-org/labkit/log/
H A Dlogger_test.go21 matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=\n$`,
26 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456\n$…
59 matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=\n$`,
65 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456 fi…
71 …matchRegExp: `\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}.*level=info msg=Hello correlation_id=123456 fi…
/dports/sysutils/py-azure-cli/azure-cli-2.29.2/azure/cli/command_modules/monitor/
H A Dcustom.py14 def list_activity_log(client, filters=None, correlation_id=None, resource_group=None, resource_id=N… argument
20 …odata_filters = _build_activity_log_odata_filter(correlation_id, resource_group, resource_id, reso…
30 def _build_activity_log_odata_filter(correlation_id=None, resource_group=None, resource_id=None, re… argument
47 if correlation_id:
48 …odata_filters = _build_odata_filter(odata_filters, 'correlation_id', correlation_id, 'correlationI…
/dports/devel/py-oslo.middleware/oslo.middleware-4.5.0/oslo/middleware/
H A D__init__.py32 from oslo_middleware import correlation_id
39 sys.modules['oslo.middleware.correlation_id'] = correlation_id
45 from oslo_middleware.correlation_id import CorrelationId
/dports/devel/py-oslo.middleware/oslo.middleware-4.5.0/oslo_middleware/tests/
H A Dtest_correlation_id.py21 from oslo_middleware import correlation_id
38 middleware = correlation_id.CorrelationId(app)
48 middleware = correlation_id.CorrelationId(app)
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/doc/development/
H A Ddatabase_query_comments.md23 - `correlation_id`
32 - `correlation_id`
49 …/*application:web,controller:blob,action:show,correlation_id:01EZVMR923313VV44ZJDJ7PMEZ,endpoint_i…
55 …/*application:web,correlation_id:01EZVN0DAYGJF5XHG9N4VX8FAH,endpoint_id:/api/:version/users/:id*/ …
61 …/*application:sidekiq,correlation_id:df643992563683313bc0a0288fb55e23,jid:15fbc506590c625d7664b074…

12345678910>>...14