metapb

package
v0.0.0-...-dac20d5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 14, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMeta        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMeta          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMeta = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BMLoader_name = map[int32]string{
	0: "RawLoader",
	1: "KVLoader",
	2: "KVShardLoader",
	3: "ClickhouseLoader",
}
View Source 
var BMLoader_value = map[string]int32{
	"RawLoader":        0,
	"KVLoader":         1,
	"KVShardLoader":    2,
	"ClickhouseLoader": 3,
}
View Source 
var EventType_name = map[int32]string{
	0: "UserType",
	1: "UpdateCrowdType",
	2: "UpdateWorkflowType",
}
View Source 
var EventType_value = map[string]int32{
	"UserType":           0,
	"UpdateCrowdType":    1,
	"UpdateWorkflowType": 2,
}
View Source 
var ExectuionType_name = map[int32]string{
	0: "Direct",
	1: "Timer",
	2: "Branch",
	3: "Parallel",
}
View Source 
var ExectuionType_value = map[string]int32{
	"Direct":   0,
	"Timer":    1,
	"Branch":   2,
	"Parallel": 3,
}
View Source 
var ExprResultType_name = map[int32]string{
	0: "BoolResult",
	1: "BMResult",
}
View Source 
var ExprResultType_value = map[string]int32{
	"BoolResult": 0,
	"BMResult":   1,
}
View Source 
var Group_name = map[int32]string{
	0: "DefaultGroup",
	1: "TenantInputGroup",
	2: "TenantOutputGroup",
	3: "TenantRunnerGroup",
}
View Source 
var Group_value = map[string]int32{
	"DefaultGroup":      0,
	"TenantInputGroup":  1,
	"TenantOutputGroup": 2,
	"TenantRunnerGroup": 3,
}
View Source 
var WorkerRunnerState_name = map[int32]string{
	0: "WRRunning",
	1: "WRStopped",
}
View Source 
var WorkerRunnerState_value = map[string]int32{
	"WRRunning": 0,
	"WRStopped": 1,
}
View Source 
var WorkflowInstanceState_name = map[int32]string{
	0: "Starting",
	1: "Running",
	2: "Stopping",
	3: "Stopped",
}
View Source 
var WorkflowInstanceState_value = map[string]int32{
	"Starting": 0,
	"Running":  1,
	"Stopping": 2,
	"Stopped":  3,
}

Functions

This section is empty.

Types

type BMLoader 

type BMLoader int32

BMLoader bitmap loader type 

const (
	RawLoader        BMLoader = 0
	KVLoader         BMLoader = 1
	KVShardLoader    BMLoader = 2
	ClickhouseLoader BMLoader = 3
)

func (BMLoader) EnumDescriptor 

func (BMLoader) EnumDescriptor() ([]byte, []int)

func (BMLoader) String 

func (x BMLoader) String() string

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) MarshalTo 

func (m *CallbackAction) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *CountState) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *DirectExecution) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Event) GetType 

func (m *Event) GetType() EventType

func (*Event) GetUpdateCrowd 

func (m *Event) GetUpdateCrowd() *UpdateCrowdEvent

func (*Event) GetUpdateWorkflow 

func (m *Event) GetUpdateWorkflow() *UpdateWorkflowEvent

func (*Event) GetUser 

func (m *Event) GetUser() *UserEvent

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer 

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type EventType 

type EventType int32

EventType tenant input event type 

const (
	UserType           EventType = 0
	UpdateCrowdType    EventType = 1
	UpdateWorkflowType EventType = 2
)

func (EventType) EnumDescriptor 

func (EventType) EnumDescriptor() ([]byte, []int)

func (EventType) String 

func (x EventType) String() string

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) Descriptor() ([]byte, []int)

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) Marshal 

func (m *Execution) Marshal() (dAtA []byte, err error)

func (*Execution) MarshalTo 

func (m *Execution) MarshalTo(dAtA []byte) (int, error)

func (*Execution) MarshalToSizedBuffer 

func (m *Execution) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Execution) ProtoMessage 

func (*Execution) ProtoMessage()

func (*Execution) Reset 

