search

uber-common / cadence-samples

Other
191 stars 92 forks source link

Add consistent query sample #51

Closed longquanzheng closed 2 years ago

longquanzheng commented 2 years ago 
(qlong-consistent-query) $./bin/consistentquery
2021-10-01T11:51:15.222-0700    INFO    common/sample_helper.go:109 Logger created.
2021-10-01T11:51:15.222-0700    DEBUG   common/factory.go:151   Creating RPC dispatcher outbound    {"ServiceName": "cadence-frontend", "HostPort": "127.0.0.1:7933"}
2021-10-01T11:51:15.229-0700    INFO    common/sample_helper.go:161 Domain successfully registered. {"Domain": "samples-domain"}
2021-10-01T11:51:15.237-0700    INFO    common/sample_helper.go:195 Started Workflow    {"WorkflowID": "query_4a90468e-98da-43b6-94f7-3e2d4f3803fa", "RunID": "36d89d98-aa0b-4c09-bcd2-5fa151ee0fa3"}
2021-10-01T11:51:15.248-0700    INFO    consistentquery/query_workflow.go:17    QueryWorkflow started   {"Domain": "samples-domain", "TaskList": "queryGroup", "WorkerID": "36233@IT-USA-25920@queryGroup", "WorkflowType": "main.queryWorkflow", "WorkflowID": "query_4a90468e-98da-43b6-94f7-3e2d4f3803fa", "RunID": "36d89d98-aa0b-4c09-bcd2-5fa151ee0fa3"}
2021-10-01T11:51:15.248-0700    DEBUG   internal/internal_event_handlers.go:571 NewTimer    {"Domain": "samples-domain", "TaskList": "queryGroup", "WorkerID": "36233@IT-USA-25920@queryGroup", "WorkflowType": "main.queryWorkflow", "WorkflowID": "query_4a90468e-98da-43b6-94f7-3e2d4f3803fa", "RunID": "36d89d98-aa0b-4c09-bcd2-5fa151ee0fa3", "TimerID": "0", "Duration": "2m0s"}
2021-10-01T11:51:15.452-0700    INFO    common/sample_helper.go:301 Received consistent query result.   {"Result": 0}
initial query result after started: 0
2021-10-01T11:51:15.475-0700    INFO    consistentquery/query_workflow.go:33    Received signal!    {"Domain": "samples-domain", "TaskList": "queryGroup", "WorkerID": "36233@IT-USA-25920@queryGroup", "WorkflowType": "main.queryWorkflow", "WorkflowID": "query_4a90468e-98da-43b6-94f7-3e2d4f3803fa", "RunID": "36d89d98-aa0b-4c09-bcd2-5fa151ee0fa3", "signal": "increase"}
2021-10-01T11:51:15.487-0700    INFO    common/sample_helper.go:301 Received consistent query result.   {"Result": 1}
query after 1 increase: 1
2021-10-01T11:51:15.505-0700    INFO    consistentquery/query_workflow.go:33    Received signal!    {"Domain": "samples-domain", "TaskList": "queryGroup", "WorkerID": "36233@IT-USA-25920@queryGroup", "WorkflowType": "main.queryWorkflow", "WorkflowID": "query_4a90468e-98da-43b6-94f7-3e2d4f3803fa", "RunID": "36d89d98-aa0b-4c09-bcd2-5fa151ee0fa3", "signal": "increase"}
2021-10-01T11:51:15.515-0700    INFO    consistentquery/query_workflow.go:33    Received signal!    {"Domain": "samples-domain", "TaskList": "queryGroup", "WorkerID": "36233@IT-USA-25920@queryGroup", "WorkflowType": "main.queryWorkflow", "WorkflowID": "query_4a90468e-98da-43b6-94f7-3e2d4f3803fa", "RunID": "36d89d98-aa0b-4c09-bcd2-5fa151ee0fa3", "signal": "increase"}
2021-10-01T11:51:15.525-0700    INFO    consistentquery/query_workflow.go:33    Received signal!    {"Domain": "samples-domain", "TaskList": "queryGroup", "WorkerID": "36233@IT-USA-25920@queryGroup", "WorkflowType": "main.queryWorkflow", "WorkflowID": "query_4a90468e-98da-43b6-94f7-3e2d4f3803fa", "RunID": "36d89d98-aa0b-4c09-bcd2-5fa151ee0fa3", "signal": "increase"}
2021-10-01T11:51:15.539-0700    INFO    consistentquery/query_workflow.go:33    Received signal!    {"Domain": "samples-domain", "TaskList": "queryGroup", "WorkerID": "36233@IT-USA-25920@queryGroup", "WorkflowType": "main.queryWorkflow", "WorkflowID": "query_4a90468e-98da-43b6-94f7-3e2d4f3803fa", "RunID": "36d89d98-aa0b-4c09-bcd2-5fa151ee0fa3", "signal": "increase"}
2021-10-01T11:51:15.554-0700    INFO    common/sample_helper.go:301 Received consistent query result.   {"Result": 5}
query after 1 +4 increase: 5
longquanzheng commented 2 years ago

@mkolodezny can you take a look at this one as well? thanks :D