Skip to content

Instantly share code, notes, and snippets.

View lbradstreet's full-sized avatar

Lucas Bradstreet lbradstreet

View GitHub Profile
lein test onyx.peer.dashboard-colors-flow-test
STARTED
=================================
Starting Dashboard components ...
Starting Sente
18-12-10 04:36:37 vath.local INFO [onyx.messaging.aeron.status-publisher:51] - Closing status pub {:completed? true, :src-peer-id #uuid "94d8d5d7-5856-5025-5786-158432325fda", :site {:address "localhost", :port 40200}, :blocked? false, :pos 6976, :type :status-publisher, :stream-id 0, :checkpoint? true, :dst-channel "aeron:udp?endpoint=localhost:40200|term-length=4194304", :dst-peer-id [:coordinator #uuid "94d8d5d7-5856-5025-5786-158432325fda"], :dst-session-id 674235127, :short-id 1, :status-session-id 674235134}
Starting Channels
Starting ZKClient
18-12-10 04:36:37 vath.local INFO [onyx.peer.coordinator:350] - Stopping coordinator on: 94d8d5d7-5856-5025-5786-158432325fda
version: '2'
services:
zoo1:
image: zookeeper:3.4.9
restart: unless-stopped
hostname: zoo1
ports:
- "2181:2181"
environment:

Keybase proof

I hereby claim:

  • I am lbradstreet on github.
  • I am lbradstreet (https://keybase.io/lbradstreet) on keybase.
  • I have a public key ASBUKrBU43JiTDLj-Hg6HyfPMXk3EI4wTgcFQ3cHEMofuAo

To claim this, I am signing this object:

--- service: name: sensor-counts
doc: "A streaming microservice."
operations:
- operation: readFromTopic
params:
topicId: << Fill me in >>
[779236.115026] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 -361206136 [-1][1:4]
[779236.135770] RECEIVE_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0
[779236.138427] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:4]
[779236.138563] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 -1576507014 [-1][0:5]
[779236.138717] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:5]
[779236.138729] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 814924295 [-1][2:3]
[779236.138784] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:3]
[779236.162943] CMD_IN_ADD_PUBLICATION [58/58]: aeron:udp?endpoint=localhost:40199 0 [8:10]
[779236.165131] SEND_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0
[779236.294991] CMD_OUT_PUBLICATION_READY [150/150]: 421743339:0 28 [10]
[779236.115026] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 -361206136 [-1][1:4]
[779236.135770] RECEIVE_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0
[779236.138427] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:4]
[779236.138563] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 -1576507014 [-1][0:5]
[779236.138717] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:5]
[779236.138729] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 814924295 [-1][2:3]
[779236.138784] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:3]
[779236.162943] CMD_IN_ADD_PUBLICATION [58/58]: aeron:udp?endpoint=localhost:40199 0 [8:10]
[779236.165131] SEND_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0
[779236.294991] CMD_OUT_PUBLICATION_READY [150/150]: 421743339:0 28 [10]
Command `n Control file /var/folders/d8/6x6y27ln2f702g56jzzh9h780000gn/T/aeron-lucas/cnc.dat
22:50:39 - Aeron Stat
=========================
0: 0 - Bytes sent
1: 0 - Bytes received
2: 0 - Failed offers to ReceiverProxy
3: 0 - Failed offers to SenderProxy
4: 0 - Failed offers to DriverConductorProxy
5: 0 - NAKs sent
6: 0 - NAKs received
[735197.279306] RECEIVE_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0
[735197.283190] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:3]
[735197.283439] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:2]
[735197.283504] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:5]
[735197.301572] SEND_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0
[735197.388816] CMD_OUT_PUBLICATION_READY [150/150]: -264882356:0 28 [10]
[735197.388960] CMD_OUT_PUBLICATION_READY [150/150]: -264882356:0 28 [9]
[735197.389026] CMD_OUT_PUBLICATION_READY [150/150]: -264882356:0 28 [11]
[735197.495163] CMD_OUT_PUBLICATION_READY [157/157]: -264882355:-41950782 31 [13]
[735197.580585] CMD_OUT_PUBLICATION_READY [157/157]: -264882354:-213634344 34 [15]
[726462.051452] RECEIVE_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0
[726462.054697] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:3]
[726462.054944] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:2]
[726462.055003] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:5]
[726462.071602] SEND_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0
[726462.250009] CMD_OUT_PUBLICATION_READY [150/150]: -120940798:0 28 [8]
[726462.250278] CMD_OUT_PUBLICATION_READY [150/150]: -120940798:0 28 [10]
[726462.250377] CMD_OUT_PUBLICATION_READY [150/150]: -120940798:0 28 [11]
[726462.400089] CMD_OUT_PUBLICATION_READY [156/156]: -120940797:101989262 31 [13]
[726462.492061] CMD_OUT_PUBLICATION_READY [156/156]: -120940796:164441944 34 [15]
kafka client metrics
; (.value
; (get (keys (into {} (map (juxt #(.name (key %)) val) (.metrics (:producer (:topic-producer (deref system)))))))
; "connection-count"))