func (m *Execution) Reset()

func (*Execution) Size 

func (m *Execution) Size() (n int)

func (*Execution) String 

func (m *Execution) String() string

func (*Execution) Unmarshal 

func (m *Execution) Unmarshal(dAtA []byte) error

func (*Execution) XXX_DiscardUnknown 

func (m *Execution) XXX_DiscardUnknown()

func (*Execution) XXX_Marshal 

func (m *Execution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Execution) XXX_Merge 

func (m *Execution) XXX_Merge(src proto.Message)

func (*Execution) XXX_Size 

func (m *Execution) XXX_Size() int

func (*Execution) XXX_Unmarshal 

func (m *Execution) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Expr) GetType 

func (m *Expr) GetType() ExprResultType

func (*Expr) GetValue 

func (m *Expr) GetValue() []byte

func (*Expr) Marshal 

func (m *Expr) Marshal() (dAtA []byte, err error)

func (*Expr) MarshalTo 

func (m *Expr) MarshalTo(dAtA []byte) (int, error)

func (*Expr) MarshalToSizedBuffer 

func (m *Expr) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Expr) ProtoMessage 

func (*Expr) ProtoMessage()

func (*Expr) Reset 

func (m *Expr) Reset()

func (*Expr) Size 

func (m *Expr) Size() (n int)

func (*Expr) String 

func (m *Expr) String() string

func (*Expr) Unmarshal 

func (m *Expr) Unmarshal(dAtA []byte) error

func (*Expr) XXX_DiscardUnknown 

func (m *Expr) XXX_DiscardUnknown()

func (*Expr) XXX_Marshal 

func (m *Expr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Expr) XXX_Merge 

func (m *Expr) XXX_Merge(src proto.Message)

func (*Expr) XXX_Size 

func (m *Expr) XXX_Size() int

func (*Expr) XXX_Unmarshal 

func (m *Expr) XXX_Unmarshal(b []byte) error

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 Group 

type Group int32

Group shard group 

const (
	DefaultGroup      Group = 0
	TenantInputGroup  Group = 1
	TenantOutputGroup Group = 2
	TenantRunnerGroup Group = 3
)

func (Group) EnumDescriptor 

func (Group) EnumDescriptor() ([]byte, []int)

func (Group) String 

func (x Group) 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) Descriptor() ([]byte, []int)

func (*IDSet) GetValues 

func (m *IDSet) GetValues() []IDValue

func (*IDSet) Marshal 

func (m *IDSet) Marshal() (dAtA []byte, err error)

func (*IDSet) MarshalTo 

func (m *IDSet) MarshalTo(dAtA []byte) (int, error)

func (*IDSet) MarshalToSizedBuffer 

func (m *IDSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IDSet) ProtoMessage 

func (*IDSet) ProtoMessage()

func (*IDSet) Reset 

func (m *IDSet) Reset()

func (*IDSet) Size 

func (m *IDSet) Size() (n int)

func (*IDSet) String 

func (m *IDSet) String() string

func (*IDSet) Unmarshal 

func (m *IDSet) Unmarshal(dAtA []byte) error

func (*IDSet) XXX_DiscardUnknown 

func (m *IDSet) XXX_DiscardUnknown()

func (*IDSet) XXX_Marshal 

func (m *IDSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IDSet) XXX_Merge 

func (m *IDSet) XXX_Merge(src proto.Message)

func (*IDSet) XXX_Size 

func (m *IDSet) XXX_Size() int

func (*IDSet) XXX_Unmarshal 

func (m *IDSet) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*IDValue) GetType 

func (m *IDValue) GetType() string

func (*IDValue) GetValue 

func (m *IDValue) GetValue() string

func (*IDValue) Marshal 

func (m *IDValue) Marshal() (dAtA []byte, err error)

func (*IDValue) MarshalTo 

func (m *IDValue) MarshalTo(dAtA []byte) (int, error)

func (*IDValue) MarshalToSizedBuffer 

func (m *IDValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IDValue) ProtoMessage 

func (*IDValue) ProtoMessage()

func (*IDValue) Reset 

func (m *IDValue) Reset()

