metric

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)

Functions

func IncEventAdded

func IncEventAdded(value int, tenant string, group metapb.Group)

IncEventAdded inc event queue addded

func IncEventHandled

func IncEventHandled(value int, tenant string, group metapb.Group)

IncEventHandled inc event queue handled

func IncRequestFailed

func IncRequestFailed(t string)

IncRequestFailed inc request handled failed

func IncRequestReceived

func IncRequestReceived(t string)

IncRequestReceived inc request received

func IncRequestSucceed

func IncRequestSucceed(t string)

IncRequestSucceed inc request handled succeed

func IncStorageFailed

func IncStorageFailed()

IncStorageFailed storage failed

func IncUserMoved

func IncUserMoved(value uint64, tenant string)

IncUserMoved inc user moved

func IncWorkflowWorkerFailed

func IncWorkflowWorkerFailed()

IncWorkflowWorkerFailed workflow worker failed

func SetEventQueueSize

func SetEventQueueSize(max, removed uint64, tenant string, partition string, group metapb.Group)

SetEventQueueSize set event queue size

func SetQueueConsumerCompleted

func SetQueueConsumerCompleted(value uint64, tenant, partition, consumer string, group metapb.Group)

SetQueueConsumerCompleted set completed offset

func SetRunnersCount

func SetRunnersCount(value int)

SetRunnersCount set runners count

func SetWorkflowCount

func SetWorkflowCount(starting, started, stopping, stopped int)

SetWorkflowCount set workflow count

func SetWorkflowShardsCount

func SetWorkflowShardsCount(value int)

SetWorkflowShardsCount set workflow shard count