Documentation ¶
Index ¶
- func IncEventAdded(value int, tenant string, group metapb.Group)
- func IncEventHandled(value int, tenant string, group metapb.Group)
- func IncRequestFailed(t string)
- func IncRequestReceived(t string)
- func IncRequestSucceed(t string)
- func IncStorageFailed()
- func IncUserMoved(value uint64, tenant string)
- func IncWorkflowWorkerFailed()
- func SetEventQueueSize(max, removed uint64, tenant string, partition string, group metapb.Group)
- func SetQueueConsumerCompleted(value uint64, tenant, partition, consumer string, group metapb.Group)
- func SetRunnersCount(value int)
- func SetWorkflowCount(starting, started, stopping, stopped int)
- func SetWorkflowShardsCount(value int)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IncEventAdded ¶
IncEventAdded inc event queue addded
func IncEventHandled ¶
IncEventHandled inc event queue handled
func IncRequestSucceed ¶
func IncRequestSucceed(t string)
IncRequestSucceed inc request handled succeed
func IncWorkflowWorkerFailed ¶
func IncWorkflowWorkerFailed()
IncWorkflowWorkerFailed workflow worker failed
func SetEventQueueSize ¶
SetEventQueueSize set event queue size
func SetQueueConsumerCompleted ¶
func SetQueueConsumerCompleted(value uint64, tenant, partition, consumer string, group metapb.Group)
SetQueueConsumerCompleted set completed offset
func SetWorkflowCount ¶
func SetWorkflowCount(starting, started, stopping, stopped int)
SetWorkflowCount set workflow count
func SetWorkflowShardsCount ¶
func SetWorkflowShardsCount(value int)
SetWorkflowShardsCount set workflow shard count
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.