/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/protocol/ |
H A D | parser.py | 41 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 D | server_0_p_10_and_later.ex | 106 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 D | server.ex | 34 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 D | server_0_p_8_p_2.ex | 75 {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 D | server_0_p_9_p_0.ex | 101 {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 D | schema_data.sql | 13 `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 D | fuchsia_trace_parser.cc | 362 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 D | project_import_status_spec.rb | 25 …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 D | api_versions.ex | 44 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 D | metadata.ex | 149 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 D | marginalia_spec.rb | 39 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 D | import_failure_spec.rb | 9 … { 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 D | project_import_state_spec.rb | 7 …_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 D | rpc_client.py | 14 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 D | amqpbasicproperties.phpt | 21 "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 D | test_server.py | 160 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 D | logger_test.go | 21 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 D | amqp_rpc_client.erl | 29 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 D | logger_test.go | 21 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 D | logger_test.go | 21 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 D | logger_test.go | 21 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 D | custom.py | 14 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__.py | 32 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 D | test_correlation_id.py | 21 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 D | database_query_comments.md | 23 - `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…
|