func (*IDValue) Size 

func (m *IDValue) Size() (n int)

func (*IDValue) String 

func (m *IDValue) String() string

func (*IDValue) Unmarshal 

func (m *IDValue) Unmarshal(dAtA []byte) error

func (*IDValue) XXX_DiscardUnknown 

func (m *IDValue) XXX_DiscardUnknown()

func (*IDValue) XXX_Marshal 

func (m *IDValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IDValue) XXX_Merge 

func (m *IDValue) XXX_Merge(src proto.Message)

func (*IDValue) XXX_Size 

func (m *IDValue) XXX_Size() int

func (*IDValue) XXX_Unmarshal 

func (m *IDValue) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*KV) GetKey 

func (m *KV) GetKey() []byte

func (*KV) GetValue 

func (m *KV) GetValue() []byte

func (*KV) Marshal 

func (m *KV) Marshal() (dAtA []byte, err error)

func (*KV) MarshalTo 

func (m *KV) MarshalTo(dAtA []byte) (int, error)

func (*KV) MarshalToSizedBuffer 

func (m *KV) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) Reset 

func (m *KV) Reset()

func (*KV) Size 

func (m *KV) Size() (n int)

func (*KV) String 

func (m *KV) String() string

func (*KV) Unmarshal 

func (m *KV) Unmarshal(dAtA []byte) error

func (*KV) XXX_DiscardUnknown 

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal 

func (m *KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KV) XXX_Merge 

func (m *KV) XXX_Merge(src proto.Message)

func (*KV) XXX_Size 

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal 

func (m *KV) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Notify) GetCrowd 

func (m *Notify) GetCrowd() []byte

func (*Notify) GetFromAction 

func (m *Notify) GetFromAction() string

func (*Notify) GetFromStep 

func (m *Notify) GetFromStep() string

func (*Notify) GetInstanceID 

func (m *Notify) GetInstanceID() uint64

func (*Notify) GetTenantID 

func (m *Notify) GetTenantID() uint64

func (*Notify) GetToAction 

func (m *Notify) GetToAction() string

func (*Notify) GetToStep 

func (m *Notify) GetToStep() string

func (*Notify) GetToStepCycleTTL 

func (m *Notify) GetToStepCycleTTL() int32

func (*Notify) GetUserID 

func (m *Notify) GetUserID() uint32

func (*Notify) GetWorkflowID 

func (m *Notify) GetWorkflowID() uint64

func (*Notify) Marshal 

func (m *Notify) Marshal() (dAtA []byte, err error)

func (*Notify) MarshalTo 

func (m *Notify) MarshalTo(dAtA []byte) (int, error)

func (*Notify) MarshalToSizedBuffer 

func (m *Notify) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Notify) ProtoMessage 

func (*Notify) ProtoMessage()

func (*Notify) Reset 

func (m *Notify) Reset()

func (*Notify) Size 

func (m *Notify) Size() (n int)

func (*Notify) String 

func (m *Notify) String() string

func (*Notify) Unmarshal 

func (m *Notify) Unmarshal(dAtA []byte) error

func (*Notify) XXX_DiscardUnknown 

func (m *Notify) XXX_DiscardUnknown()

func (*Notify) XXX_Marshal 

func (m *Notify) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Notify) XXX_Merge 

func (m *Notify) XXX_Merge(src proto.Message)

func (*Notify) XXX_Size 

func (m *Notify) XXX_Size() int

func (*Notify) XXX_Unmarshal 

func (m *Notify) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Partiton) GetConsumer 

func (m *Partiton) GetConsumer() uint32

func (*Partiton) GetLastFetchTS 

func (m *Partiton) GetLastFetchTS() int64

func (*Partiton) GetVersion 

func (m *Partiton) GetVersion() uint64

func (*Partiton) Marshal 

func (m *Partiton) Marshal() (dAtA []byte, err error)

func (*Partiton) MarshalTo 

func (m *Partiton) MarshalTo(dAtA []byte) (int, error)

func (*Partiton) MarshalToSizedBuffer 

func (m *Partiton) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Partiton) ProtoMessage 

