Documentation ¶
Index ¶
- Variables
- type BMLoader
- type CallbackAction
- func (*CallbackAction) Descriptor() ([]byte, []int)
- func (m *CallbackAction) GetSetKV() *SetKVAction
- func (m *CallbackAction) GetUpdateTenantInitState() *TenantInitStateUpdateAction
- func (m *CallbackAction) Marshal() (dAtA []byte, err error)
- func (m *CallbackAction) MarshalTo(dAtA []byte) (int, error)
- func (m *CallbackAction) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CallbackAction) ProtoMessage()
- func (m *CallbackAction) Reset()
- func (m *CallbackAction) Size() (n int)
- func (m *CallbackAction) String() string
- func (m *CallbackAction) Unmarshal(dAtA []byte) error
- func (m *CallbackAction) XXX_DiscardUnknown()
- func (m *CallbackAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CallbackAction) XXX_Merge(src proto.Message)
- func (m *CallbackAction) XXX_Size() int
- func (m *CallbackAction) XXX_Unmarshal(b []byte) error
- type ConditionExecution
- func (*ConditionExecution) Descriptor() ([]byte, []int)
- func (m *ConditionExecution) GetCondition() Expr
- func (m *ConditionExecution) GetExecution() *Execution
- func (m *ConditionExecution) GetNextStep() string
- func (m *ConditionExecution) Marshal() (dAtA []byte, err error)
- func (m *ConditionExecution) MarshalTo(dAtA []byte) (int, error)
- func (m *ConditionExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConditionExecution) ProtoMessage()
- func (m *ConditionExecution) Reset()
- func (m *ConditionExecution) Size() (n int)
- func (m *ConditionExecution) String() string
- func (m *ConditionExecution) Unmarshal(dAtA []byte) error
- func (m *ConditionExecution) XXX_DiscardUnknown()
- func (m *ConditionExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConditionExecution) XXX_Merge(src proto.Message)
- func (m *ConditionExecution) XXX_Size() int
- func (m *ConditionExecution) XXX_Unmarshal(b []byte) error
- type CountState
- func (*CountState) Descriptor() ([]byte, []int)
- func (m *CountState) GetCount() uint64
- func (m *CountState) GetStep() string
- func (m *CountState) Marshal() (dAtA []byte, err error)
- func (m *CountState) MarshalTo(dAtA []byte) (int, error)
- func (m *CountState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CountState) ProtoMessage()
- func (m *CountState) Reset()
- func (m *CountState) Size() (n int)
- func (m *CountState) String() string
- func (m *CountState) Unmarshal(dAtA []byte) error
- func (m *CountState) XXX_DiscardUnknown()
- func (m *CountState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CountState) XXX_Merge(src proto.Message)
- func (m *CountState) XXX_Size() int
- func (m *CountState) XXX_Unmarshal(b []byte) error
- type DirectExecution
- func (*DirectExecution) Descriptor() ([]byte, []int)
- func (m *DirectExecution) GetNextStep() string
- func (m *DirectExecution) Marshal() (dAtA []byte, err error)
- func (m *DirectExecution) MarshalTo(dAtA []byte) (int, error)
- func (m *DirectExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DirectExecution) ProtoMessage()
- func (m *DirectExecution) Reset()
- func (m *DirectExecution) Size() (n int)
- func (m *DirectExecution) String() string
- func (m *DirectExecution) Unmarshal(dAtA []byte) error
- func (m *DirectExecution) XXX_DiscardUnknown()
- func (m *DirectExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DirectExecution) XXX_Merge(src proto.Message)
- func (m *DirectExecution) XXX_Size() int
- func (m *DirectExecution) XXX_Unmarshal(b []byte) error
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetType() EventType
- func (m *Event) GetUpdateCrowd() *UpdateCrowdEvent
- func (m *Event) GetUpdateWorkflow() *UpdateWorkflowEvent
- func (m *Event) GetUser() *UserEvent
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (m *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type EventType
- type ExectuionType
- type Execution
- func (*Execution) Descriptor() ([]byte, []int)
- func (m *Execution) GetBranches() []ConditionExecution
- func (m *Execution) GetDirect() *DirectExecution
- func (m *Execution) GetParallel() ParallelExecution
- func (m *Execution) GetTimer() *TimerExecution
- func (m *Execution) GetType() ExectuionType
- func (m *Execution) Marshal() (dAtA []byte, err error)
- func (m *Execution) MarshalTo(dAtA []byte) (int, error)
- func (m *Execution) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Execution) ProtoMessage()
- func (m *Execution) Reset()
- func (m *Execution) Size() (n int)
- func (m *Execution) String() string
- func (m *Execution) Unmarshal(dAtA []byte) error
- func (m *Execution) XXX_DiscardUnknown()
- func (m *Execution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Execution) XXX_Merge(src proto.Message)
- func (m *Execution) XXX_Size() int
- func (m *Execution) XXX_Unmarshal(b []byte) error
- type Expr
- func (*Expr) Descriptor() ([]byte, []int)
- func (m *Expr) GetType() ExprResultType
- func (m *Expr) GetValue() []byte
- func (m *Expr) Marshal() (dAtA []byte, err error)
- func (m *Expr) MarshalTo(dAtA []byte) (int, error)
- func (m *Expr) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Expr) ProtoMessage()
- func (m *Expr) Reset()
- func (m *Expr) Size() (n int)
- func (m *Expr) String() string
- func (m *Expr) Unmarshal(dAtA []byte) error
- func (m *Expr) XXX_DiscardUnknown()
- func (m *Expr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Expr) XXX_Merge(src proto.Message)
- func (m *Expr) XXX_Size() int
- func (m *Expr) XXX_Unmarshal(b []byte) error
- type ExprResultType
- type Group
- type IDSet
- func (*IDSet) Descriptor() ([]byte, []int)
- func (m *IDSet) GetValues() []IDValue
- func (m *IDSet) Marshal() (dAtA []byte, err error)
- func (m *IDSet) MarshalTo(dAtA []byte) (int, error)
- func (m *IDSet) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IDSet) ProtoMessage()
- func (m *IDSet) Reset()
- func (m *IDSet) Size() (n int)
- func (m *IDSet) String() string
- func (m *IDSet) Unmarshal(dAtA []byte) error
- func (m *IDSet) XXX_DiscardUnknown()
- func (m *IDSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IDSet) XXX_Merge(src proto.Message)
- func (m *IDSet) XXX_Size() int
- func (m *IDSet) XXX_Unmarshal(b []byte) error
- type IDValue
- func (*IDValue) Descriptor() ([]byte, []int)
- func (m *IDValue) GetType() string
- func (m *IDValue) GetValue() string
- func (m *IDValue) Marshal() (dAtA []byte, err error)
- func (m *IDValue) MarshalTo(dAtA []byte) (int, error)
- func (m *IDValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IDValue) ProtoMessage()
- func (m *IDValue) Reset()
- func (m *IDValue) Size() (n int)
- func (m *IDValue) String() string
- func (m *IDValue) Unmarshal(dAtA []byte) error
- func (m *IDValue) XXX_DiscardUnknown()
- func (m *IDValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IDValue) XXX_Merge(src proto.Message)
- func (m *IDValue) XXX_Size() int
- func (m *IDValue) XXX_Unmarshal(b []byte) error
- type InstanceCountState
- func (*InstanceCountState) Descriptor() ([]byte, []int)
- func (m *InstanceCountState) GetSnapshot() Workflow
- func (m *InstanceCountState) GetStates() []CountState
- func (m *InstanceCountState) GetTotal() uint64
- func (m *InstanceCountState) Marshal() (dAtA []byte, err error)
- func (m *InstanceCountState) MarshalTo(dAtA []byte) (int, error)
- func (m *InstanceCountState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InstanceCountState) ProtoMessage()
- func (m *InstanceCountState) Reset()
- func (m *InstanceCountState) Size() (n int)
- func (m *InstanceCountState) String() string
- func (m *InstanceCountState) Unmarshal(dAtA []byte) error
- func (m *InstanceCountState) XXX_DiscardUnknown()
- func (m *InstanceCountState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InstanceCountState) XXX_Merge(src proto.Message)
- func (m *InstanceCountState) XXX_Size() int
- func (m *InstanceCountState) XXX_Unmarshal(b []byte) error
- type KV
- func (*KV) Descriptor() ([]byte, []int)
- func (m *KV) GetKey() []byte
- func (m *KV) GetValue() []byte
- func (m *KV) Marshal() (dAtA []byte, err error)
- func (m *KV) MarshalTo(dAtA []byte) (int, error)
- func (m *KV) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KV) ProtoMessage()
- func (m *KV) Reset()
- func (m *KV) Size() (n int)
- func (m *KV) String() string
- func (m *KV) Unmarshal(dAtA []byte) error
- func (m *KV) XXX_DiscardUnknown()
- func (m *KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KV) XXX_Merge(src proto.Message)
- func (m *KV) XXX_Size() int
- func (m *KV) XXX_Unmarshal(b []byte) error
- type Notify
- func (*Notify) Descriptor() ([]byte, []int)
- func (m *Notify) GetCrowd() []byte
- func (m *Notify) GetFromAction() string
- func (m *Notify) GetFromStep() string
- func (m *Notify) GetInstanceID() uint64
- func (m *Notify) GetTenantID() uint64
- func (m *Notify) GetToAction() string
- func (m *Notify) GetToStep() string
- func (m *Notify) GetToStepCycleTTL() int32
- func (m *Notify) GetUserID() uint32
- func (m *Notify) GetWorkflowID() uint64
- func (m *Notify) Marshal() (dAtA []byte, err error)
- func (m *Notify) MarshalTo(dAtA []byte) (int, error)
- func (m *Notify) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Notify) ProtoMessage()
- func (m *Notify) Reset()
- func (m *Notify) Size() (n int)
- func (m *Notify) String() string
- func (m *Notify) Unmarshal(dAtA []byte) error
- func (m *Notify) XXX_DiscardUnknown()
- func (m *Notify) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Notify) XXX_Merge(src proto.Message)
- func (m *Notify) XXX_Size() int
- func (m *Notify) XXX_Unmarshal(b []byte) error
- type ParallelExecution
- func (*ParallelExecution) Descriptor() ([]byte, []int)
- func (m *ParallelExecution) GetNextStep() string
- func (m *ParallelExecution) GetParallels() []Execution
- func (m *ParallelExecution) Marshal() (dAtA []byte, err error)
- func (m *ParallelExecution) MarshalTo(dAtA []byte) (int, error)
- func (m *ParallelExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ParallelExecution) ProtoMessage()
- func (m *ParallelExecution) Reset()
- func (m *ParallelExecution) Size() (n int)
- func (m *ParallelExecution) String() string
- func (m *ParallelExecution) Unmarshal(dAtA []byte) error
- func (m *ParallelExecution) XXX_DiscardUnknown()
- func (m *ParallelExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ParallelExecution) XXX_Merge(src proto.Message)
- func (m *ParallelExecution) XXX_Size() int
- func (m *ParallelExecution) XXX_Unmarshal(b []byte) error
- type Partiton
- func (*Partiton) Descriptor() ([]byte, []int)
- func (m *Partiton) GetConsumer() uint32
- func (m *Partiton) GetLastFetchTS() int64
- func (m *Partiton) GetVersion() uint64
- func (m *Partiton) Marshal() (dAtA []byte, err error)
- func (m *Partiton) MarshalTo(dAtA []byte) (int, error)
- func (m *Partiton) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Partiton) ProtoMessage()
- func (m *Partiton) Reset()
- func (m *Partiton) Size() (n int)
- func (m *Partiton) String() string
- func (m *Partiton) Unmarshal(dAtA []byte) error
- func (m *Partiton) XXX_DiscardUnknown()
- func (m *Partiton) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Partiton) XXX_Merge(src proto.Message)
- func (m *Partiton) XXX_Size() int
- func (m *Partiton) XXX_Unmarshal(b []byte) error
- type QueueState
- func (*QueueState) Descriptor() ([]byte, []int)
- func (m *QueueState) GetCleanBatch() uint64
- func (m *QueueState) GetConsumers() uint32
- func (m *QueueState) GetMaxAlive() int64
- func (m *QueueState) GetPartitions() uint32
- func (m *QueueState) GetStates() []Partiton
- func (m *QueueState) GetTimeout() int64
- func (m *QueueState) Marshal() (dAtA []byte, err error)
- func (m *QueueState) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueState) ProtoMessage()
- func (m *QueueState) Reset()
- func (m *QueueState) Size() (n int)
- func (m *QueueState) String() string
- func (m *QueueState) Unmarshal(dAtA []byte) error
- func (m *QueueState) XXX_DiscardUnknown()
- func (m *QueueState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueState) XXX_Merge(src proto.Message)
- func (m *QueueState) XXX_Size() int
- func (m *QueueState) XXX_Unmarshal(b []byte) error
- type SetKVAction
- func (*SetKVAction) Descriptor() ([]byte, []int)
- func (m *SetKVAction) GetGroup() Group
- func (m *SetKVAction) GetKV() KV
- func (m *SetKVAction) Marshal() (dAtA []byte, err error)
- func (m *SetKVAction) MarshalTo(dAtA []byte) (int, error)
- func (m *SetKVAction) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetKVAction) ProtoMessage()
- func (m *SetKVAction) Reset()
- func (m *SetKVAction) Size() (n int)
- func (m *SetKVAction) String() string
- func (m *SetKVAction) Unmarshal(dAtA []byte) error
- func (m *SetKVAction) XXX_DiscardUnknown()
- func (m *SetKVAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetKVAction) XXX_Merge(src proto.Message)
- func (m *SetKVAction) XXX_Size() int
- func (m *SetKVAction) XXX_Unmarshal(b []byte) error
- type ShardBitmapLoadMeta
- func (*ShardBitmapLoadMeta) Descriptor() ([]byte, []int)
- func (m *ShardBitmapLoadMeta) GetKey() []byte
- func (m *ShardBitmapLoadMeta) GetShards() uint32
- func (m *ShardBitmapLoadMeta) GetTotal() uint64
- func (m *ShardBitmapLoadMeta) Marshal() (dAtA []byte, err error)
- func (m *ShardBitmapLoadMeta) MarshalTo(dAtA []byte) (int, error)
- func (m *ShardBitmapLoadMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShardBitmapLoadMeta) ProtoMessage()
- func (m *ShardBitmapLoadMeta) Reset()
- func (m *ShardBitmapLoadMeta) Size() (n int)
- func (m *ShardBitmapLoadMeta) String() string
- func (m *ShardBitmapLoadMeta) Unmarshal(dAtA []byte) error
- func (m *ShardBitmapLoadMeta) XXX_DiscardUnknown()
- func (m *ShardBitmapLoadMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShardBitmapLoadMeta) XXX_Merge(src proto.Message)
- func (m *ShardBitmapLoadMeta) XXX_Size() int
- func (m *ShardBitmapLoadMeta) XXX_Unmarshal(b []byte) error
- type ShardBitmapPutMeta
- func (*ShardBitmapPutMeta) Descriptor() ([]byte, []int)
- func (m *ShardBitmapPutMeta) GetBytesPerShard() uint32
- func (m *ShardBitmapPutMeta) GetKey() []byte
- func (m *ShardBitmapPutMeta) GetTTL() uint32
- func (m *ShardBitmapPutMeta) Marshal() (dAtA []byte, err error)
- func (m *ShardBitmapPutMeta) MarshalTo(dAtA []byte) (int, error)
- func (m *ShardBitmapPutMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShardBitmapPutMeta) ProtoMessage()
- func (m *ShardBitmapPutMeta) Reset()
- func (m *ShardBitmapPutMeta) Size() (n int)
- func (m *ShardBitmapPutMeta) String() string
- func (m *ShardBitmapPutMeta) Unmarshal(dAtA []byte) error
- func (m *ShardBitmapPutMeta) XXX_DiscardUnknown()
- func (m *ShardBitmapPutMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShardBitmapPutMeta) XXX_Merge(src proto.Message)
- func (m *ShardBitmapPutMeta) XXX_Size() int
- func (m *ShardBitmapPutMeta) XXX_Unmarshal(b []byte) error
- type Step
- func (*Step) Descriptor() ([]byte, []int)
- func (m *Step) GetEnterAction() string
- func (m *Step) GetExecution() Execution
- func (m *Step) GetLeaveAction() string
- func (m *Step) GetName() string
- func (m *Step) GetTTL() int32
- func (m *Step) Marshal() (dAtA []byte, err error)
- func (m *Step) MarshalTo(dAtA []byte) (int, error)
- func (m *Step) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Step) ProtoMessage()
- func (m *Step) Reset()
- func (m *Step) Size() (n int)
- func (m *Step) String() string
- func (m *Step) Unmarshal(dAtA []byte) error
- func (m *Step) XXX_DiscardUnknown()
- func (m *Step) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Step) XXX_Merge(src proto.Message)
- func (m *Step) XXX_Size() int
- func (m *Step) XXX_Unmarshal(b []byte) error
- type StepState
- func (*StepState) Descriptor() ([]byte, []int)
- func (m *StepState) GetLoader() BMLoader
- func (m *StepState) GetLoaderMeta() []byte
- func (m *StepState) GetStep() Step
- func (m *StepState) GetTotalCrowd() uint64
- func (m *StepState) Marshal() (dAtA []byte, err error)
- func (m *StepState) MarshalTo(dAtA []byte) (int, error)
- func (m *StepState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StepState) ProtoMessage()
- func (m *StepState) Reset()
- func (m *StepState) Size() (n int)
- func (m *StepState) String() string
- func (m *StepState) Unmarshal(dAtA []byte) error
- func (m *StepState) XXX_DiscardUnknown()
- func (m *StepState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StepState) XXX_Merge(src proto.Message)
- func (m *StepState) XXX_Size() int
- func (m *StepState) XXX_Unmarshal(b []byte) error
- type Tenant
- func (*Tenant) Descriptor() ([]byte, []int)
- func (m *Tenant) GetID() uint64
- func (m *Tenant) GetInput() TenantQueue
- func (m *Tenant) GetInputsState() []bool
- func (m *Tenant) GetOutput() TenantQueue
- func (m *Tenant) GetOutputsState() []bool
- func (m *Tenant) GetRunners() uint64
- func (m *Tenant) GetRunnersState() []bool
- func (m *Tenant) Marshal() (dAtA []byte, err error)
- func (m *Tenant) MarshalTo(dAtA []byte) (int, error)
- func (m *Tenant) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Tenant) ProtoMessage()
- func (m *Tenant) Reset()
- func (m *Tenant) Size() (n int)
- func (m *Tenant) String() string
- func (m *Tenant) Unmarshal(dAtA []byte) error
- func (m *Tenant) XXX_DiscardUnknown()
- func (m *Tenant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Tenant) XXX_Merge(src proto.Message)
- func (m *Tenant) XXX_Size() int
- func (m *Tenant) XXX_Unmarshal(b []byte) error
- type TenantInitStateUpdateAction
- func (*TenantInitStateUpdateAction) Descriptor() ([]byte, []int)
- func (m *TenantInitStateUpdateAction) GetGroup() Group
- func (m *TenantInitStateUpdateAction) GetID() uint64
- func (m *TenantInitStateUpdateAction) GetIndex() int32
- func (m *TenantInitStateUpdateAction) Marshal() (dAtA []byte, err error)
- func (m *TenantInitStateUpdateAction) MarshalTo(dAtA []byte) (int, error)
- func (m *TenantInitStateUpdateAction) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TenantInitStateUpdateAction) ProtoMessage()
- func (m *TenantInitStateUpdateAction) Reset()
- func (m *TenantInitStateUpdateAction) Size() (n int)
- func (m *TenantInitStateUpdateAction) String() string
- func (m *TenantInitStateUpdateAction) Unmarshal(dAtA []byte) error
- func (m *TenantInitStateUpdateAction) XXX_DiscardUnknown()
- func (m *TenantInitStateUpdateAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TenantInitStateUpdateAction) XXX_Merge(src proto.Message)
- func (m *TenantInitStateUpdateAction) XXX_Size() int
- func (m *TenantInitStateUpdateAction) XXX_Unmarshal(b []byte) error
- type TenantQueue
- func (*TenantQueue) Descriptor() ([]byte, []int)
- func (m *TenantQueue) GetCleanBatch() uint64
- func (m *TenantQueue) GetConsumerTimeout() int64
- func (m *TenantQueue) GetMaxAlive() int64
- func (m *TenantQueue) GetPartitions() uint32
- func (m *TenantQueue) Marshal() (dAtA []byte, err error)
- func (m *TenantQueue) MarshalTo(dAtA []byte) (int, error)
- func (m *TenantQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TenantQueue) ProtoMessage()
- func (m *TenantQueue) Reset()
- func (m *TenantQueue) Size() (n int)
- func (m *TenantQueue) String() string
- func (m *TenantQueue) Unmarshal(dAtA []byte) error
- func (m *TenantQueue) XXX_DiscardUnknown()
- func (m *TenantQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TenantQueue) XXX_Merge(src proto.Message)
- func (m *TenantQueue) XXX_Size() int
- func (m *TenantQueue) XXX_Unmarshal(b []byte) error
- type TenantRunnerOffsets
- func (*TenantRunnerOffsets) Descriptor() ([]byte, []int)
- func (m *TenantRunnerOffsets) GetOffsets() []*TenantRunnerWorkerOffsets
- func (m *TenantRunnerOffsets) GetWorkers() []string
- func (m *TenantRunnerOffsets) Marshal() (dAtA []byte, err error)
- func (m *TenantRunnerOffsets) MarshalTo(dAtA []byte) (int, error)
- func (m *TenantRunnerOffsets) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TenantRunnerOffsets) ProtoMessage()
- func (m *TenantRunnerOffsets) Reset()
- func (m *TenantRunnerOffsets) Size() (n int)
- func (m *TenantRunnerOffsets) String() string
- func (m *TenantRunnerOffsets) Unmarshal(dAtA []byte) error
- func (m *TenantRunnerOffsets) XXX_DiscardUnknown()
- func (m *TenantRunnerOffsets) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TenantRunnerOffsets) XXX_Merge(src proto.Message)
- func (m *TenantRunnerOffsets) XXX_Size() int
- func (m *TenantRunnerOffsets) XXX_Unmarshal(b []byte) error
- type TenantRunnerWorkerOffsets
- func (*TenantRunnerWorkerOffsets) Descriptor() ([]byte, []int)
- func (m *TenantRunnerWorkerOffsets) GetOffsets() []uint64
- func (m *TenantRunnerWorkerOffsets) Marshal() (dAtA []byte, err error)
- func (m *TenantRunnerWorkerOffsets) MarshalTo(dAtA []byte) (int, error)
- func (m *TenantRunnerWorkerOffsets) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TenantRunnerWorkerOffsets) ProtoMessage()
- func (m *TenantRunnerWorkerOffsets) Reset()
- func (m *TenantRunnerWorkerOffsets) Size() (n int)
- func (m *TenantRunnerWorkerOffsets) String() string
- func (m *TenantRunnerWorkerOffsets) Unmarshal(dAtA []byte) error
- func (m *TenantRunnerWorkerOffsets) XXX_DiscardUnknown()
- func (m *TenantRunnerWorkerOffsets) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TenantRunnerWorkerOffsets) XXX_Merge(src proto.Message)
- func (m *TenantRunnerWorkerOffsets) XXX_Size() int
- func (m *TenantRunnerWorkerOffsets) XXX_Unmarshal(b []byte) error
- type TimerExecution
- func (*TimerExecution) Descriptor() ([]byte, []int)
- func (m *TimerExecution) GetCondition() *Expr
- func (m *TimerExecution) GetCron() string
- func (m *TimerExecution) GetNextStep() string
- func (m *TimerExecution) GetUseStepCrowdToDrive() bool
- func (m *TimerExecution) Marshal() (dAtA []byte, err error)
- func (m *TimerExecution) MarshalTo(dAtA []byte) (int, error)
- func (m *TimerExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TimerExecution) ProtoMessage()
- func (m *TimerExecution) Reset()
- func (m *TimerExecution) Size() (n int)
- func (m *TimerExecution) String() string
- func (m *TimerExecution) Unmarshal(dAtA []byte) error
- func (m *TimerExecution) XXX_DiscardUnknown()
- func (m *TimerExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimerExecution) XXX_Merge(src proto.Message)
- func (m *TimerExecution) XXX_Size() int
- func (m *TimerExecution) XXX_Unmarshal(b []byte) error
- type UpdateCrowdEvent
- func (*UpdateCrowdEvent) Descriptor() ([]byte, []int)
- func (m *UpdateCrowdEvent) GetCrowd() []byte
- func (m *UpdateCrowdEvent) GetIndex() uint32
- func (m *UpdateCrowdEvent) GetWorkflowID() uint64
- func (m *UpdateCrowdEvent) Marshal() (dAtA []byte, err error)
- func (m *UpdateCrowdEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateCrowdEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateCrowdEvent) ProtoMessage()
- func (m *UpdateCrowdEvent) Reset()
- func (m *UpdateCrowdEvent) Size() (n int)
- func (m *UpdateCrowdEvent) String() string
- func (m *UpdateCrowdEvent) Unmarshal(dAtA []byte) error
- func (m *UpdateCrowdEvent) XXX_DiscardUnknown()
- func (m *UpdateCrowdEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateCrowdEvent) XXX_Merge(src proto.Message)
- func (m *UpdateCrowdEvent) XXX_Size() int
- func (m *UpdateCrowdEvent) XXX_Unmarshal(b []byte) error
- type UpdateWorkflowEvent
- func (*UpdateWorkflowEvent) Descriptor() ([]byte, []int)
- func (m *UpdateWorkflowEvent) GetWorkflow() Workflow
- func (m *UpdateWorkflowEvent) Marshal() (dAtA []byte, err error)
- func (m *UpdateWorkflowEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateWorkflowEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateWorkflowEvent) ProtoMessage()
- func (m *UpdateWorkflowEvent) Reset()
- func (m *UpdateWorkflowEvent) Size() (n int)
- func (m *UpdateWorkflowEvent) String() string
- func (m *UpdateWorkflowEvent) Unmarshal(dAtA []byte) error
- func (m *UpdateWorkflowEvent) XXX_DiscardUnknown()
- func (m *UpdateWorkflowEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateWorkflowEvent) XXX_Merge(src proto.Message)
- func (m *UpdateWorkflowEvent) XXX_Size() int
- func (m *UpdateWorkflowEvent) XXX_Unmarshal(b []byte) error
- type UserEvent
- func (*UserEvent) Descriptor() ([]byte, []int)
- func (m *UserEvent) GetData() []KV
- func (m *UserEvent) GetTenantID() uint64
- func (m *UserEvent) GetUserID() uint32
- func (m *UserEvent) Marshal() (dAtA []byte, err error)
- func (m *UserEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *UserEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UserEvent) ProtoMessage()
- func (m *UserEvent) Reset()
- func (m *UserEvent) Size() (n int)
- func (m *UserEvent) String() string
- func (m *UserEvent) Unmarshal(dAtA []byte) error
- func (m *UserEvent) XXX_DiscardUnknown()
- func (m *UserEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UserEvent) XXX_Merge(src proto.Message)
- func (m *UserEvent) XXX_Size() int
- func (m *UserEvent) XXX_Unmarshal(b []byte) error
- type WorkerRunner
- func (*WorkerRunner) Descriptor() ([]byte, []int)
- func (m *WorkerRunner) GetID() uint64
- func (m *WorkerRunner) GetIndex() uint64
- func (m *WorkerRunner) GetState() WorkerRunnerState
- func (m *WorkerRunner) GetTotalCrowd() uint64
- func (m *WorkerRunner) GetWorkers() []WorkflowWorker
- func (m *WorkerRunner) Marshal() (dAtA []byte, err error)
- func (m *WorkerRunner) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkerRunner) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkerRunner) ProtoMessage()
- func (m *WorkerRunner) Reset()
- func (m *WorkerRunner) Size() (n int)
- func (m *WorkerRunner) String() string
- func (m *WorkerRunner) Unmarshal(dAtA []byte) error
- func (m *WorkerRunner) XXX_DiscardUnknown()
- func (m *WorkerRunner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkerRunner) XXX_Merge(src proto.Message)
- func (m *WorkerRunner) XXX_Size() int
- func (m *WorkerRunner) XXX_Unmarshal(b []byte) error
- type WorkerRunnerState
- type Workflow
- func (*Workflow) Descriptor() ([]byte, []int)
- func (m *Workflow) GetID() uint64
- func (m *Workflow) GetName() string
- func (m *Workflow) GetSteps() []Step
- func (m *Workflow) GetStopAt() int64
- func (m *Workflow) GetTenantID() uint64
- func (m *Workflow) Marshal() (dAtA []byte, err error)
- func (m *Workflow) MarshalTo(dAtA []byte) (int, error)
- func (m *Workflow) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Workflow) ProtoMessage()
- func (m *Workflow) Reset()
- func (m *Workflow) Size() (n int)
- func (m *Workflow) String() string
- func (m *Workflow) Unmarshal(dAtA []byte) error
- func (m *Workflow) XXX_DiscardUnknown()
- func (m *Workflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Workflow) XXX_Merge(src proto.Message)
- func (m *Workflow) XXX_Size() int
- func (m *Workflow) XXX_Unmarshal(b []byte) error
- type WorkflowInstance
- func (*WorkflowInstance) Descriptor() ([]byte, []int)
- func (m *WorkflowInstance) GetInstanceID() uint64
- func (m *WorkflowInstance) GetLoader() BMLoader
- func (m *WorkflowInstance) GetLoaderMeta() []byte
- func (m *WorkflowInstance) GetSnapshot() Workflow
- func (m *WorkflowInstance) GetStartedAt() int64
- func (m *WorkflowInstance) GetState() WorkflowInstanceState
- func (m *WorkflowInstance) GetStoppedAt() int64
- func (m *WorkflowInstance) GetTotalCrowd() uint64
- func (m *WorkflowInstance) GetVersion() uint64
- func (m *WorkflowInstance) Marshal() (dAtA []byte, err error)
- func (m *WorkflowInstance) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowInstance) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowInstance) ProtoMessage()
- func (m *WorkflowInstance) Reset()
- func (m *WorkflowInstance) Size() (n int)
- func (m *WorkflowInstance) String() string
- func (m *WorkflowInstance) Unmarshal(dAtA []byte) error
- func (m *WorkflowInstance) XXX_DiscardUnknown()
- func (m *WorkflowInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowInstance) XXX_Merge(src proto.Message)
- func (m *WorkflowInstance) XXX_Size() int
- func (m *WorkflowInstance) XXX_Unmarshal(b []byte) error
- type WorkflowInstanceSnapshot
- func (*WorkflowInstanceSnapshot) Descriptor() ([]byte, []int)
- func (m *WorkflowInstanceSnapshot) GetSnapshot() WorkflowInstance
- func (m *WorkflowInstanceSnapshot) GetStates() []StepState
- func (m *WorkflowInstanceSnapshot) GetTimestamp() int64
- func (m *WorkflowInstanceSnapshot) Marshal() (dAtA []byte, err error)
- func (m *WorkflowInstanceSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowInstanceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowInstanceSnapshot) ProtoMessage()
- func (m *WorkflowInstanceSnapshot) Reset()
- func (m *WorkflowInstanceSnapshot) Size() (n int)
- func (m *WorkflowInstanceSnapshot) String() string
- func (m *WorkflowInstanceSnapshot) Unmarshal(dAtA []byte) error
- func (m *WorkflowInstanceSnapshot) XXX_DiscardUnknown()
- func (m *WorkflowInstanceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowInstanceSnapshot) XXX_Merge(src proto.Message)
- func (m *WorkflowInstanceSnapshot) XXX_Size() int
- func (m *WorkflowInstanceSnapshot) XXX_Unmarshal(b []byte) error
- type WorkflowInstanceState
- type WorkflowInstanceWorkerState
- func (*WorkflowInstanceWorkerState) Descriptor() ([]byte, []int)
- func (m *WorkflowInstanceWorkerState) GetIndex() uint32
- func (m *WorkflowInstanceWorkerState) GetInstanceID() uint64
- func (m *WorkflowInstanceWorkerState) GetRunner() uint64
- func (m *WorkflowInstanceWorkerState) GetStates() []StepState
- func (m *WorkflowInstanceWorkerState) GetStopAt() int64
- func (m *WorkflowInstanceWorkerState) GetTenantID() uint64
- func (m *WorkflowInstanceWorkerState) GetVersion() uint64
- func (m *WorkflowInstanceWorkerState) GetWorkflowID() uint64
- func (m *WorkflowInstanceWorkerState) Marshal() (dAtA []byte, err error)
- func (m *WorkflowInstanceWorkerState) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowInstanceWorkerState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowInstanceWorkerState) ProtoMessage()
- func (m *WorkflowInstanceWorkerState) Reset()
- func (m *WorkflowInstanceWorkerState) Size() (n int)
- func (m *WorkflowInstanceWorkerState) String() string
- func (m *WorkflowInstanceWorkerState) Unmarshal(dAtA []byte) error
- func (m *WorkflowInstanceWorkerState) XXX_DiscardUnknown()
- func (m *WorkflowInstanceWorkerState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowInstanceWorkerState) XXX_Merge(src proto.Message)
- func (m *WorkflowInstanceWorkerState) XXX_Size() int
- func (m *WorkflowInstanceWorkerState) XXX_Unmarshal(b []byte) error
- type WorkflowWorker
- func (*WorkflowWorker) Descriptor() ([]byte, []int)
- func (m *WorkflowWorker) GetIndex() uint32
- func (m *WorkflowWorker) GetInstanceID() uint64
- func (m *WorkflowWorker) GetWorkflowID() uint64
- func (m *WorkflowWorker) Marshal() (dAtA []byte, err error)
- func (m *WorkflowWorker) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkflowWorker) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkflowWorker) ProtoMessage()
- func (m *WorkflowWorker) Reset()
- func (m *WorkflowWorker) Size() (n int)
- func (m *WorkflowWorker) String() string
- func (m *WorkflowWorker) Unmarshal(dAtA []byte) error
- func (m *WorkflowWorker) XXX_DiscardUnknown()
- func (m *WorkflowWorker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkflowWorker) XXX_Merge(src proto.Message)
- func (m *WorkflowWorker) XXX_Size() int
- func (m *WorkflowWorker) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthMeta = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMeta = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMeta = fmt.Errorf("proto: unexpected end of group") )
var BMLoader_name = map[int32]string{
0: "RawLoader",
1: "KVLoader",
2: "KVShardLoader",
3: "ClickhouseLoader",
}
var BMLoader_value = map[string]int32{
"RawLoader": 0,
"KVLoader": 1,
"KVShardLoader": 2,
"ClickhouseLoader": 3,
}
var EventType_name = map[int32]string{
0: "UserType",
1: "UpdateCrowdType",
2: "UpdateWorkflowType",
}
var EventType_value = map[string]int32{
"UserType": 0,
"UpdateCrowdType": 1,
"UpdateWorkflowType": 2,
}
var ExectuionType_name = map[int32]string{
0: "Direct",
1: "Timer",
2: "Branch",
3: "Parallel",
}
var ExectuionType_value = map[string]int32{
"Direct": 0,
"Timer": 1,
"Branch": 2,
"Parallel": 3,
}
var ExprResultType_name = map[int32]string{
0: "BoolResult",
1: "BMResult",
}
var ExprResultType_value = map[string]int32{
"BoolResult": 0,
"BMResult": 1,
}
var Group_name = map[int32]string{
0: "DefaultGroup",
1: "TenantInputGroup",
2: "TenantOutputGroup",
3: "TenantRunnerGroup",
}
var Group_value = map[string]int32{
"DefaultGroup": 0,
"TenantInputGroup": 1,
"TenantOutputGroup": 2,
"TenantRunnerGroup": 3,
}
var WorkerRunnerState_name = map[int32]string{
0: "WRRunning",
1: "WRStopped",
}
var WorkerRunnerState_value = map[string]int32{
"WRRunning": 0,
"WRStopped": 1,
}
var WorkflowInstanceState_name = map[int32]string{
0: "Starting",
1: "Running",
2: "Stopping",
3: "Stopped",
}
var WorkflowInstanceState_value = map[string]int32{
"Starting": 0,
"Running": 1,
"Stopping": 2,
"Stopped": 3,
}
Functions ¶
This section is empty.
Types ¶
type CallbackAction ¶
type CallbackAction struct { SetKV *SetKVAction `protobuf:"bytes,1,opt,name=setKV,proto3" json:"setKV,omitempty"` UpdateTenantInitState *TenantInitStateUpdateAction `protobuf:"bytes,2,opt,name=updateTenantInitState,proto3" json:"updateTenantInitState,omitempty"` }
message CallbackAction
func (*CallbackAction) Descriptor ¶
func (*CallbackAction) Descriptor() ([]byte, []int)
func (*CallbackAction) GetSetKV ¶
func (m *CallbackAction) GetSetKV() *SetKVAction
func (*CallbackAction) GetUpdateTenantInitState ¶
func (m *CallbackAction) GetUpdateTenantInitState() *TenantInitStateUpdateAction
func (*CallbackAction) Marshal ¶
func (m *CallbackAction) Marshal() (dAtA []byte, err error)
func (*CallbackAction) MarshalToSizedBuffer ¶
func (m *CallbackAction) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CallbackAction) ProtoMessage ¶
func (*CallbackAction) ProtoMessage()
func (*CallbackAction) Reset ¶
func (m *CallbackAction) Reset()
func (*CallbackAction) Size ¶
func (m *CallbackAction) Size() (n int)
func (*CallbackAction) String ¶
func (m *CallbackAction) String() string
func (*CallbackAction) Unmarshal ¶
func (m *CallbackAction) Unmarshal(dAtA []byte) error
func (*CallbackAction) XXX_DiscardUnknown ¶
func (m *CallbackAction) XXX_DiscardUnknown()
func (*CallbackAction) XXX_Marshal ¶
func (m *CallbackAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CallbackAction) XXX_Merge ¶
func (m *CallbackAction) XXX_Merge(src proto.Message)
func (*CallbackAction) XXX_Size ¶
func (m *CallbackAction) XXX_Size() int
func (*CallbackAction) XXX_Unmarshal ¶
func (m *CallbackAction) XXX_Unmarshal(b []byte) error
type ConditionExecution ¶
type ConditionExecution struct { Condition Expr `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition"` Execution *Execution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"` NextStep string `protobuf:"bytes,3,opt,name=nextStep,proto3" json:"nextStep,omitempty"` }
ConditionExecution is selecting multiple operations to satisfy the operation of the conditional operation
func (*ConditionExecution) Descriptor ¶
func (*ConditionExecution) Descriptor() ([]byte, []int)
func (*ConditionExecution) GetCondition ¶
func (m *ConditionExecution) GetCondition() Expr
func (*ConditionExecution) GetExecution ¶
func (m *ConditionExecution) GetExecution() *Execution
func (*ConditionExecution) GetNextStep ¶
func (m *ConditionExecution) GetNextStep() string
func (*ConditionExecution) Marshal ¶
func (m *ConditionExecution) Marshal() (dAtA []byte, err error)
func (*ConditionExecution) MarshalTo ¶
func (m *ConditionExecution) MarshalTo(dAtA []byte) (int, error)
func (*ConditionExecution) MarshalToSizedBuffer ¶
func (m *ConditionExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConditionExecution) ProtoMessage ¶
func (*ConditionExecution) ProtoMessage()
func (*ConditionExecution) Reset ¶
func (m *ConditionExecution) Reset()
func (*ConditionExecution) Size ¶
func (m *ConditionExecution) Size() (n int)
func (*ConditionExecution) String ¶
func (m *ConditionExecution) String() string
func (*ConditionExecution) Unmarshal ¶
func (m *ConditionExecution) Unmarshal(dAtA []byte) error
func (*ConditionExecution) XXX_DiscardUnknown ¶
func (m *ConditionExecution) XXX_DiscardUnknown()
func (*ConditionExecution) XXX_Marshal ¶
func (m *ConditionExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConditionExecution) XXX_Merge ¶
func (m *ConditionExecution) XXX_Merge(src proto.Message)
func (*ConditionExecution) XXX_Size ¶
func (m *ConditionExecution) XXX_Size() int
func (*ConditionExecution) XXX_Unmarshal ¶
func (m *ConditionExecution) XXX_Unmarshal(b []byte) error
type CountState ¶
type CountState struct { Step string `protobuf:"bytes,1,opt,name=step,proto3" json:"step,omitempty"` Count uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` }
CountState step count state
func (*CountState) Descriptor ¶
func (*CountState) Descriptor() ([]byte, []int)
func (*CountState) GetCount ¶
func (m *CountState) GetCount() uint64
func (*CountState) GetStep ¶
func (m *CountState) GetStep() string
func (*CountState) Marshal ¶
func (m *CountState) Marshal() (dAtA []byte, err error)
func (*CountState) MarshalToSizedBuffer ¶
func (m *CountState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CountState) ProtoMessage ¶
func (*CountState) ProtoMessage()
func (*CountState) Reset ¶
func (m *CountState) Reset()
func (*CountState) Size ¶
func (m *CountState) Size() (n int)
func (*CountState) String ¶
func (m *CountState) String() string
func (*CountState) Unmarshal ¶
func (m *CountState) Unmarshal(dAtA []byte) error
func (*CountState) XXX_DiscardUnknown ¶
func (m *CountState) XXX_DiscardUnknown()
func (*CountState) XXX_Marshal ¶
func (m *CountState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CountState) XXX_Merge ¶
func (m *CountState) XXX_Merge(src proto.Message)
func (*CountState) XXX_Size ¶
func (m *CountState) XXX_Size() int
func (*CountState) XXX_Unmarshal ¶
func (m *CountState) XXX_Unmarshal(b []byte) error
type DirectExecution ¶
type DirectExecution struct {
NextStep string `protobuf:"bytes,1,opt,name=nextStep,proto3" json:"nextStep,omitempty"`
}
DirectExecution is a directly performable operation
func (*DirectExecution) Descriptor ¶
func (*DirectExecution) Descriptor() ([]byte, []int)
func (*DirectExecution) GetNextStep ¶
func (m *DirectExecution) GetNextStep() string
func (*DirectExecution) Marshal ¶
func (m *DirectExecution) Marshal() (dAtA []byte, err error)
func (*DirectExecution) MarshalToSizedBuffer ¶
func (m *DirectExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DirectExecution) ProtoMessage ¶
func (*DirectExecution) ProtoMessage()
func (*DirectExecution) Reset ¶
func (m *DirectExecution) Reset()
func (*DirectExecution) Size ¶
func (m *DirectExecution) Size() (n int)
func (*DirectExecution) String ¶
func (m *DirectExecution) String() string
func (*DirectExecution) Unmarshal ¶
func (m *DirectExecution) Unmarshal(dAtA []byte) error
func (*DirectExecution) XXX_DiscardUnknown ¶
func (m *DirectExecution) XXX_DiscardUnknown()
func (*DirectExecution) XXX_Marshal ¶
func (m *DirectExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DirectExecution) XXX_Merge ¶
func (m *DirectExecution) XXX_Merge(src proto.Message)
func (*DirectExecution) XXX_Size ¶
func (m *DirectExecution) XXX_Size() int
func (*DirectExecution) XXX_Unmarshal ¶
func (m *DirectExecution) XXX_Unmarshal(b []byte) error
type Event ¶
type Event struct { Type EventType `protobuf:"varint,1,opt,name=type,proto3,enum=metapb.EventType" json:"type,omitempty"` User *UserEvent `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` UpdateCrowd *UpdateCrowdEvent `protobuf:"bytes,3,opt,name=updateCrowd,proto3" json:"updateCrowd,omitempty"` UpdateWorkflow *UpdateWorkflowEvent `protobuf:"bytes,4,opt,name=updateWorkflow,proto3" json:"updateWorkflow,omitempty"` }
Event tenant event
func (*Event) Descriptor ¶
func (*Event) GetUpdateCrowd ¶
func (m *Event) GetUpdateCrowd() *UpdateCrowdEvent
func (*Event) GetUpdateWorkflow ¶
func (m *Event) GetUpdateWorkflow() *UpdateWorkflowEvent
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
type EventType ¶
type EventType int32
EventType tenant input event type
func (EventType) EnumDescriptor ¶
type ExectuionType ¶
type ExectuionType int32
ExectuionType is is the type of a execution operation
const ( // Direct is an executable operation. Direct ExectuionType = 0 // Timer is an timer executable. Timer ExectuionType = 1 // Branch contains several of the operations that will be performed if certain conditions are met. Branch ExectuionType = 2 // Parallel contains multiple sets of operations that can be executed concurrently. Parallel ExectuionType = 3 )
func (ExectuionType) EnumDescriptor ¶
func (ExectuionType) EnumDescriptor() ([]byte, []int)
func (ExectuionType) String ¶
func (x ExectuionType) String() string
type Execution ¶
type Execution struct { Type ExectuionType `protobuf:"varint,1,opt,name=type,proto3,enum=metapb.ExectuionType" json:"type,omitempty"` Timer *TimerExecution `protobuf:"bytes,2,opt,name=timer,proto3" json:"timer,omitempty"` Direct *DirectExecution `protobuf:"bytes,3,opt,name=direct,proto3" json:"direct,omitempty"` Branches []ConditionExecution `protobuf:"bytes,4,rep,name=branches,proto3" json:"branches"` Parallel ParallelExecution `protobuf:"bytes,5,opt,name=parallel,proto3" json:"parallel"` }
Execution is node operation in a seqence of executions. A node may have the following roles: 1. DirectExecution 2. BranchExecution 3. ParallelExecution
func (*Execution) Descriptor ¶
func (*Execution) GetBranches ¶
func (m *Execution) GetBranches() []ConditionExecution
func (*Execution) GetDirect ¶
func (m *Execution) GetDirect() *DirectExecution
func (*Execution) GetParallel ¶
func (m *Execution) GetParallel() ParallelExecution
func (*Execution) GetTimer ¶
func (m *Execution) GetTimer() *TimerExecution
func (*Execution) GetType ¶
func (m *Execution) GetType() ExectuionType
func (*Execution) MarshalToSizedBuffer ¶
func (*Execution) ProtoMessage ¶
func (*Execution) ProtoMessage()
func (*Execution) XXX_DiscardUnknown ¶
func (m *Execution) XXX_DiscardUnknown()
func (*Execution) XXX_Marshal ¶
func (*Execution) XXX_Unmarshal ¶
type Expr ¶
type Expr struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` Type ExprResultType `protobuf:"varint,2,opt,name=type,proto3,enum=metapb.ExprResultType" json:"type,omitempty"` }
Expr expr
func (*Expr) Descriptor ¶
func (*Expr) GetType ¶
func (m *Expr) GetType() ExprResultType
func (*Expr) ProtoMessage ¶
func (*Expr) ProtoMessage()
func (*Expr) XXX_DiscardUnknown ¶
func (m *Expr) XXX_DiscardUnknown()
func (*Expr) XXX_Unmarshal ¶
type ExprResultType ¶
type ExprResultType int32
ExprResultType expr execute type
const ( BoolResult ExprResultType = 0 BMResult ExprResultType = 1 )
func (ExprResultType) EnumDescriptor ¶
func (ExprResultType) EnumDescriptor() ([]byte, []int)
func (ExprResultType) String ¶
func (x ExprResultType) String() string
type IDSet ¶
type IDSet struct {
Values []IDValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values"`
}
IDSet id set
func (*IDSet) Descriptor ¶
func (*IDSet) ProtoMessage ¶
func (*IDSet) ProtoMessage()
func (*IDSet) XXX_DiscardUnknown ¶
func (m *IDSet) XXX_DiscardUnknown()
func (*IDSet) XXX_Marshal ¶
func (*IDSet) XXX_Unmarshal ¶
type IDValue ¶
type IDValue struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` }
IDValue is a id value
func (*IDValue) Descriptor ¶
func (*IDValue) MarshalToSizedBuffer ¶
func (*IDValue) ProtoMessage ¶
func (*IDValue) ProtoMessage()
func (*IDValue) XXX_DiscardUnknown ¶
func (m *IDValue) XXX_DiscardUnknown()
func (*IDValue) XXX_Marshal ¶
func (*IDValue) XXX_Unmarshal ¶
type InstanceCountState ¶
type InstanceCountState struct { Snapshot Workflow `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot"` States []CountState `protobuf:"bytes,2,rep,name=states,proto3" json:"states"` Total uint64 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"` }
InstanceCountState active instance count state
func (*InstanceCountState) Descriptor ¶
func (*InstanceCountState) Descriptor() ([]byte, []int)
func (*InstanceCountState) GetSnapshot ¶
func (m *InstanceCountState) GetSnapshot() Workflow
func (*InstanceCountState) GetStates ¶
func (m *InstanceCountState) GetStates() []CountState
func (*InstanceCountState) GetTotal ¶
func (m *InstanceCountState) GetTotal() uint64
func (*InstanceCountState) Marshal ¶
func (m *InstanceCountState) Marshal() (dAtA []byte, err error)
func (*InstanceCountState) MarshalTo ¶
func (m *InstanceCountState) MarshalTo(dAtA []byte) (int, error)
func (*InstanceCountState) MarshalToSizedBuffer ¶
func (m *InstanceCountState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InstanceCountState) ProtoMessage ¶
func (*InstanceCountState) ProtoMessage()
func (*InstanceCountState) Reset ¶
func (m *InstanceCountState) Reset()
func (*InstanceCountState) Size ¶
func (m *InstanceCountState) Size() (n int)
func (*InstanceCountState) String ¶
func (m *InstanceCountState) String() string
func (*InstanceCountState) Unmarshal ¶
func (m *InstanceCountState) Unmarshal(dAtA []byte) error
func (*InstanceCountState) XXX_DiscardUnknown ¶
func (m *InstanceCountState) XXX_DiscardUnknown()
func (*InstanceCountState) XXX_Marshal ¶
func (m *InstanceCountState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InstanceCountState) XXX_Merge ¶
func (m *InstanceCountState) XXX_Merge(src proto.Message)
func (*InstanceCountState) XXX_Size ¶
func (m *InstanceCountState) XXX_Size() int
func (*InstanceCountState) XXX_Unmarshal ¶
func (m *InstanceCountState) XXX_Unmarshal(b []byte) error
type KV ¶
type KV struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
KV custom KV data
func (*KV) Descriptor ¶
func (*KV) ProtoMessage ¶
func (*KV) ProtoMessage()
func (*KV) XXX_DiscardUnknown ¶
func (m *KV) XXX_DiscardUnknown()
func (*KV) XXX_Unmarshal ¶
type Notify ¶
type Notify struct { UserID uint32 `protobuf:"varint,1,opt,name=userID,proto3" json:"userID,omitempty"` Crowd []byte `protobuf:"bytes,2,opt,name=crowd,proto3" json:"crowd,omitempty"` TenantID uint64 `protobuf:"varint,3,opt,name=tenantID,proto3" json:"tenantID,omitempty"` WorkflowID uint64 `protobuf:"varint,4,opt,name=workflowID,proto3" json:"workflowID,omitempty"` InstanceID uint64 `protobuf:"varint,5,opt,name=instanceID,proto3" json:"instanceID,omitempty"` FromStep string `protobuf:"bytes,6,opt,name=fromStep,proto3" json:"fromStep,omitempty"` FromAction string `protobuf:"bytes,7,opt,name=fromAction,proto3" json:"fromAction,omitempty"` ToStep string `protobuf:"bytes,8,opt,name=toStep,proto3" json:"toStep,omitempty"` ToAction string `protobuf:"bytes,9,opt,name=toAction,proto3" json:"toAction,omitempty"` ToStepCycleTTL int32 `protobuf:"varint,10,opt,name=toStepCycleTTL,proto3" json:"toStepCycleTTL,omitempty"` }
Notify notify message
func (*Notify) Descriptor ¶
func (*Notify) GetFromAction ¶
func (*Notify) GetFromStep ¶
func (*Notify) GetInstanceID ¶
func (*Notify) GetTenantID ¶
func (*Notify) GetToAction ¶
func (*Notify) GetToStepCycleTTL ¶
func (*Notify) GetWorkflowID ¶
func (*Notify) MarshalToSizedBuffer ¶
func (*Notify) ProtoMessage ¶
func (*Notify) ProtoMessage()
func (*Notify) XXX_DiscardUnknown ¶
func (m *Notify) XXX_DiscardUnknown()
func (*Notify) XXX_Marshal ¶
func (*Notify) XXX_Unmarshal ¶
type ParallelExecution ¶
type ParallelExecution struct { NextStep string `protobuf:"bytes,1,opt,name=nextStep,proto3" json:"nextStep,omitempty"` Parallels []Execution `protobuf:"bytes,2,rep,name=parallels,proto3" json:"parallels"` }
ParallelExecution is a parallel execution
func (*ParallelExecution) Descriptor ¶
func (*ParallelExecution) Descriptor() ([]byte, []int)
func (*ParallelExecution) GetNextStep ¶
func (m *ParallelExecution) GetNextStep() string
func (*ParallelExecution) GetParallels ¶
func (m *ParallelExecution) GetParallels() []Execution
func (*ParallelExecution) Marshal ¶
func (m *ParallelExecution) Marshal() (dAtA []byte, err error)
func (*ParallelExecution) MarshalTo ¶
func (m *ParallelExecution) MarshalTo(dAtA []byte) (int, error)
func (*ParallelExecution) MarshalToSizedBuffer ¶
func (m *ParallelExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ParallelExecution) ProtoMessage ¶
func (*ParallelExecution) ProtoMessage()
func (*ParallelExecution) Reset ¶
func (m *ParallelExecution) Reset()
func (*ParallelExecution) Size ¶
func (m *ParallelExecution) Size() (n int)
func (*ParallelExecution) String ¶
func (m *ParallelExecution) String() string
func (*ParallelExecution) Unmarshal ¶
func (m *ParallelExecution) Unmarshal(dAtA []byte) error
func (*ParallelExecution) XXX_DiscardUnknown ¶
func (m *ParallelExecution) XXX_DiscardUnknown()
func (*ParallelExecution) XXX_Marshal ¶
func (m *ParallelExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ParallelExecution) XXX_Merge ¶
func (m *ParallelExecution) XXX_Merge(src proto.Message)
func (*ParallelExecution) XXX_Size ¶
func (m *ParallelExecution) XXX_Size() int
func (*ParallelExecution) XXX_Unmarshal ¶
func (m *ParallelExecution) XXX_Unmarshal(b []byte) error
type Partiton ¶
type Partiton struct { Consumer uint32 `protobuf:"varint,1,opt,name=consumer,proto3" json:"consumer,omitempty"` Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` LastFetchTS int64 `protobuf:"varint,3,opt,name=lastFetchTS,proto3" json:"lastFetchTS,omitempty"` }
Partiton partition state
func (*Partiton) Descriptor ¶
func (*Partiton) GetConsumer ¶
func (*Partiton) GetLastFetchTS ¶
func (*Partiton) GetVersion ¶
func (*Partiton) MarshalToSizedBuffer ¶
func (*Partiton) ProtoMessage ¶
func (*Partiton) ProtoMessage()
func (*Partiton) XXX_DiscardUnknown ¶
func (m *Partiton) XXX_DiscardUnknown()
func (*Partiton) XXX_Marshal ¶
func (*Partiton) XXX_Unmarshal ¶
type QueueState ¶
type QueueState struct { Partitions uint32 `protobuf:"varint,1,opt,name=partitions,proto3" json:"partitions,omitempty"` Consumers uint32 `protobuf:"varint,2,opt,name=consumers,proto3" json:"consumers,omitempty"` States []Partiton `protobuf:"bytes,3,rep,name=states,proto3" json:"states"` Timeout int64 `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"` MaxAlive int64 `protobuf:"varint,5,opt,name=maxAlive,proto3" json:"maxAlive,omitempty"` CleanBatch uint64 `protobuf:"varint,6,opt,name=cleanBatch,proto3" json:"cleanBatch,omitempty"` }
QueueState queue state
func (*QueueState) Descriptor ¶
func (*QueueState) Descriptor() ([]byte, []int)
func (*QueueState) GetCleanBatch ¶
func (m *QueueState) GetCleanBatch() uint64
func (*QueueState) GetConsumers ¶
func (m *QueueState) GetConsumers() uint32
func (*QueueState) GetMaxAlive ¶
func (m *QueueState) GetMaxAlive() int64
func (*QueueState) GetPartitions ¶
func (m *QueueState) GetPartitions() uint32
func (*QueueState) GetStates ¶
func (m *QueueState) GetStates() []Partiton
func (*QueueState) GetTimeout ¶
func (m *QueueState) GetTimeout() int64
func (*QueueState) Marshal ¶
func (m *QueueState) Marshal() (dAtA []byte, err error)
func (*QueueState) MarshalToSizedBuffer ¶
func (m *QueueState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueState) ProtoMessage ¶
func (*QueueState) ProtoMessage()
func (*QueueState) Reset ¶
func (m *QueueState) Reset()
func (*QueueState) Size ¶
func (m *QueueState) Size() (n int)
func (*QueueState) String ¶
func (m *QueueState) String() string
func (*QueueState) Unmarshal ¶
func (m *QueueState) Unmarshal(dAtA []byte) error
func (*QueueState) XXX_DiscardUnknown ¶
func (m *QueueState) XXX_DiscardUnknown()
func (*QueueState) XXX_Marshal ¶
func (m *QueueState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueState) XXX_Merge ¶
func (m *QueueState) XXX_Merge(src proto.Message)
func (*QueueState) XXX_Size ¶
func (m *QueueState) XXX_Size() int
func (*QueueState) XXX_Unmarshal ¶
func (m *QueueState) XXX_Unmarshal(b []byte) error
type SetKVAction ¶
type SetKVAction struct { KV KV `protobuf:"bytes,1,opt,name=kv,proto3" json:"kv"` Group Group `protobuf:"varint,2,opt,name=group,proto3,enum=metapb.Group" json:"group,omitempty"` }
SetKVAction set kv action
func (*SetKVAction) Descriptor ¶
func (*SetKVAction) Descriptor() ([]byte, []int)
func (*SetKVAction) GetGroup ¶
func (m *SetKVAction) GetGroup() Group
func (*SetKVAction) GetKV ¶
func (m *SetKVAction) GetKV() KV
func (*SetKVAction) Marshal ¶
func (m *SetKVAction) Marshal() (dAtA []byte, err error)
func (*SetKVAction) MarshalToSizedBuffer ¶
func (m *SetKVAction) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetKVAction) ProtoMessage ¶
func (*SetKVAction) ProtoMessage()
func (*SetKVAction) Reset ¶
func (m *SetKVAction) Reset()
func (*SetKVAction) Size ¶
func (m *SetKVAction) Size() (n int)
func (*SetKVAction) String ¶
func (m *SetKVAction) String() string
func (*SetKVAction) Unmarshal ¶
func (m *SetKVAction) Unmarshal(dAtA []byte) error
func (*SetKVAction) XXX_DiscardUnknown ¶
func (m *SetKVAction) XXX_DiscardUnknown()
func (*SetKVAction) XXX_Marshal ¶
func (m *SetKVAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetKVAction) XXX_Merge ¶
func (m *SetKVAction) XXX_Merge(src proto.Message)
func (*SetKVAction) XXX_Size ¶
func (m *SetKVAction) XXX_Size() int
func (*SetKVAction) XXX_Unmarshal ¶
func (m *SetKVAction) XXX_Unmarshal(b []byte) error
type ShardBitmapLoadMeta ¶
type ShardBitmapLoadMeta struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Total uint64 `protobuf:"varint,2,opt,name=Total,proto3" json:"Total,omitempty"` Shards uint32 `protobuf:"varint,3,opt,name=shards,proto3" json:"shards,omitempty"` }
ShardBitmapLoadMeta shard bitmap load meta
func (*ShardBitmapLoadMeta) Descriptor ¶
func (*ShardBitmapLoadMeta) Descriptor() ([]byte, []int)
func (*ShardBitmapLoadMeta) GetKey ¶
func (m *ShardBitmapLoadMeta) GetKey() []byte
func (*ShardBitmapLoadMeta) GetShards ¶
func (m *ShardBitmapLoadMeta) GetShards() uint32
func (*ShardBitmapLoadMeta) GetTotal ¶
func (m *ShardBitmapLoadMeta) GetTotal() uint64
func (*ShardBitmapLoadMeta) Marshal ¶
func (m *ShardBitmapLoadMeta) Marshal() (dAtA []byte, err error)
func (*ShardBitmapLoadMeta) MarshalTo ¶
func (m *ShardBitmapLoadMeta) MarshalTo(dAtA []byte) (int, error)
func (*ShardBitmapLoadMeta) MarshalToSizedBuffer ¶
func (m *ShardBitmapLoadMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShardBitmapLoadMeta) ProtoMessage ¶
func (*ShardBitmapLoadMeta) ProtoMessage()
func (*ShardBitmapLoadMeta) Reset ¶
func (m *ShardBitmapLoadMeta) Reset()
func (*ShardBitmapLoadMeta) Size ¶
func (m *ShardBitmapLoadMeta) Size() (n int)
func (*ShardBitmapLoadMeta) String ¶
func (m *ShardBitmapLoadMeta) String() string
func (*ShardBitmapLoadMeta) Unmarshal ¶
func (m *ShardBitmapLoadMeta) Unmarshal(dAtA []byte) error
func (*ShardBitmapLoadMeta) XXX_DiscardUnknown ¶
func (m *ShardBitmapLoadMeta) XXX_DiscardUnknown()
func (*ShardBitmapLoadMeta) XXX_Marshal ¶
func (m *ShardBitmapLoadMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShardBitmapLoadMeta) XXX_Merge ¶
func (m *ShardBitmapLoadMeta) XXX_Merge(src proto.Message)
func (*ShardBitmapLoadMeta) XXX_Size ¶
func (m *ShardBitmapLoadMeta) XXX_Size() int
func (*ShardBitmapLoadMeta) XXX_Unmarshal ¶
func (m *ShardBitmapLoadMeta) XXX_Unmarshal(b []byte) error
type ShardBitmapPutMeta ¶
type ShardBitmapPutMeta struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` TTL uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"` BytesPerShard uint32 `protobuf:"varint,3,opt,name=bytesPerShard,proto3" json:"bytesPerShard,omitempty"` }
ShardBitmapPutMeta shard bitmap put meta
func (*ShardBitmapPutMeta) Descriptor ¶
func (*ShardBitmapPutMeta) Descriptor() ([]byte, []int)
func (*ShardBitmapPutMeta) GetBytesPerShard ¶
func (m *ShardBitmapPutMeta) GetBytesPerShard() uint32
func (*ShardBitmapPutMeta) GetKey ¶
func (m *ShardBitmapPutMeta) GetKey() []byte
func (*ShardBitmapPutMeta) GetTTL ¶
func (m *ShardBitmapPutMeta) GetTTL() uint32
func (*ShardBitmapPutMeta) Marshal ¶
func (m *ShardBitmapPutMeta) Marshal() (dAtA []byte, err error)
func (*ShardBitmapPutMeta) MarshalTo ¶
func (m *ShardBitmapPutMeta) MarshalTo(dAtA []byte) (int, error)
func (*ShardBitmapPutMeta) MarshalToSizedBuffer ¶
func (m *ShardBitmapPutMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShardBitmapPutMeta) ProtoMessage ¶
func (*ShardBitmapPutMeta) ProtoMessage()
func (*ShardBitmapPutMeta) Reset ¶
func (m *ShardBitmapPutMeta) Reset()
func (*ShardBitmapPutMeta) Size ¶
func (m *ShardBitmapPutMeta) Size() (n int)
func (*ShardBitmapPutMeta) String ¶
func (m *ShardBitmapPutMeta) String() string
func (*ShardBitmapPutMeta) Unmarshal ¶
func (m *ShardBitmapPutMeta) Unmarshal(dAtA []byte) error
func (*ShardBitmapPutMeta) XXX_DiscardUnknown ¶
func (m *ShardBitmapPutMeta) XXX_DiscardUnknown()
func (*ShardBitmapPutMeta) XXX_Marshal ¶
func (m *ShardBitmapPutMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShardBitmapPutMeta) XXX_Merge ¶
func (m *ShardBitmapPutMeta) XXX_Merge(src proto.Message)
func (*ShardBitmapPutMeta) XXX_Size ¶
func (m *ShardBitmapPutMeta) XXX_Size() int
func (*ShardBitmapPutMeta) XXX_Unmarshal ¶
func (m *ShardBitmapPutMeta) XXX_Unmarshal(b []byte) error
type Step ¶
type Step struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Execution Execution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution"` EnterAction string `protobuf:"bytes,3,opt,name=enterAction,proto3" json:"enterAction,omitempty"` LeaveAction string `protobuf:"bytes,4,opt,name=leaveAction,proto3" json:"leaveAction,omitempty"` TTL int32 `protobuf:"varint,5,opt,name=ttl,proto3" json:"ttl,omitempty"` }
Step is a step of the work flow
func (*Step) Descriptor ¶
func (*Step) GetEnterAction ¶
func (*Step) GetExecution ¶
func (*Step) GetLeaveAction ¶
func (*Step) ProtoMessage ¶
func (*Step) ProtoMessage()
func (*Step) XXX_DiscardUnknown ¶
func (m *Step) XXX_DiscardUnknown()
func (*Step) XXX_Unmarshal ¶
type StepState ¶
type StepState struct { Step Step `protobuf:"bytes,1,opt,name=step,proto3" json:"step"` TotalCrowd uint64 `protobuf:"varint,2,opt,name=totalCrowd,proto3" json:"totalCrowd,omitempty"` Loader BMLoader `protobuf:"varint,3,opt,name=loader,proto3,enum=metapb.BMLoader" json:"loader,omitempty"` LoaderMeta []byte `protobuf:"bytes,4,opt,name=loaderMeta,proto3" json:"loaderMeta,omitempty"` }
StepState workflow step state.
func (*StepState) Descriptor ¶
func (*StepState) GetLoaderMeta ¶
func (*StepState) GetTotalCrowd ¶
func (*StepState) MarshalToSizedBuffer ¶
func (*StepState) ProtoMessage ¶
func (*StepState) ProtoMessage()
func (*StepState) XXX_DiscardUnknown ¶
func (m *StepState) XXX_DiscardUnknown()
func (*StepState) XXX_Marshal ¶
func (*StepState) XXX_Unmarshal ¶
type Tenant ¶
type Tenant struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Input TenantQueue `protobuf:"bytes,2,opt,name=input,proto3" json:"input"` Output TenantQueue `protobuf:"bytes,3,opt,name=output,proto3" json:"output"` Runners uint64 `protobuf:"varint,4,opt,name=runners,proto3" json:"runners,omitempty"` InputsState []bool `protobuf:"varint,5,rep,packed,name=inputsState,proto3" json:"inputsState,omitempty"` OutputsState []bool `protobuf:"varint,6,rep,packed,name=outputsState,proto3" json:"outputsState,omitempty"` RunnersState []bool `protobuf:"varint,7,rep,packed,name=runnersState,proto3" json:"runnersState,omitempty"` }
Tenant tenant metadata
func (*Tenant) Descriptor ¶
func (*Tenant) GetInput ¶
func (m *Tenant) GetInput() TenantQueue
func (*Tenant) GetInputsState ¶
func (*Tenant) GetOutput ¶
func (m *Tenant) GetOutput() TenantQueue
func (*Tenant) GetOutputsState ¶
func (*Tenant) GetRunners ¶
func (*Tenant) GetRunnersState ¶
func (*Tenant) MarshalToSizedBuffer ¶
func (*Tenant) ProtoMessage ¶
func (*Tenant) ProtoMessage()
func (*Tenant) XXX_DiscardUnknown ¶
func (m *Tenant) XXX_DiscardUnknown()
func (*Tenant) XXX_Marshal ¶
func (*Tenant) XXX_Unmarshal ¶
type TenantInitStateUpdateAction ¶
type TenantInitStateUpdateAction struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Index int32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Group Group `protobuf:"varint,3,opt,name=group,proto3,enum=metapb.Group" json:"group,omitempty"` }
TenantInitStateUpdateAction update tenant init state
func (*TenantInitStateUpdateAction) Descriptor ¶
func (*TenantInitStateUpdateAction) Descriptor() ([]byte, []int)
func (*TenantInitStateUpdateAction) GetGroup ¶
func (m *TenantInitStateUpdateAction) GetGroup() Group
func (*TenantInitStateUpdateAction) GetID ¶
func (m *TenantInitStateUpdateAction) GetID() uint64
func (*TenantInitStateUpdateAction) GetIndex ¶
func (m *TenantInitStateUpdateAction) GetIndex() int32
func (*TenantInitStateUpdateAction) Marshal ¶
func (m *TenantInitStateUpdateAction) Marshal() (dAtA []byte, err error)
func (*TenantInitStateUpdateAction) MarshalTo ¶
func (m *TenantInitStateUpdateAction) MarshalTo(dAtA []byte) (int, error)
func (*TenantInitStateUpdateAction) MarshalToSizedBuffer ¶
func (m *TenantInitStateUpdateAction) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TenantInitStateUpdateAction) ProtoMessage ¶
func (*TenantInitStateUpdateAction) ProtoMessage()
func (*TenantInitStateUpdateAction) Reset ¶
func (m *TenantInitStateUpdateAction) Reset()
func (*TenantInitStateUpdateAction) Size ¶
func (m *TenantInitStateUpdateAction) Size() (n int)
func (*TenantInitStateUpdateAction) String ¶
func (m *TenantInitStateUpdateAction) String() string
func (*TenantInitStateUpdateAction) Unmarshal ¶
func (m *TenantInitStateUpdateAction) Unmarshal(dAtA []byte) error
func (*TenantInitStateUpdateAction) XXX_DiscardUnknown ¶
func (m *TenantInitStateUpdateAction) XXX_DiscardUnknown()
func (*TenantInitStateUpdateAction) XXX_Marshal ¶
func (m *TenantInitStateUpdateAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TenantInitStateUpdateAction) XXX_Merge ¶
func (m *TenantInitStateUpdateAction) XXX_Merge(src proto.Message)
func (*TenantInitStateUpdateAction) XXX_Size ¶
func (m *TenantInitStateUpdateAction) XXX_Size() int
func (*TenantInitStateUpdateAction) XXX_Unmarshal ¶
func (m *TenantInitStateUpdateAction) XXX_Unmarshal(b []byte) error
type TenantQueue ¶
type TenantQueue struct { Partitions uint32 `protobuf:"varint,1,opt,name=partitions,proto3" json:"partitions,omitempty"` ConsumerTimeout int64 `protobuf:"varint,2,opt,name=consumerTimeout,proto3" json:"consumerTimeout,omitempty"` MaxAlive int64 `protobuf:"varint,3,opt,name=maxAlive,proto3" json:"maxAlive,omitempty"` CleanBatch uint64 `protobuf:"varint,4,opt,name=cleanBatch,proto3" json:"cleanBatch,omitempty"` }
TenantQueue queue metadata
func (*TenantQueue) Descriptor ¶
func (*TenantQueue) Descriptor() ([]byte, []int)
func (*TenantQueue) GetCleanBatch ¶
func (m *TenantQueue) GetCleanBatch() uint64
func (*TenantQueue) GetConsumerTimeout ¶
func (m *TenantQueue) GetConsumerTimeout() int64
func (*TenantQueue) GetMaxAlive ¶
func (m *TenantQueue) GetMaxAlive() int64
func (*TenantQueue) GetPartitions ¶
func (m *TenantQueue) GetPartitions() uint32
func (*TenantQueue) Marshal ¶
func (m *TenantQueue) Marshal() (dAtA []byte, err error)
func (*TenantQueue) MarshalToSizedBuffer ¶
func (m *TenantQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TenantQueue) ProtoMessage ¶
func (*TenantQueue) ProtoMessage()
func (*TenantQueue) Reset ¶
func (m *TenantQueue) Reset()
func (*TenantQueue) Size ¶
func (m *TenantQueue) Size() (n int)
func (*TenantQueue) String ¶
func (m *TenantQueue) String() string
func (*TenantQueue) Unmarshal ¶
func (m *TenantQueue) Unmarshal(dAtA []byte) error
func (*TenantQueue) XXX_DiscardUnknown ¶
func (m *TenantQueue) XXX_DiscardUnknown()
func (*TenantQueue) XXX_Marshal ¶
func (m *TenantQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TenantQueue) XXX_Merge ¶
func (m *TenantQueue) XXX_Merge(src proto.Message)
func (*TenantQueue) XXX_Size ¶
func (m *TenantQueue) XXX_Size() int
func (*TenantQueue) XXX_Unmarshal ¶
func (m *TenantQueue) XXX_Unmarshal(b []byte) error
type TenantRunnerOffsets ¶
type TenantRunnerOffsets struct { Workers []string `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"` Offsets []*TenantRunnerWorkerOffsets `protobuf:"bytes,2,rep,name=offsets,proto3" json:"offsets,omitempty"` }
TenantRunnerOffsets offsets
func (*TenantRunnerOffsets) Descriptor ¶
func (*TenantRunnerOffsets) Descriptor() ([]byte, []int)
func (*TenantRunnerOffsets) GetOffsets ¶
func (m *TenantRunnerOffsets) GetOffsets() []*TenantRunnerWorkerOffsets
func (*TenantRunnerOffsets) GetWorkers ¶
func (m *TenantRunnerOffsets) GetWorkers() []string
func (*TenantRunnerOffsets) Marshal ¶
func (m *TenantRunnerOffsets) Marshal() (dAtA []byte, err error)
func (*TenantRunnerOffsets) MarshalTo ¶
func (m *TenantRunnerOffsets) MarshalTo(dAtA []byte) (int, error)
func (*TenantRunnerOffsets) MarshalToSizedBuffer ¶
func (m *TenantRunnerOffsets) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TenantRunnerOffsets) ProtoMessage ¶
func (*TenantRunnerOffsets) ProtoMessage()
func (*TenantRunnerOffsets) Reset ¶
func (m *TenantRunnerOffsets) Reset()
func (*TenantRunnerOffsets) Size ¶
func (m *TenantRunnerOffsets) Size() (n int)
func (*TenantRunnerOffsets) String ¶
func (m *TenantRunnerOffsets) String() string
func (*TenantRunnerOffsets) Unmarshal ¶
func (m *TenantRunnerOffsets) Unmarshal(dAtA []byte) error
func (*TenantRunnerOffsets) XXX_DiscardUnknown ¶
func (m *TenantRunnerOffsets) XXX_DiscardUnknown()
func (*TenantRunnerOffsets) XXX_Marshal ¶
func (m *TenantRunnerOffsets) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TenantRunnerOffsets) XXX_Merge ¶
func (m *TenantRunnerOffsets) XXX_Merge(src proto.Message)
func (*TenantRunnerOffsets) XXX_Size ¶
func (m *TenantRunnerOffsets) XXX_Size() int
func (*TenantRunnerOffsets) XXX_Unmarshal ¶
func (m *TenantRunnerOffsets) XXX_Unmarshal(b []byte) error
type TenantRunnerWorkerOffsets ¶
type TenantRunnerWorkerOffsets struct {
Offsets []uint64 `protobuf:"varint,1,rep,packed,name=offsets,proto3" json:"offsets,omitempty"`
}
TenantRunnerWorkerOffsets offsets
func (*TenantRunnerWorkerOffsets) Descriptor ¶
func (*TenantRunnerWorkerOffsets) Descriptor() ([]byte, []int)
func (*TenantRunnerWorkerOffsets) GetOffsets ¶
func (m *TenantRunnerWorkerOffsets) GetOffsets() []uint64
func (*TenantRunnerWorkerOffsets) Marshal ¶
func (m *TenantRunnerWorkerOffsets) Marshal() (dAtA []byte, err error)
func (*TenantRunnerWorkerOffsets) MarshalTo ¶
func (m *TenantRunnerWorkerOffsets) MarshalTo(dAtA []byte) (int, error)
func (*TenantRunnerWorkerOffsets) MarshalToSizedBuffer ¶
func (m *TenantRunnerWorkerOffsets) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TenantRunnerWorkerOffsets) ProtoMessage ¶
func (*TenantRunnerWorkerOffsets) ProtoMessage()
func (*TenantRunnerWorkerOffsets) Reset ¶
func (m *TenantRunnerWorkerOffsets) Reset()
func (*TenantRunnerWorkerOffsets) Size ¶
func (m *TenantRunnerWorkerOffsets) Size() (n int)
func (*TenantRunnerWorkerOffsets) String ¶
func (m *TenantRunnerWorkerOffsets) String() string
func (*TenantRunnerWorkerOffsets) Unmarshal ¶
func (m *TenantRunnerWorkerOffsets) Unmarshal(dAtA []byte) error
func (*TenantRunnerWorkerOffsets) XXX_DiscardUnknown ¶
func (m *TenantRunnerWorkerOffsets) XXX_DiscardUnknown()
func (*TenantRunnerWorkerOffsets) XXX_Marshal ¶
func (m *TenantRunnerWorkerOffsets) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TenantRunnerWorkerOffsets) XXX_Merge ¶
func (m *TenantRunnerWorkerOffsets) XXX_Merge(src proto.Message)
func (*TenantRunnerWorkerOffsets) XXX_Size ¶
func (m *TenantRunnerWorkerOffsets) XXX_Size() int
func (*TenantRunnerWorkerOffsets) XXX_Unmarshal ¶
func (m *TenantRunnerWorkerOffsets) XXX_Unmarshal(b []byte) error
type TimerExecution ¶
type TimerExecution struct { Condition *Expr `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"` Cron string `protobuf:"bytes,2,opt,name=cron,proto3" json:"cron,omitempty"` NextStep string `protobuf:"bytes,3,opt,name=nextStep,proto3" json:"nextStep,omitempty"` UseStepCrowdToDrive bool `protobuf:"varint,4,opt,name=useStepCrowdToDrive,proto3" json:"useStepCrowdToDrive,omitempty"` }
TimerExecution is a timer performable operation
func (*TimerExecution) Descriptor ¶
func (*TimerExecution) Descriptor() ([]byte, []int)
func (*TimerExecution) GetCondition ¶
func (m *TimerExecution) GetCondition() *Expr
func (*TimerExecution) GetCron ¶
func (m *TimerExecution) GetCron() string
func (*TimerExecution) GetNextStep ¶
func (m *TimerExecution) GetNextStep() string
func (*TimerExecution) GetUseStepCrowdToDrive ¶
func (m *TimerExecution) GetUseStepCrowdToDrive() bool
func (*TimerExecution) Marshal ¶
func (m *TimerExecution) Marshal() (dAtA []byte, err error)
func (*TimerExecution) MarshalToSizedBuffer ¶
func (m *TimerExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TimerExecution) ProtoMessage ¶
func (*TimerExecution) ProtoMessage()
func (*TimerExecution) Reset ¶
func (m *TimerExecution) Reset()
func (*TimerExecution) Size ¶
func (m *TimerExecution) Size() (n int)
func (*TimerExecution) String ¶
func (m *TimerExecution) String() string
func (*TimerExecution) Unmarshal ¶
func (m *TimerExecution) Unmarshal(dAtA []byte) error
func (*TimerExecution) XXX_DiscardUnknown ¶
func (m *TimerExecution) XXX_DiscardUnknown()
func (*TimerExecution) XXX_Marshal ¶
func (m *TimerExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TimerExecution) XXX_Merge ¶
func (m *TimerExecution) XXX_Merge(src proto.Message)
func (*TimerExecution) XXX_Size ¶
func (m *TimerExecution) XXX_Size() int
func (*TimerExecution) XXX_Unmarshal ¶
func (m *TimerExecution) XXX_Unmarshal(b []byte) error
type UpdateCrowdEvent ¶
type UpdateCrowdEvent struct { WorkflowID uint64 `protobuf:"varint,1,opt,name=workflowID,proto3" json:"workflowID,omitempty"` Index uint32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Crowd []byte `protobuf:"bytes,3,opt,name=crowd,proto3" json:"crowd,omitempty"` }
UpdateCrowdEvent update crowd event
func (*UpdateCrowdEvent) Descriptor ¶
func (*UpdateCrowdEvent) Descriptor() ([]byte, []int)
func (*UpdateCrowdEvent) GetCrowd ¶
func (m *UpdateCrowdEvent) GetCrowd() []byte
func (*UpdateCrowdEvent) GetIndex ¶
func (m *UpdateCrowdEvent) GetIndex() uint32
func (*UpdateCrowdEvent) GetWorkflowID ¶
func (m *UpdateCrowdEvent) GetWorkflowID() uint64
func (*UpdateCrowdEvent) Marshal ¶
func (m *UpdateCrowdEvent) Marshal() (dAtA []byte, err error)
func (*UpdateCrowdEvent) MarshalToSizedBuffer ¶
func (m *UpdateCrowdEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateCrowdEvent) ProtoMessage ¶
func (*UpdateCrowdEvent) ProtoMessage()
func (*UpdateCrowdEvent) Reset ¶
func (m *UpdateCrowdEvent) Reset()
func (*UpdateCrowdEvent) Size ¶
func (m *UpdateCrowdEvent) Size() (n int)
func (*UpdateCrowdEvent) String ¶
func (m *UpdateCrowdEvent) String() string
func (*UpdateCrowdEvent) Unmarshal ¶
func (m *UpdateCrowdEvent) Unmarshal(dAtA []byte) error
func (*UpdateCrowdEvent) XXX_DiscardUnknown ¶
func (m *UpdateCrowdEvent) XXX_DiscardUnknown()
func (*UpdateCrowdEvent) XXX_Marshal ¶
func (m *UpdateCrowdEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateCrowdEvent) XXX_Merge ¶
func (m *UpdateCrowdEvent) XXX_Merge(src proto.Message)
func (*UpdateCrowdEvent) XXX_Size ¶
func (m *UpdateCrowdEvent) XXX_Size() int
func (*UpdateCrowdEvent) XXX_Unmarshal ¶
func (m *UpdateCrowdEvent) XXX_Unmarshal(b []byte) error
type UpdateWorkflowEvent ¶
type UpdateWorkflowEvent struct {
Workflow Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow"`
}
UpdateWorkflowEvent update crowd event
func (*UpdateWorkflowEvent) Descriptor ¶
func (*UpdateWorkflowEvent) Descriptor() ([]byte, []int)
func (*UpdateWorkflowEvent) GetWorkflow ¶
func (m *UpdateWorkflowEvent) GetWorkflow() Workflow
func (*UpdateWorkflowEvent) Marshal ¶
func (m *UpdateWorkflowEvent) Marshal() (dAtA []byte, err error)
func (*UpdateWorkflowEvent) MarshalTo ¶
func (m *UpdateWorkflowEvent) MarshalTo(dAtA []byte) (int, error)
func (*UpdateWorkflowEvent) MarshalToSizedBuffer ¶
func (m *UpdateWorkflowEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateWorkflowEvent) ProtoMessage ¶
func (*UpdateWorkflowEvent) ProtoMessage()
func (*UpdateWorkflowEvent) Reset ¶
func (m *UpdateWorkflowEvent) Reset()
func (*UpdateWorkflowEvent) Size ¶
func (m *UpdateWorkflowEvent) Size() (n int)
func (*UpdateWorkflowEvent) String ¶
func (m *UpdateWorkflowEvent) String() string
func (*UpdateWorkflowEvent) Unmarshal ¶
func (m *UpdateWorkflowEvent) Unmarshal(dAtA []byte) error
func (*UpdateWorkflowEvent) XXX_DiscardUnknown ¶
func (m *UpdateWorkflowEvent) XXX_DiscardUnknown()
func (*UpdateWorkflowEvent) XXX_Marshal ¶
func (m *UpdateWorkflowEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateWorkflowEvent) XXX_Merge ¶
func (m *UpdateWorkflowEvent) XXX_Merge(src proto.Message)
func (*UpdateWorkflowEvent) XXX_Size ¶
func (m *UpdateWorkflowEvent) XXX_Size() int
func (*UpdateWorkflowEvent) XXX_Unmarshal ¶
func (m *UpdateWorkflowEvent) XXX_Unmarshal(b []byte) error
type UserEvent ¶
type UserEvent struct { UserID uint32 `protobuf:"varint,1,opt,name=userID,proto3" json:"userID,omitempty"` TenantID uint64 `protobuf:"varint,2,opt,name=tenantID,proto3" json:"tenantID,omitempty"` Data []KV `protobuf:"bytes,3,rep,name=data,proto3" json:"data"` }
UserEvent is process definition
func (*UserEvent) Descriptor ¶
func (*UserEvent) GetTenantID ¶
func (*UserEvent) MarshalToSizedBuffer ¶
func (*UserEvent) ProtoMessage ¶
func (*UserEvent) ProtoMessage()
func (*UserEvent) XXX_DiscardUnknown ¶
func (m *UserEvent) XXX_DiscardUnknown()
func (*UserEvent) XXX_Marshal ¶
func (*UserEvent) XXX_Unmarshal ¶
type WorkerRunner ¶
type WorkerRunner struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` State WorkerRunnerState `protobuf:"varint,3,opt,name=state,proto3,enum=metapb.WorkerRunnerState" json:"state,omitempty"` Workers []WorkflowWorker `protobuf:"bytes,4,rep,name=workers,proto3" json:"workers"` TotalCrowd uint64 `protobuf:"varint,5,opt,name=totalCrowd,proto3" json:"totalCrowd,omitempty"` }
WorkerRunner worker runner
func (*WorkerRunner) Descriptor ¶
func (*WorkerRunner) Descriptor() ([]byte, []int)
func (*WorkerRunner) GetID ¶
func (m *WorkerRunner) GetID() uint64
func (*WorkerRunner) GetIndex ¶
func (m *WorkerRunner) GetIndex() uint64
func (*WorkerRunner) GetState ¶
func (m *WorkerRunner) GetState() WorkerRunnerState
func (*WorkerRunner) GetTotalCrowd ¶
func (m *WorkerRunner) GetTotalCrowd() uint64
func (*WorkerRunner) GetWorkers ¶
func (m *WorkerRunner) GetWorkers() []WorkflowWorker
func (*WorkerRunner) Marshal ¶
func (m *WorkerRunner) Marshal() (dAtA []byte, err error)
func (*WorkerRunner) MarshalToSizedBuffer ¶
func (m *WorkerRunner) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkerRunner) ProtoMessage ¶
func (*WorkerRunner) ProtoMessage()
func (*WorkerRunner) Reset ¶
func (m *WorkerRunner) Reset()
func (*WorkerRunner) Size ¶
func (m *WorkerRunner) Size() (n int)
func (*WorkerRunner) String ¶
func (m *WorkerRunner) String() string
func (*WorkerRunner) Unmarshal ¶
func (m *WorkerRunner) Unmarshal(dAtA []byte) error
func (*WorkerRunner) XXX_DiscardUnknown ¶
func (m *WorkerRunner) XXX_DiscardUnknown()
func (*WorkerRunner) XXX_Marshal ¶
func (m *WorkerRunner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkerRunner) XXX_Merge ¶
func (m *WorkerRunner) XXX_Merge(src proto.Message)
func (*WorkerRunner) XXX_Size ¶
func (m *WorkerRunner) XXX_Size() int
func (*WorkerRunner) XXX_Unmarshal ¶
func (m *WorkerRunner) XXX_Unmarshal(b []byte) error
type WorkerRunnerState ¶
type WorkerRunnerState int32
WorkerRunnerState runner state
const ( WRRunning WorkerRunnerState = 0 WRStopped WorkerRunnerState = 1 )
func (WorkerRunnerState) EnumDescriptor ¶
func (WorkerRunnerState) EnumDescriptor() ([]byte, []int)
func (WorkerRunnerState) String ¶
func (x WorkerRunnerState) String() string
type Workflow ¶
type Workflow struct { ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` TenantID uint64 `protobuf:"varint,2,opt,name=tenantID,proto3" json:"tenantID,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Steps []Step `protobuf:"bytes,4,rep,name=steps,proto3" json:"steps"` StopAt int64 `protobuf:"varint,5,opt,name=stopAt,proto3" json:"stopAt,omitempty"` }
Workflow is process definition
func (*Workflow) Descriptor ¶
func (*Workflow) GetTenantID ¶
func (*Workflow) MarshalToSizedBuffer ¶
func (*Workflow) ProtoMessage ¶
func (*Workflow) ProtoMessage()
func (*Workflow) XXX_DiscardUnknown ¶
func (m *Workflow) XXX_DiscardUnknown()
func (*Workflow) XXX_Marshal ¶
func (*Workflow) XXX_Unmarshal ¶
type WorkflowInstance ¶
type WorkflowInstance struct { Snapshot Workflow `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot"` InstanceID uint64 `protobuf:"varint,2,opt,name=instanceID,proto3" json:"instanceID,omitempty"` LoaderMeta []byte `protobuf:"bytes,3,opt,name=loaderMeta,proto3" json:"loaderMeta,omitempty"` Loader BMLoader `protobuf:"varint,4,opt,name=loader,proto3,enum=metapb.BMLoader" json:"loader,omitempty"` TotalCrowd uint64 `protobuf:"varint,5,opt,name=totalCrowd,proto3" json:"totalCrowd,omitempty"` StartedAt int64 `protobuf:"varint,6,opt,name=startedAt,proto3" json:"startedAt,omitempty"` StoppedAt int64 `protobuf:"varint,7,opt,name=stoppedAt,proto3" json:"stoppedAt,omitempty"` Version uint64 `protobuf:"varint,8,opt,name=version,proto3" json:"version,omitempty"` State WorkflowInstanceState `protobuf:"varint,9,opt,name=state,proto3,enum=metapb.WorkflowInstanceState" json:"state,omitempty"` }
WorkflowInstance workflow instance
func (*WorkflowInstance) Descriptor ¶
func (*WorkflowInstance) Descriptor() ([]byte, []int)
func (*WorkflowInstance) GetInstanceID ¶
func (m *WorkflowInstance) GetInstanceID() uint64
func (*WorkflowInstance) GetLoader ¶
func (m *WorkflowInstance) GetLoader() BMLoader
func (*WorkflowInstance) GetLoaderMeta ¶
func (m *WorkflowInstance) GetLoaderMeta() []byte
func (*WorkflowInstance) GetSnapshot ¶
func (m *WorkflowInstance) GetSnapshot() Workflow
func (*WorkflowInstance) GetStartedAt ¶
func (m *WorkflowInstance) GetStartedAt() int64
func (*WorkflowInstance) GetState ¶
func (m *WorkflowInstance) GetState() WorkflowInstanceState
func (*WorkflowInstance) GetStoppedAt ¶
func (m *WorkflowInstance) GetStoppedAt() int64
func (*WorkflowInstance) GetTotalCrowd ¶
func (m *WorkflowInstance) GetTotalCrowd() uint64
func (*WorkflowInstance) GetVersion ¶
func (m *WorkflowInstance) GetVersion() uint64
func (*WorkflowInstance) Marshal ¶
func (m *WorkflowInstance) Marshal() (dAtA []byte, err error)
func (*WorkflowInstance) MarshalToSizedBuffer ¶
func (m *WorkflowInstance) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowInstance) ProtoMessage ¶
func (*WorkflowInstance) ProtoMessage()
func (*WorkflowInstance) Reset ¶
func (m *WorkflowInstance) Reset()
func (*WorkflowInstance) Size ¶
func (m *WorkflowInstance) Size() (n int)
func (*WorkflowInstance) String ¶
func (m *WorkflowInstance) String() string
func (*WorkflowInstance) Unmarshal ¶
func (m *WorkflowInstance) Unmarshal(dAtA []byte) error
func (*WorkflowInstance) XXX_DiscardUnknown ¶
func (m *WorkflowInstance) XXX_DiscardUnknown()
func (*WorkflowInstance) XXX_Marshal ¶
func (m *WorkflowInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowInstance) XXX_Merge ¶
func (m *WorkflowInstance) XXX_Merge(src proto.Message)
func (*WorkflowInstance) XXX_Size ¶
func (m *WorkflowInstance) XXX_Size() int
func (*WorkflowInstance) XXX_Unmarshal ¶
func (m *WorkflowInstance) XXX_Unmarshal(b []byte) error
type WorkflowInstanceSnapshot ¶
type WorkflowInstanceSnapshot struct { Snapshot WorkflowInstance `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot"` Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` States []StepState `protobuf:"bytes,3,rep,name=states,proto3" json:"states"` }
WorkflowInstanceSnapshot workflow instance snapshpot
func (*WorkflowInstanceSnapshot) Descriptor ¶
func (*WorkflowInstanceSnapshot) Descriptor() ([]byte, []int)
func (*WorkflowInstanceSnapshot) GetSnapshot ¶
func (m *WorkflowInstanceSnapshot) GetSnapshot() WorkflowInstance
func (*WorkflowInstanceSnapshot) GetStates ¶
func (m *WorkflowInstanceSnapshot) GetStates() []StepState
func (*WorkflowInstanceSnapshot) GetTimestamp ¶
func (m *WorkflowInstanceSnapshot) GetTimestamp() int64
func (*WorkflowInstanceSnapshot) Marshal ¶
func (m *WorkflowInstanceSnapshot) Marshal() (dAtA []byte, err error)
func (*WorkflowInstanceSnapshot) MarshalTo ¶
func (m *WorkflowInstanceSnapshot) MarshalTo(dAtA []byte) (int, error)
func (*WorkflowInstanceSnapshot) MarshalToSizedBuffer ¶
func (m *WorkflowInstanceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowInstanceSnapshot) ProtoMessage ¶
func (*WorkflowInstanceSnapshot) ProtoMessage()
func (*WorkflowInstanceSnapshot) Reset ¶
func (m *WorkflowInstanceSnapshot) Reset()
func (*WorkflowInstanceSnapshot) Size ¶
func (m *WorkflowInstanceSnapshot) Size() (n int)
func (*WorkflowInstanceSnapshot) String ¶
func (m *WorkflowInstanceSnapshot) String() string
func (*WorkflowInstanceSnapshot) Unmarshal ¶
func (m *WorkflowInstanceSnapshot) Unmarshal(dAtA []byte) error
func (*WorkflowInstanceSnapshot) XXX_DiscardUnknown ¶
func (m *WorkflowInstanceSnapshot) XXX_DiscardUnknown()
func (*WorkflowInstanceSnapshot) XXX_Marshal ¶
func (m *WorkflowInstanceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowInstanceSnapshot) XXX_Merge ¶
func (m *WorkflowInstanceSnapshot) XXX_Merge(src proto.Message)
func (*WorkflowInstanceSnapshot) XXX_Size ¶
func (m *WorkflowInstanceSnapshot) XXX_Size() int
func (*WorkflowInstanceSnapshot) XXX_Unmarshal ¶
func (m *WorkflowInstanceSnapshot) XXX_Unmarshal(b []byte) error
type WorkflowInstanceState ¶
type WorkflowInstanceState int32
WorkflowInstanceState workflow instance state
const ( Starting WorkflowInstanceState = 0 Running WorkflowInstanceState = 1 Stopping WorkflowInstanceState = 2 Stopped WorkflowInstanceState = 3 )
func (WorkflowInstanceState) EnumDescriptor ¶
func (WorkflowInstanceState) EnumDescriptor() ([]byte, []int)
func (WorkflowInstanceState) String ¶
func (x WorkflowInstanceState) String() string
type WorkflowInstanceWorkerState ¶
type WorkflowInstanceWorkerState struct { TenantID uint64 `protobuf:"varint,1,opt,name=tenantID,proto3" json:"tenantID,omitempty"` WorkflowID uint64 `protobuf:"varint,2,opt,name=workflowID,proto3" json:"workflowID,omitempty"` InstanceID uint64 `protobuf:"varint,3,opt,name=instanceID,proto3" json:"instanceID,omitempty"` Index uint32 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"` States []StepState `protobuf:"bytes,5,rep,name=states,proto3" json:"states"` Version uint64 `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"` StopAt int64 `protobuf:"varint,7,opt,name=stopAt,proto3" json:"stopAt,omitempty"` Runner uint64 `protobuf:"varint,8,opt,name=runner,proto3" json:"runner,omitempty"` }
WorkflowInstanceWorkerState workflow instance state. instance : instanceState = 1 : N
func (*WorkflowInstanceWorkerState) Descriptor ¶
func (*WorkflowInstanceWorkerState) Descriptor() ([]byte, []int)
func (*WorkflowInstanceWorkerState) GetIndex ¶
func (m *WorkflowInstanceWorkerState) GetIndex() uint32
func (*WorkflowInstanceWorkerState) GetInstanceID ¶
func (m *WorkflowInstanceWorkerState) GetInstanceID() uint64
func (*WorkflowInstanceWorkerState) GetRunner ¶
func (m *WorkflowInstanceWorkerState) GetRunner() uint64
func (*WorkflowInstanceWorkerState) GetStates ¶
func (m *WorkflowInstanceWorkerState) GetStates() []StepState
func (*WorkflowInstanceWorkerState) GetStopAt ¶
func (m *WorkflowInstanceWorkerState) GetStopAt() int64
func (*WorkflowInstanceWorkerState) GetTenantID ¶
func (m *WorkflowInstanceWorkerState) GetTenantID() uint64
func (*WorkflowInstanceWorkerState) GetVersion ¶
func (m *WorkflowInstanceWorkerState) GetVersion() uint64
func (*WorkflowInstanceWorkerState) GetWorkflowID ¶
func (m *WorkflowInstanceWorkerState) GetWorkflowID() uint64
func (*WorkflowInstanceWorkerState) Marshal ¶
func (m *WorkflowInstanceWorkerState) Marshal() (dAtA []byte, err error)
func (*WorkflowInstanceWorkerState) MarshalTo ¶
func (m *WorkflowInstanceWorkerState) MarshalTo(dAtA []byte) (int, error)
func (*WorkflowInstanceWorkerState) MarshalToSizedBuffer ¶
func (m *WorkflowInstanceWorkerState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowInstanceWorkerState) ProtoMessage ¶
func (*WorkflowInstanceWorkerState) ProtoMessage()
func (*WorkflowInstanceWorkerState) Reset ¶
func (m *WorkflowInstanceWorkerState) Reset()
func (*WorkflowInstanceWorkerState) Size ¶
func (m *WorkflowInstanceWorkerState) Size() (n int)
func (*WorkflowInstanceWorkerState) String ¶
func (m *WorkflowInstanceWorkerState) String() string
func (*WorkflowInstanceWorkerState) Unmarshal ¶
func (m *WorkflowInstanceWorkerState) Unmarshal(dAtA []byte) error
func (*WorkflowInstanceWorkerState) XXX_DiscardUnknown ¶
func (m *WorkflowInstanceWorkerState) XXX_DiscardUnknown()
func (*WorkflowInstanceWorkerState) XXX_Marshal ¶
func (m *WorkflowInstanceWorkerState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowInstanceWorkerState) XXX_Merge ¶
func (m *WorkflowInstanceWorkerState) XXX_Merge(src proto.Message)
func (*WorkflowInstanceWorkerState) XXX_Size ¶
func (m *WorkflowInstanceWorkerState) XXX_Size() int
func (*WorkflowInstanceWorkerState) XXX_Unmarshal ¶
func (m *WorkflowInstanceWorkerState) XXX_Unmarshal(b []byte) error
type WorkflowWorker ¶
type WorkflowWorker struct { WorkflowID uint64 `protobuf:"varint,1,opt,name=workflowID,proto3" json:"workflowID,omitempty"` InstanceID uint64 `protobuf:"varint,2,opt,name=instanceID,proto3" json:"instanceID,omitempty"` Index uint32 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` }
func (*WorkflowWorker) Descriptor ¶
func (*WorkflowWorker) Descriptor() ([]byte, []int)
func (*WorkflowWorker) GetIndex ¶
func (m *WorkflowWorker) GetIndex() uint32
func (*WorkflowWorker) GetInstanceID ¶
func (m *WorkflowWorker) GetInstanceID() uint64
func (*WorkflowWorker) GetWorkflowID ¶
func (m *WorkflowWorker) GetWorkflowID() uint64
func (*WorkflowWorker) Marshal ¶
func (m *WorkflowWorker) Marshal() (dAtA []byte, err error)
func (*WorkflowWorker) MarshalToSizedBuffer ¶
func (m *WorkflowWorker) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkflowWorker) ProtoMessage ¶
func (*WorkflowWorker) ProtoMessage()
func (*WorkflowWorker) Reset ¶
func (m *WorkflowWorker) Reset()
func (*WorkflowWorker) Size ¶
func (m *WorkflowWorker) Size() (n int)
func (*WorkflowWorker) String ¶
func (m *WorkflowWorker) String() string
func (*WorkflowWorker) Unmarshal ¶
func (m *WorkflowWorker) Unmarshal(dAtA []byte) error
func (*WorkflowWorker) XXX_DiscardUnknown ¶
func (m *WorkflowWorker) XXX_DiscardUnknown()
func (*WorkflowWorker) XXX_Marshal ¶
func (m *WorkflowWorker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkflowWorker) XXX_Merge ¶
func (m *WorkflowWorker) XXX_Merge(src proto.Message)
func (*WorkflowWorker) XXX_Size ¶
func (m *WorkflowWorker) XXX_Size() int
func (*WorkflowWorker) XXX_Unmarshal ¶
func (m *WorkflowWorker) XXX_Unmarshal(b []byte) error