func (*Partiton) ProtoMessage()

func (*Partiton) Reset 

func (m *Partiton) Reset()

func (*Partiton) Size 

func (m *Partiton) Size() (n int)

func (*Partiton) String 

func (m *Partiton) String() string

func (*Partiton) Unmarshal 

func (m *Partiton) Unmarshal(dAtA []byte) error

func (*Partiton) XXX_DiscardUnknown 

func (m *Partiton) XXX_DiscardUnknown()

func (*Partiton) XXX_Marshal 

func (m *Partiton) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Partiton) XXX_Merge 

func (m *Partiton) XXX_Merge(src proto.Message)

func (*Partiton) XXX_Size 

func (m *Partiton) XXX_Size() int

func (*Partiton) XXX_Unmarshal 

func (m *Partiton) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *QueueState) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SetKVAction) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Step) GetEnterAction 

func (m *Step) GetEnterAction() string

func (*Step) GetExecution 

func (m *Step) GetExecution() Execution

func (*Step) GetLeaveAction 

func (m *Step) GetLeaveAction() string

func (*Step) GetName 

func (m *Step) GetName() string

func (*Step) GetTTL 

func (m *Step) GetTTL() int32

func (*Step) Marshal 

func (m *Step) Marshal() (dAtA []byte, err error)

func (*Step) MarshalTo 

func (m *Step) MarshalTo(dAtA []byte) (int, error)

func (*Step) MarshalToSizedBuffer 

func (m *Step) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Step) ProtoMessage 

func (*Step) ProtoMessage()

func (*Step) Reset 

func (m *Step) Reset()

func (*Step) Size 

func (m *Step) Size() (n int)

func (*Step) String 

func (m *Step) String() string

func (*Step) Unmarshal 

func (m *Step) Unmarshal(dAtA []byte) error

func (*Step) XXX_DiscardUnknown 

func (m *Step) XXX_DiscardUnknown()

func (*Step) XXX_Marshal 

func (m *Step) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Step) XXX_Merge 

func (m *Step) XXX_Merge(src proto.Message)

func (*Step) XXX_Size 

func (m *Step) XXX_Size() int

func (*Step) XXX_Unmarshal 

func (m *Step) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*StepState) GetLoader 

func (m *StepState) GetLoader() BMLoader

func (*StepState) GetLoaderMeta 

func (m *StepState) GetLoaderMeta() []byte

func (*StepState) GetStep 

func (m *StepState) GetStep() Step

func (*StepState) GetTotalCrowd 

func (m *StepState) GetTotalCrowd() uint64

func (*StepState) Marshal 

func (m *StepState) Marshal() (dAtA []byte, err error)

func (*StepState) MarshalTo 

func (m *StepState) MarshalTo(dAtA []byte) (int, error)

func (*StepState) MarshalToSizedBuffer 

func (m *StepState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StepState) ProtoMessage 

func (*StepState) ProtoMessage()

func (*StepState) Reset 

func (m *StepState) Reset()

func (*StepState) Size 

func (m *StepState) Size() (n int)

func (*StepState) String 

func (m *StepState) String() string

func (*StepState) Unmarshal 

func (m *StepState) Unmarshal(dAtA []byte) error

func (*StepState) XXX_DiscardUnknown 

func (m *StepState) XXX_DiscardUnknown()

func (*StepState) XXX_Marshal 

func (m *StepState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepState) XXX_Merge 

func (m *StepState) XXX_Merge(src proto.Message)

func (*StepState) XXX_Size 

func (m *StepState) XXX_Size() int

func (*StepState) XXX_Unmarshal 

func (m *StepState) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Tenant) GetID 

func (m *Tenant) GetID() uint64

func (*Tenant) GetInput 

func (m *Tenant) GetInput() TenantQueue

func (*Tenant) GetInputsState 

func (m *Tenant) GetInputsState() []bool

func (*Tenant) GetOutput 

func (m *Tenant) GetOutput() TenantQueue

func (*Tenant) GetOutputsState 

func (m *Tenant) GetOutputsState() []bool

func (*Tenant) GetRunners 

func (m *Tenant) GetRunners() uint64

func (*Tenant) GetRunnersState 

func (m *Tenant) GetRunnersState() []bool

func (*Tenant) Marshal 

func (m *Tenant) Marshal() (dAtA []byte, err error)

func (*Tenant) MarshalTo 

func (m *Tenant) MarshalTo(dAtA []byte) (int, error)

func (*Tenant) MarshalToSizedBuffer 

func (m *Tenant) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Tenant) ProtoMessage 

func (*Tenant) ProtoMessage()

func (*Tenant) Reset 

func (m *Tenant) Reset()

func (*Tenant) Size 

func (m *Tenant) Size() (n int)

func (*Tenant) String 

func (m *Tenant) String() string

func (*Tenant) Unmarshal 

func (m *Tenant) Unmarshal(dAtA []byte) error

func (*Tenant) XXX_DiscardUnknown 

func (m *Tenant) XXX_DiscardUnknown()

func (*Tenant) XXX_Marshal 

func (m *Tenant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tenant) XXX_Merge 

func (m *Tenant) XXX_Merge(src proto.Message)

func (*Tenant) XXX_Size 

func (m *Tenant) XXX_Size() int

func (*Tenant) XXX_Unmarshal 

func (m *Tenant) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *TenantQueue) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *TimerExecution) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *UpdateCrowdEvent) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*UserEvent) GetData 

func (m *UserEvent) GetData() []KV

func (*UserEvent) GetTenantID 

func (m *UserEvent) GetTenantID() uint64

func (*UserEvent) GetUserID 

func (m *UserEvent) GetUserID() uint32

func (*UserEvent) Marshal 

func (m *UserEvent) Marshal() (dAtA []byte, err error)

func (*UserEvent) MarshalTo 

func (m *UserEvent) MarshalTo(dAtA []byte) (int, error)

func (*UserEvent) MarshalToSizedBuffer 

func (m *UserEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserEvent) ProtoMessage 

func (*UserEvent) ProtoMessage()

func (*UserEvent) Reset 

func (m *UserEvent) Reset()

func (*UserEvent) Size 

func (m *UserEvent) Size() (n int)

func (*UserEvent) String 

func (m *UserEvent) String() string

func (*UserEvent) Unmarshal 

func (m *UserEvent) Unmarshal(dAtA []byte) error

func (*UserEvent) XXX_DiscardUnknown 

func (m *UserEvent) XXX_DiscardUnknown()

func (*UserEvent) XXX_Marshal 

func (m *UserEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserEvent) XXX_Merge 

func (m *UserEvent) XXX_Merge(src proto.Message)

func (*UserEvent) XXX_Size 

func (m *UserEvent) XXX_Size() int

func (*UserEvent) XXX_Unmarshal 

func (m *UserEvent) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *WorkerRunner) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Workflow) GetID 

func (m *Workflow) GetID() uint64

func (*Workflow) GetName 

func (m *Workflow) GetName() string

func (*Workflow) GetSteps 

func (m *Workflow) GetSteps() []Step

func (*Workflow) GetStopAt 

func (m *Workflow) GetStopAt() int64

func (*Workflow) GetTenantID 

func (m *Workflow) GetTenantID() uint64

func (*Workflow) Marshal 

func (m *Workflow) Marshal() (dAtA []byte, err error)

func (*Workflow) MarshalTo 

func (m *Workflow) MarshalTo(dAtA []byte) (int, error)

func (*Workflow) MarshalToSizedBuffer 

func (m *Workflow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) Reset 

func (m *Workflow) Reset()

func (*Workflow) Size 

func (m *Workflow) Size() (n int)

func (*Workflow) String 

func (m *Workflow) String() string

func (*Workflow) Unmarshal 

func (m *Workflow) Unmarshal(dAtA []byte) error

func (*Workflow) XXX_DiscardUnknown 

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal 

func (m *Workflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow) XXX_Merge 

func (m *Workflow) XXX_Merge(src proto.Message)

func (*Workflow) XXX_Size 

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal 

func (m *Workflow) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *WorkflowInstance) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *WorkflowWorker) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.