rpcpb

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: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// EmptyResp empty resp
	EmptyResp = EmptyResponse{}
	// EmptyRespBytes empty resp bytes
	EmptyRespBytes = protoc.MustMarshal(&EmptyResp)
	// EmptyBytesSliceBytes empty bytes slice response
	EmptyBytesSliceBytes = protoc.MustMarshal(&BytesSliceResponse{})
	// TrueRespBytes true response
	TrueRespBytes = protoc.MustMarshal(&BoolResponse{Value: true})
	// FalseRespBytes true response
	FalseRespBytes = protoc.MustMarshal(&BoolResponse{})
)
View Source 
var (
	ErrInvalidLengthRpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Cmp_name = map[int32]string{
	0: "Exists",
	1: "NotExists",
	2: "Equal",
	3: "NotEqual",
	4: "GE",
	5: "GT",
	6: "LE",
	7: "LT",
}
View Source 
var Cmp_value = map[string]int32{
	"Exists":    0,
	"NotExists": 1,
	"Equal":     2,
	"NotEqual":  3,
	"GE":        4,
	"GT":        5,
	"LE":        6,
	"LT":        7,
}
View Source 
var Type_name = map[int32]string{
	0:   "Set",
	1:   "Get",
	2:   "Delete",
	3:   "Scan",
	4:   "SetIf",
	5:   "DeleteIf",
	100: "BMCreate",
	101: "BMAdd",
	102: "BMRemove",
	103: "BMClear",
	104: "BMContains",
	105: "BMCount",
	106: "BMRange",
	200: "StartingInstance",
	201: "LastInstance",
	202: "HistoryInstance",
	203: "UpdateWorkflow",
	204: "UpdateCrowd",
	205: "StartedInstance",
	206: "StopInstance",
	207: "StoppedInstance",
	208: "CreateInstanceStateShard",
	209: "UpdateInstanceStateShard",
	210: "RemoveInstanceStateShard",
	211: "InstanceCountState",
	212: "InstanceCrowdState",
	300: "QueueAdd",
	301: "QueueFetch",
	302: "QueueJoin",
	303: "QueueScan",
	304: "QueueCommit",
	305: "QueueDelete",
	400: "TenantInit",
	401: "UpdateMapping",
	402: "GetMapping",
	403: "UpdateProfile",
	404: "GetProfile",
	405: "AddEvent",
	406: "FetchNotify",
	407: "ScanMapping",
	408: "GetIDSet",
	409: "TenantInitStateUpdate",
	501: "AllocID",
	502: "ResetID",
	601: "Lock",
	602: "Unlock",
}
View Source 
var Type_value = map[string]int32{
	"Set":                      0,
	"Get":                      1,
	"Delete":                   2,
	"Scan":                     3,
	"SetIf":                    4,
	"DeleteIf":                 5,
	"BMCreate":                 100,
	"BMAdd":                    101,
	"BMRemove":                 102,
	"BMClear":                  103,
	"BMContains":               104,
	"BMCount":                  105,
	"BMRange":                  106,
	"StartingInstance":         200,
	"LastInstance":             201,
	"HistoryInstance":          202,
	"UpdateWorkflow":           203,
	"UpdateCrowd":              204,
	"StartedInstance":          205,
	"StopInstance":             206,
	"StoppedInstance":          207,
	"CreateInstanceStateShard": 208,
	"UpdateInstanceStateShard": 209,
	"RemoveInstanceStateShard": 210,
	"InstanceCountState":       211,
	"InstanceCrowdState":       212,
	"QueueAdd":                 300,
	"QueueFetch":               301,
	"QueueJoin":                302,
	"QueueScan":                303,
	"QueueCommit":              304,
	"QueueDelete":              305,
	"TenantInit":               400,
	"UpdateMapping":            401,
	"GetMapping":               402,
	"UpdateProfile":            403,
	"GetProfile":               404,
	"AddEvent":                 405,
	"FetchNotify":              406,
	"ScanMapping":              407,
	"GetIDSet":                 408,
	"TenantInitStateUpdate":    409,
	"AllocID":                  501,
	"ResetID":                  502,
	"Lock":                     601,
	"Unlock":                   602,
}

Functions

func ReleaseAllocIDRequest 

func ReleaseAllocIDRequest(value *AllocIDRequest)

ReleaseAllocIDRequest returns the value to pool

func ReleaseBMAddRequest 

func ReleaseBMAddRequest(value *BMAddRequest)

ReleaseBMAddRequest returns the value to pool

func ReleaseBMClearRequest 

func ReleaseBMClearRequest(value *BMClearRequest)

ReleaseBMClearRequest returns the value to pool

func ReleaseBMContainsRequest 

func ReleaseBMContainsRequest(value *BMContainsRequest)

ReleaseBMContainsRequest returns the value to pool

func ReleaseBMCountRequest 

func ReleaseBMCountRequest(value *BMCountRequest)

ReleaseBMCountRequest returns the value to pool

func ReleaseBMCreateRequest 

func ReleaseBMCreateRequest(value *BMCreateRequest)

ReleaseBMCreateRequest returns the value to pool

func ReleaseBMRangeRequest 

func ReleaseBMRangeRequest(value *BMRangeRequest)

ReleaseBMRangeRequest returns the value to pool

func ReleaseBMRemoveRequest 

func ReleaseBMRemoveRequest(value *BMRemoveRequest)

ReleaseBMRemoveRequest returns the value to pool

func ReleaseBoolResponse 

func ReleaseBoolResponse(value *BoolResponse)

ReleaseBoolResponse returns the value to pool

func ReleaseBytesResponse 

func ReleaseBytesResponse(value *BytesResponse)

ReleaseBytesResponse returns the value to pool

func ReleaseBytesSliceResponse 

func ReleaseBytesSliceResponse(value *BytesSliceResponse)

ReleaseBytesSliceResponse returns the value to pool

func ReleaseCreateInstanceStateShardRequest 

func ReleaseCreateInstanceStateShardRequest(value *CreateInstanceStateShardRequest)

ReleaseCreateInstanceStateShardRequest returns the value to pool

func ReleaseDeleteIfRequest 

func ReleaseDeleteIfRequest(value *DeleteIfRequest)

ReleaseDeleteIfRequest returns the value to pool

func ReleaseDeleteRequest 

func ReleaseDeleteRequest(value *DeleteRequest)

ReleaseDeleteRequest returns the value to pool

func ReleaseGetRequest 

func ReleaseGetRequest(value *GetRequest)

ReleaseGetRequest returns the value to pool

func ReleaseLockRequest 

func ReleaseLockRequest(value *LockRequest)

ReleaseLockRequest returns the value to pool

func ReleaseQueueAddRequest 

func ReleaseQueueAddRequest(value *QueueAddRequest)

ReleaseQueueAddRequest returns the value to pool

func ReleaseQueueCommitRequest 

func ReleaseQueueCommitRequest(value *QueueCommitRequest)

ReleaseQueueCommitRequest returns the value to pool

func ReleaseQueueDeleteRequest 

func ReleaseQueueDeleteRequest(value *QueueDeleteRequest)

ReleaseQueueDeleteRequest returns the value to pool

func ReleaseQueueFetchRequest 

func ReleaseQueueFetchRequest(value *QueueFetchRequest)

ReleaseQueueFetchRequest returns the value to pool

func ReleaseQueueJoinGroupRequest 

func ReleaseQueueJoinGroupRequest(value *QueueJoinGroupRequest)

ReleaseQueueJoinGroupRequest returns the value to pool

func ReleaseQueueScanRequest 

func ReleaseQueueScanRequest(value *QueueScanRequest)

ReleaseQueueScanRequest returns the value to pool

func ReleaseRemoveInstanceStateShardRequest 

func ReleaseRemoveInstanceStateShardRequest(value *RemoveInstanceStateShardRequest)

ReleaseRemoveInstanceStateShardRequest returns the value to pool

func ReleaseRequest 

func ReleaseRequest(value *Request)

ReleaseRequest returns the value to pool

func ReleaseResetIDRequest 

func ReleaseResetIDRequest(value *ResetIDRequest)

ReleaseResetIDRequest returns the value to pool

func ReleaseResponse 

func ReleaseResponse(value *Response)

ReleaseResponse returns the value to pool

func ReleaseScanMappingRequest 

func ReleaseScanMappingRequest(value *ScanMappingRequest)

ReleaseScanMappingRequest returns the value to pool

func ReleaseScanRequest 

func ReleaseScanRequest(value *ScanRequest)

ReleaseScanRequest returns the value to pool

func ReleaseSetIfRequest 

func ReleaseSetIfRequest(value *SetIfRequest)

ReleaseSetIfRequest returns the value to pool

func ReleaseSetRequest 

func ReleaseSetRequest(value *SetRequest)

ReleaseSetRequest returns the value to pool

func ReleaseStartedInstanceRequest 

func ReleaseStartedInstanceRequest(value *StartedInstanceRequest)

ReleaseStartedInstanceRequest returns the value to pool

func ReleaseStartingInstanceRequest 

func ReleaseStartingInstanceRequest(value *StartingInstanceRequest)

ReleaseStartingInstanceRequest returns the value to pool

func ReleaseStopInstanceRequest 

func ReleaseStopInstanceRequest(value *StopInstanceRequest)

ReleaseStopInstanceRequest returns the value to pool

func ReleaseStoppedInstanceRequest 

func ReleaseStoppedInstanceRequest(value *StoppedInstanceRequest)

ReleaseStoppedInstanceRequest returns the value to pool

func ReleaseTenantInitRequest 

func ReleaseTenantInitRequest(value *TenantInitRequest)

ReleaseTenantInitRequest returns the value to pool

func ReleaseTenantInitStateUpdateRequest 

func ReleaseTenantInitStateUpdateRequest(value *TenantInitStateUpdateRequest)

ReleaseTenantInitStateUpdateRequest returns the value to pool

func ReleaseUint32RangeResponse 

func ReleaseUint32RangeResponse(value *Uint32RangeResponse)

ReleaseUint32RangeResponse returns the value to pool

func ReleaseUint32Response 

func ReleaseUint32Response(value *Uint32Response)

ReleaseUint32Response returns the value to pool

func ReleaseUint32SliceResponse 

func ReleaseUint32SliceResponse(value *Uint32SliceResponse)

ReleaseUint32SliceResponse returns the value to pool

func ReleaseUint64Response 

func ReleaseUint64Response(value *Uint64Response)

ReleaseUint64Response returns the value to pool

func ReleaseUnlockRequest 

func ReleaseUnlockRequest(value *UnlockRequest)

ReleaseUnlockRequest returns the value to pool

func ReleaseUpdateInstanceStateShardRequest 

func ReleaseUpdateInstanceStateShardRequest(value *UpdateInstanceStateShardRequest)

ReleaseUpdateInstanceStateShardRequest returns the value to pool

func ReleaseUpdateMappingRequest 

func ReleaseUpdateMappingRequest(value *UpdateMappingRequest)

ReleaseUpdateMappingRequest returns the value to pool

Types

type AddEventRequest 

type AddEventRequest struct {
	Event metapb.UserEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event"`
}

AddEventRequest add event

func (*AddEventRequest) Descriptor 

func (*AddEventRequest) Descriptor() ([]byte, []int)

func (*AddEventRequest) GetEvent 

func (m *AddEventRequest) GetEvent() metapb.UserEvent

func (*AddEventRequest) Marshal 

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

func (*AddEventRequest) MarshalTo 

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

func (*AddEventRequest) MarshalToSizedBuffer 

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

func (*AddEventRequest) ProtoMessage 

func (*AddEventRequest) ProtoMessage()

func (*AddEventRequest) Reset 

func (m *AddEventRequest) Reset()

func (*AddEventRequest) Size 

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

func (*AddEventRequest) String 

func (m *AddEventRequest) String() string

func (*AddEventRequest) Unmarshal 

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

func (*AddEventRequest) XXX_DiscardUnknown 

func (m *AddEventRequest) XXX_DiscardUnknown()

func (*AddEventRequest) XXX_Marshal 

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

func (*AddEventRequest) XXX_Merge 

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

func (*AddEventRequest) XXX_Size 

func (m *AddEventRequest) XXX_Size() int

func (*AddEventRequest) XXX_Unmarshal 

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

type AllocIDRequest 

type AllocIDRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Batch uint64 `protobuf:"varint,2,opt,name=batch,proto3" json:"batch,omitempty"`
}

AllocIDRequest alloc id request

func AcquireAllocIDRequest 

func AcquireAllocIDRequest() *AllocIDRequest

AcquireAllocIDRequest returns value from pool

func (*AllocIDRequest) Descriptor 

func (*AllocIDRequest) Descriptor() ([]byte, []int)

func (*AllocIDRequest) GetBatch 

func (m *AllocIDRequest) GetBatch() uint64

func (*AllocIDRequest) GetKey 

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

func (*AllocIDRequest) Marshal 

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

func (*AllocIDRequest) MarshalTo 

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

func (*AllocIDRequest) MarshalToSizedBuffer 

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

func (*AllocIDRequest) ProtoMessage 

func (*AllocIDRequest) ProtoMessage()

func (*AllocIDRequest) Reset 

func (m *AllocIDRequest) Reset()

func (*AllocIDRequest) Size 

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

func (*AllocIDRequest) String 

func (m *AllocIDRequest) String() string

func (*AllocIDRequest) Unmarshal 

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

func (*AllocIDRequest) XXX_DiscardUnknown 

func (m *AllocIDRequest) XXX_DiscardUnknown()

func (*AllocIDRequest) XXX_Marshal 

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

func (*AllocIDRequest) XXX_Merge 

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

func (*AllocIDRequest) XXX_Size 

func (m *AllocIDRequest) XXX_Size() int

func (*AllocIDRequest) XXX_Unmarshal 

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

type BMAddRequest 

type BMAddRequest struct {
	Key   []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []uint32 `protobuf:"varint,2,rep,packed,name=value,proto3" json:"value,omitempty"`
	Mod   uint32   `protobuf:"varint,3,opt,name=mod,proto3" json:"mod,omitempty"`
}

BMAddRequest add some uint64 to a bitmap

func AcquireBMAddRequest 

func AcquireBMAddRequest() *BMAddRequest

AcquireBMAddRequest returns value from pool

func (*BMAddRequest) Descriptor 

func (*BMAddRequest) Descriptor() ([]byte, []int)

func (*BMAddRequest) GetKey 

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

func (*BMAddRequest) GetMod 

func (m *BMAddRequest) GetMod() uint32

func (*BMAddRequest) GetValue 

func (m *BMAddRequest) GetValue() []uint32

func (*BMAddRequest) Marshal 

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

func (*BMAddRequest) MarshalTo 

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

func (*BMAddRequest) MarshalToSizedBuffer 

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

func (*BMAddRequest) ProtoMessage 

func (*BMAddRequest) ProtoMessage()

func (*BMAddRequest) Reset 

func (m *BMAddRequest) Reset()

func (*BMAddRequest) Size 

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

func (*BMAddRequest) String 

func (m *BMAddRequest) String() string

func (*BMAddRequest) Unmarshal 

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

func (*BMAddRequest) XXX_DiscardUnknown 

func (m *BMAddRequest) XXX_DiscardUnknown()

func (*BMAddRequest) XXX_Marshal 

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

func (*BMAddRequest) XXX_Merge 

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

func (*BMAddRequest) XXX_Size 

func (m *BMAddRequest) XXX_Size() int

func (*BMAddRequest) XXX_Unmarshal 

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

type BMClearRequest 

type BMClearRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

BMClearRequest clear a bitmap

func AcquireBMClearRequest 

func AcquireBMClearRequest() *BMClearRequest

AcquireBMClearRequest returns value from pool

func (*BMClearRequest) Descriptor 

func (*BMClearRequest) Descriptor() ([]byte, []int)

func (*BMClearRequest) GetKey 

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

func (*BMClearRequest) Marshal 

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

func (*BMClearRequest) MarshalTo 

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

func (*BMClearRequest) MarshalToSizedBuffer 

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

func (*BMClearRequest) ProtoMessage 

func (*BMClearRequest) ProtoMessage()

func (*BMClearRequest) Reset 

func (m *BMClearRequest) Reset()

func (*BMClearRequest) Size 

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

func (*BMClearRequest) String 

func (m *BMClearRequest) String() string

func (*BMClearRequest) Unmarshal 

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

func (*BMClearRequest) XXX_DiscardUnknown 

func (m *BMClearRequest) XXX_DiscardUnknown()

func (*BMClearRequest) XXX_Marshal 

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

func (*BMClearRequest) XXX_Merge 

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

func (*BMClearRequest) XXX_Size 

func (m *BMClearRequest) XXX_Size() int

func (*BMClearRequest) XXX_Unmarshal 

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

type BMContainsRequest 

type BMContainsRequest struct {
	Key   []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []uint32 `protobuf:"varint,2,rep,packed,name=value,proto3" json:"value,omitempty"`
}

BMContainsRequest check some uint64 is in a bitmap

func AcquireBMContainsRequest 

func AcquireBMContainsRequest() *BMContainsRequest

AcquireBMContainsRequest returns value from pool

func (*BMContainsRequest) Descriptor 

func (*BMContainsRequest) Descriptor() ([]byte, []int)

func (*BMContainsRequest) GetKey 

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

func (*BMContainsRequest) GetValue 

func (m *BMContainsRequest) GetValue() []uint32

func (*BMContainsRequest) Marshal 

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

func (*BMContainsRequest) MarshalTo 

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

func (*BMContainsRequest) MarshalToSizedBuffer 

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

func (*BMContainsRequest) ProtoMessage 

func (*BMContainsRequest) ProtoMessage()

func (*BMContainsRequest) Reset 

func (m *BMContainsRequest) Reset()

func (*BMContainsRequest) Size 

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

func (*BMContainsRequest) String 

func (m *BMContainsRequest) String() string

func (*BMContainsRequest) Unmarshal 

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

func (*BMContainsRequest) XXX_DiscardUnknown 

func (m *BMContainsRequest) XXX_DiscardUnknown()

func (*BMContainsRequest) XXX_Marshal 

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

func (*BMContainsRequest) XXX_Merge 

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

func (*BMContainsRequest) XXX_Size 

func (m *BMContainsRequest) XXX_Size() int

func (*BMContainsRequest) XXX_Unmarshal 

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

type BMCountRequest 

type BMCountRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

BMCountRequest returns the count of a bitmap

func AcquireBMCountRequest 

func AcquireBMCountRequest() *BMCountRequest

AcquireBMCountRequest returns value from pool

func (*BMCountRequest) Descriptor 

func (*BMCountRequest) Descriptor() ([]byte, []int)

func (*BMCountRequest) GetKey 

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

func (*BMCountRequest) Marshal 

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

func (*BMCountRequest) MarshalTo 

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

func (*BMCountRequest) MarshalToSizedBuffer 

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

func (*BMCountRequest) ProtoMessage 

func (*BMCountRequest) ProtoMessage()

func (*BMCountRequest) Reset 

func (m *BMCountRequest) Reset()

func (*BMCountRequest) Size 

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

func (*BMCountRequest) String 

func (m *BMCountRequest) String() string

func (*BMCountRequest) Unmarshal 

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

func (*BMCountRequest) XXX_DiscardUnknown 

func (m *BMCountRequest) XXX_DiscardUnknown()

func (*BMCountRequest) XXX_Marshal 

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

func (*BMCountRequest) XXX_Merge 

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

func (*BMCountRequest) XXX_Size 

func (m *BMCountRequest) XXX_Size() int

func (*BMCountRequest) XXX_Unmarshal 

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

type BMCreateRequest 

type BMCreateRequest struct {
	Key   []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []uint32 `protobuf:"varint,2,rep,packed,name=value,proto3" json:"value,omitempty"`
	Mod   uint32   `protobuf:"varint,3,opt,name=mod,proto3" json:"mod,omitempty"`
}

BMCreateRequest create a bitmap

func AcquireBMCreateRequest 

func AcquireBMCreateRequest() *BMCreateRequest

AcquireBMCreateRequest returns value from pool

func (*BMCreateRequest) Descriptor 

func (*BMCreateRequest) Descriptor() ([]byte, []int)

func (*BMCreateRequest) GetKey 

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

func (*BMCreateRequest) GetMod 

func (m *BMCreateRequest) GetMod() uint32

func (*BMCreateRequest) GetValue 

func (m *BMCreateRequest) GetValue() []uint32

func (*BMCreateRequest) Marshal 

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

func (*BMCreateRequest) MarshalTo 

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

func (*BMCreateRequest) MarshalToSizedBuffer 

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

func (*BMCreateRequest) ProtoMessage 

func (*BMCreateRequest) ProtoMessage()

func (*BMCreateRequest) Reset 

func (m *BMCreateRequest) Reset()

func (*BMCreateRequest) Size 

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

func (*BMCreateRequest) String 

func (m *BMCreateRequest) String() string

func (*BMCreateRequest) Unmarshal 

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

func (*BMCreateRequest) XXX_DiscardUnknown 

func (m *BMCreateRequest) XXX_DiscardUnknown()

func (*BMCreateRequest) XXX_Marshal 

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

func (*BMCreateRequest) XXX_Merge 

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

func (*BMCreateRequest) XXX_Size 

func (m *BMCreateRequest) XXX_Size() int

func (*BMCreateRequest) XXX_Unmarshal 

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

type BMRangeRequest 

type BMRangeRequest struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Start uint32 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	Limit uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
}

BMRangeRequest returns the limit uint64s that that >= start of a bitmap

func AcquireBMRangeRequest 

func AcquireBMRangeRequest() *BMRangeRequest

AcquireBMRangeRequest returns value from pool

func (*BMRangeRequest) Descriptor 

func (*BMRangeRequest) Descriptor() ([]byte, []int)

func (*BMRangeRequest) GetKey 

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

func (*BMRangeRequest) GetLimit 

func (m *BMRangeRequest) GetLimit() uint64

func (*BMRangeRequest) GetStart 

func (m *BMRangeRequest) GetStart() uint32

func (*BMRangeRequest) Marshal 

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

func (*BMRangeRequest) MarshalTo 

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

func (*BMRangeRequest) MarshalToSizedBuffer 

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

func (*BMRangeRequest) ProtoMessage 

func (*BMRangeRequest) ProtoMessage()

func (*BMRangeRequest) Reset 

func (m *BMRangeRequest) Reset()

func (*BMRangeRequest) Size 

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

func (*BMRangeRequest) String 

func (m *BMRangeRequest) String() string

func (*BMRangeRequest) Unmarshal 

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

func (*BMRangeRequest) XXX_DiscardUnknown 

func (m *BMRangeRequest) XXX_DiscardUnknown()

func (*BMRangeRequest) XXX_Marshal 

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

func (*BMRangeRequest) XXX_Merge 

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

func (*BMRangeRequest) XXX_Size 

func (m *BMRangeRequest) XXX_Size() int

func (*BMRangeRequest) XXX_Unmarshal 

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

type BMRemoveRequest 

type BMRemoveRequest struct {
	Key   []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []uint32 `protobuf:"varint,2,rep,packed,name=value,proto3" json:"value,omitempty"`
}

BMRemoveRequest remove some uint64 from a bitmap

func AcquireBMRemoveRequest 

func AcquireBMRemoveRequest() *BMRemoveRequest

AcquireBMRemoveRequest returns value from pool

func (*BMRemoveRequest) Descriptor 

func (*BMRemoveRequest) Descriptor() ([]byte, []int)

func (*BMRemoveRequest) GetKey 

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

func (*BMRemoveRequest) GetValue 

func (m *BMRemoveRequest) GetValue() []uint32

func (*BMRemoveRequest) Marshal 

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

func (*BMRemoveRequest) MarshalTo 

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

func (*BMRemoveRequest) MarshalToSizedBuffer 

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

func (*BMRemoveRequest) ProtoMessage 

func (*BMRemoveRequest) ProtoMessage()

func (*BMRemoveRequest) Reset 

func (m *BMRemoveRequest) Reset()

func (*BMRemoveRequest) Size 

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

func (*BMRemoveRequest) String 

func (m *BMRemoveRequest) String() string

func (*BMRemoveRequest) Unmarshal 

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

func (*BMRemoveRequest) XXX_DiscardUnknown 

func (m *BMRemoveRequest) XXX_DiscardUnknown()

func (*BMRemoveRequest) XXX_Marshal 

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

func (*BMRemoveRequest) XXX_Merge 

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

func (*BMRemoveRequest) XXX_Size 

func (m *BMRemoveRequest) XXX_Size() int

func (*BMRemoveRequest) XXX_Unmarshal 

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

type BoolResponse 

type BoolResponse struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}

BoolResponse response

func AcquireBoolResponse 

func AcquireBoolResponse() *BoolResponse

AcquireBoolResponse returns value from pool

func (*BoolResponse) Descriptor 

func (*BoolResponse) Descriptor() ([]byte, []int)

func (*BoolResponse) GetValue 

func (m *BoolResponse) GetValue() bool

func (*BoolResponse) Marshal 

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

func (*BoolResponse) MarshalTo 

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

func (*BoolResponse) MarshalToSizedBuffer 

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

func (*BoolResponse) ProtoMessage 

func (*BoolResponse) ProtoMessage()

func (*BoolResponse) Reset 

func (m *BoolResponse) Reset()

func (*BoolResponse) Size 

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

func (*BoolResponse) String 

func (m *BoolResponse) String() string

func (*BoolResponse) Unmarshal 

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

func (*BoolResponse) XXX_DiscardUnknown 

func (m *BoolResponse) XXX_DiscardUnknown()

func (*BoolResponse) XXX_Marshal 

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

func (*BoolResponse) XXX_Merge 

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

func (*BoolResponse) XXX_Size 

func (m *BoolResponse) XXX_Size() int

func (*BoolResponse) XXX_Unmarshal 

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

type BytesResponse 

type BytesResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

BytesResponse response

func AcquireBytesResponse 

func AcquireBytesResponse() *BytesResponse

AcquireBytesResponse returns value from pool

func (*BytesResponse) Descriptor 

func (*BytesResponse) Descriptor() ([]byte, []int)

func (*BytesResponse) GetValue 

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

func (*BytesResponse) Marshal 

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

func (*BytesResponse) MarshalTo 

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

func (*BytesResponse) MarshalToSizedBuffer 

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

func (*BytesResponse) ProtoMessage 

func (*BytesResponse) ProtoMessage()

func (*BytesResponse) Reset 

func (m *BytesResponse) Reset()

func (*BytesResponse) Size 

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

func (*BytesResponse) String 

func (m *BytesResponse) String() string

func (*BytesResponse) Unmarshal 

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

func (*BytesResponse) XXX_DiscardUnknown 

func (m *BytesResponse) XXX_DiscardUnknown()

func (*BytesResponse) XXX_Marshal 

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

func (*BytesResponse) XXX_Merge 

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

func (*BytesResponse) XXX_Size 

func (m *BytesResponse) XXX_Size() int

func (*BytesResponse) XXX_Unmarshal 

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

type BytesSliceResponse 

type BytesSliceResponse struct {
	Keys      [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Values    [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	LastValue uint64   `protobuf:"varint,3,opt,name=lastValue,proto3" json:"lastValue,omitempty"`
}

BytesSliceResponse response

func AcquireBytesSliceResponse 

func AcquireBytesSliceResponse() *BytesSliceResponse

AcquireBytesSliceResponse returns value from pool

func (*BytesSliceResponse) Descriptor 

func (*BytesSliceResponse) Descriptor() ([]byte, []int)

func (*BytesSliceResponse) GetKeys 

func (m *BytesSliceResponse) GetKeys() [][]byte

func (*BytesSliceResponse) GetLastValue 

func (m *BytesSliceResponse) GetLastValue() uint64

func (*BytesSliceResponse) GetValues 

func (m *BytesSliceResponse) GetValues() [][]byte

func (*BytesSliceResponse) Marshal 

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

func (*BytesSliceResponse) MarshalTo 

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

func (*BytesSliceResponse) MarshalToSizedBuffer 

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

func (*BytesSliceResponse) ProtoMessage 

func (*BytesSliceResponse) ProtoMessage()

func (*BytesSliceResponse) Reset 

func (m *BytesSliceResponse) Reset()

func (*BytesSliceResponse) Size 

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

func (*BytesSliceResponse) String 

func (m *BytesSliceResponse) String() string

func (*BytesSliceResponse) Unmarshal 

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

func (*BytesSliceResponse) XXX_DiscardUnknown 

func (m *BytesSliceResponse) XXX_DiscardUnknown()

func (*BytesSliceResponse) XXX_Marshal 

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

func (*BytesSliceResponse) XXX_Merge 

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

func (*BytesSliceResponse) XXX_Size 

func (m *BytesSliceResponse) XXX_Size() int

func (*BytesSliceResponse) XXX_Unmarshal 

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

type Cmp 

type Cmp int32

Cmp cmp operation 

const (
	Exists    Cmp = 0
	NotExists Cmp = 1
	Equal     Cmp = 2
	NotEqual  Cmp = 3
	GE        Cmp = 4
	GT        Cmp = 5
	LE        Cmp = 6
	LT        Cmp = 7
)

func (Cmp) EnumDescriptor 

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

func (Cmp) String 

func (x Cmp) String() string

type Condition 

type Condition struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Cmp   Cmp    `protobuf:"varint,2,opt,name=cmp,proto3,enum=rpcpb.Cmp" json:"cmp,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

Condition condition

func (*Condition) Descriptor 

func (*Condition) Descriptor() ([]byte, []int)

func (*Condition) GetCmp 

func (m *Condition) GetCmp() Cmp

func (*Condition) GetKey 

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

func (*Condition) GetValue 

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

func (*Condition) Marshal 

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

func (*Condition) MarshalTo 

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

func (*Condition) MarshalToSizedBuffer 

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

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) Reset 

func (m *Condition) Reset()

func (*Condition) Size 

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

func (*Condition) String 

func (m *Condition) String() string

func (*Condition) Unmarshal 

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

func (*Condition) XXX_DiscardUnknown 

func (m *Condition) XXX_DiscardUnknown()

func (*Condition) XXX_Marshal 

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

func (*Condition) XXX_Merge 

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

func (*Condition) XXX_Size 

func (m *Condition) XXX_Size() int

func (*Condition) XXX_Unmarshal 

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

type ConditionGroup 

type ConditionGroup struct {
	Conditions []Condition `protobuf:"bytes,1,rep,name=conditions,proto3" json:"conditions"`
}

ConditionGroup condition groups

func (*ConditionGroup) Descriptor 

func (*ConditionGroup) Descriptor() ([]byte, []int)

func (*ConditionGroup) GetConditions 

func (m *ConditionGroup) GetConditions() []Condition

func (*ConditionGroup) Marshal 

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

func (*ConditionGroup) MarshalTo 

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

func (*ConditionGroup) MarshalToSizedBuffer 

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

func (*ConditionGroup) ProtoMessage 

func (*ConditionGroup) ProtoMessage()

func (*ConditionGroup) Reset 

func (m *ConditionGroup) Reset()

func (*ConditionGroup) Size 

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

func (*ConditionGroup) String 

func (m *ConditionGroup) String() string

func (*ConditionGroup) Unmarshal 

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

func (*ConditionGroup) XXX_DiscardUnknown 

func (m *ConditionGroup) XXX_DiscardUnknown()

func (*ConditionGroup) XXX_Marshal 

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

func (*ConditionGroup) XXX_Merge 

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

func (*ConditionGroup) XXX_Size 

func (m *ConditionGroup) XXX_Size() int

func (*ConditionGroup) XXX_Unmarshal 

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

type CreateInstanceStateShardRequest 

type CreateInstanceStateShardRequest struct {
	State metapb.WorkflowInstanceWorkerState `protobuf:"bytes,1,opt,name=state,proto3" json:"state"`
}

CreateInstanceStateShardRequest create a instance state

func AcquireCreateInstanceStateShardRequest 

func AcquireCreateInstanceStateShardRequest() *CreateInstanceStateShardRequest

AcquireCreateInstanceStateShardRequest returns value from pool

func (*CreateInstanceStateShardRequest) Descriptor 

func (*CreateInstanceStateShardRequest) Descriptor() ([]byte, []int)

func (*CreateInstanceStateShardRequest) GetState 

func (m *CreateInstanceStateShardRequest) GetState() metapb.WorkflowInstanceWorkerState

func (*CreateInstanceStateShardRequest) Marshal 

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

func (*CreateInstanceStateShardRequest) MarshalTo 

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

func (*CreateInstanceStateShardRequest) MarshalToSizedBuffer 

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

func (*CreateInstanceStateShardRequest) ProtoMessage 

func (*CreateInstanceStateShardRequest) ProtoMessage()

func (*CreateInstanceStateShardRequest) Reset 

func (m *CreateInstanceStateShardRequest) Reset()

func (*CreateInstanceStateShardRequest) Size 

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

func (*CreateInstanceStateShardRequest) String 

func (m *CreateInstanceStateShardRequest) String() string

func (*CreateInstanceStateShardRequest) Unmarshal 

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

func (*CreateInstanceStateShardRequest) XXX_DiscardUnknown 

func (m *CreateInstanceStateShardRequest) XXX_DiscardUnknown()

func (*CreateInstanceStateShardRequest) XXX_Marshal 

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

func (*CreateInstanceStateShardRequest) XXX_Merge 

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

func (*CreateInstanceStateShardRequest) XXX_Size 

func (m *CreateInstanceStateShardRequest) XXX_Size() int

func (*CreateInstanceStateShardRequest) XXX_Unmarshal 

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

type DeleteIfRequest 

type DeleteIfRequest struct {
	Key        []byte           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Conditions []ConditionGroup `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions"`
}

DeleteIfRequest delete with condition

func AcquireDeleteIfRequest 

func AcquireDeleteIfRequest() *DeleteIfRequest

AcquireDeleteIfRequest returns value from pool

func (*DeleteIfRequest) Descriptor 

func (*DeleteIfRequest) Descriptor() ([]byte, []int)

func (*DeleteIfRequest) GetConditions 

func (m *DeleteIfRequest) GetConditions() []ConditionGroup

func (*DeleteIfRequest) GetKey 

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

func (*DeleteIfRequest) Marshal 

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

func (*DeleteIfRequest) MarshalTo 

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

func (*DeleteIfRequest) MarshalToSizedBuffer 

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

func (*DeleteIfRequest) ProtoMessage 

func (*DeleteIfRequest) ProtoMessage()

func (*DeleteIfRequest) Reset 

func (m *DeleteIfRequest) Reset()

func (*DeleteIfRequest) Size 

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

func (*DeleteIfRequest) String 

func (m *DeleteIfRequest) String() string

func (*DeleteIfRequest) Unmarshal 

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

func (*DeleteIfRequest) XXX_DiscardUnknown 

func (m *DeleteIfRequest) XXX_DiscardUnknown()

func (*DeleteIfRequest) XXX_Marshal 

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

func (*DeleteIfRequest) XXX_Merge 

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

func (*DeleteIfRequest) XXX_Size 

func (m *DeleteIfRequest) XXX_Size() int

func (*DeleteIfRequest) XXX_Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

DeleteRequest remove a key value pair

func AcquireDeleteRequest 

func AcquireDeleteRequest() *DeleteRequest

AcquireDeleteRequest returns value from pool

func (*DeleteRequest) Descriptor 

func (*DeleteRequest) Descriptor() ([]byte, []int)

func (*DeleteRequest) GetKey 

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

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) MarshalToSizedBuffer 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type EmptyResponse 

type EmptyResponse struct {
}

EmptyResponse empty response

func (*EmptyResponse) Descriptor 

func (*EmptyResponse) Descriptor() ([]byte, []int)

func (*EmptyResponse) Marshal 

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

func (*EmptyResponse) MarshalTo 

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

func (*EmptyResponse) MarshalToSizedBuffer 

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

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset 

func (m *EmptyResponse) Reset()

func (*EmptyResponse) Size 

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

func (*EmptyResponse) String 

func (m *EmptyResponse) String() string

func (*EmptyResponse) Unmarshal 

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

func (*EmptyResponse) XXX_DiscardUnknown 

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal 

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

func (*EmptyResponse) XXX_Merge 

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

func (*EmptyResponse) XXX_Size 

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal 

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

type ErrorResponse 

type ErrorResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

ErrorResponse error response

func (*ErrorResponse) Descriptor 

func (*ErrorResponse) Descriptor() ([]byte, []int)

func (*ErrorResponse) GetError 

func (m *ErrorResponse) GetError() string

func (*ErrorResponse) Marshal 

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

func (*ErrorResponse) MarshalTo 

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

func (*ErrorResponse) MarshalToSizedBuffer 

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

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) Reset 

func (m *ErrorResponse) Reset()

func (*ErrorResponse) Size 

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

func (*ErrorResponse) String 

func (m *ErrorResponse) String() string

func (*ErrorResponse) Unmarshal 

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

func (*ErrorResponse) XXX_DiscardUnknown 

func (m *ErrorResponse) XXX_DiscardUnknown()

func (*ErrorResponse) XXX_Marshal 

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

func (*ErrorResponse) XXX_Merge 

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

func (*ErrorResponse) XXX_Size 

func (m *ErrorResponse) XXX_Size() int

func (*ErrorResponse) XXX_Unmarshal 

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

type GetIDSetRequest 

type GetIDSetRequest struct {
	ID     uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserID uint32 `protobuf:"varint,2,opt,name=userID,proto3" json:"userID,omitempty"`
}

GetIDSet get id set

func (*GetIDSetRequest) Descriptor 

func (*GetIDSetRequest) Descriptor() ([]byte, []int)

func (*GetIDSetRequest) GetID 

func (m *GetIDSetRequest) GetID() uint64

func (*GetIDSetRequest) GetUserID 

func (m *GetIDSetRequest) GetUserID() uint32

func (*GetIDSetRequest) Marshal 

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

func (*GetIDSetRequest) MarshalTo 

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

func (*GetIDSetRequest) MarshalToSizedBuffer 

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

func (*GetIDSetRequest) ProtoMessage 

func (*GetIDSetRequest) ProtoMessage()

func (*GetIDSetRequest) Reset 

func (m *GetIDSetRequest) Reset()

func (*GetIDSetRequest) Size 

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

func (*GetIDSetRequest) String 

func (m *GetIDSetRequest) String() string

func (*GetIDSetRequest) Unmarshal 

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

func (*GetIDSetRequest) XXX_DiscardUnknown 

func (m *GetIDSetRequest) XXX_DiscardUnknown()

func (*GetIDSetRequest) XXX_Marshal 

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

func (*GetIDSetRequest) XXX_Merge 

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

func (*GetIDSetRequest) XXX_Size 

func (m *GetIDSetRequest) XXX_Size() int

func (*GetIDSetRequest) XXX_Unmarshal 

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

type GetMappingRequest 

type GetMappingRequest struct {
	ID   uint64         `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	From metapb.IDValue `protobuf:"bytes,2,opt,name=from,proto3" json:"from"`
	To   string         `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
}

GetMappingRequest get id mapping request

func (*GetMappingRequest) Descriptor 

func (*GetMappingRequest) Descriptor() ([]byte, []int)

func (*GetMappingRequest) GetFrom 

func (m *GetMappingRequest) GetFrom() metapb.IDValue

func (*GetMappingRequest) GetID 

func (m *GetMappingRequest) GetID() uint64

func (*GetMappingRequest) GetTo 

func (m *GetMappingRequest) GetTo() string

func (*GetMappingRequest) Marshal 

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

func (*GetMappingRequest) MarshalTo 

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

func (*GetMappingRequest) MarshalToSizedBuffer 

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

func (*GetMappingRequest) ProtoMessage 

func (*GetMappingRequest) ProtoMessage()

func (*GetMappingRequest) Reset 

func (m *GetMappingRequest) Reset()

func (*GetMappingRequest) Size 

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

func (*GetMappingRequest) String 

func (m *GetMappingRequest) String() string

func (*GetMappingRequest) Unmarshal 

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

func (*GetMappingRequest) XXX_DiscardUnknown 

func (m *GetMappingRequest) XXX_DiscardUnknown()

func (*GetMappingRequest) XXX_Marshal 

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

func (*GetMappingRequest) XXX_Merge 

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

func (*GetMappingRequest) XXX_Size 

func (m *GetMappingRequest) XXX_Size() int

func (*GetMappingRequest) XXX_Unmarshal 

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

type GetProfileRequest 

type GetProfileRequest struct {
	ID     uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserID uint32 `protobuf:"varint,2,opt,name=userID,proto3" json:"userID,omitempty"`
	Field  string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
}

GetProfileRequest get profile request

func (*GetProfileRequest) Descriptor 

func (*GetProfileRequest) Descriptor() ([]byte, []int)

func (*GetProfileRequest) GetField 

func (m *GetProfileRequest) GetField() string

func (*GetProfileRequest) GetID 

func (m *GetProfileRequest) GetID() uint64

func (*GetProfileRequest) GetUserID 

func (m *GetProfileRequest) GetUserID() uint32

func (*GetProfileRequest) Marshal 

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

func (*GetProfileRequest) MarshalTo 

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

func (*GetProfileRequest) MarshalToSizedBuffer 

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

func (*GetProfileRequest) ProtoMessage 

func (*GetProfileRequest) ProtoMessage()

func (*GetProfileRequest) Reset 

func (m *GetProfileRequest) Reset()

func (*GetProfileRequest) Size 

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

func (*GetProfileRequest) String 

func (m *GetProfileRequest) String() string

func (*GetProfileRequest) Unmarshal 

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

func (*GetProfileRequest) XXX_DiscardUnknown 

func (m *GetProfileRequest) XXX_DiscardUnknown()

func (*GetProfileRequest) XXX_Marshal 

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

func (*GetProfileRequest) XXX_Merge 

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

func (*GetProfileRequest) XXX_Size 

func (m *GetProfileRequest) XXX_Size() int

func (*GetProfileRequest) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

GetRequest get value by key

func AcquireGetRequest 

func AcquireGetRequest() *GetRequest

AcquireGetRequest returns value from pool

func (*GetRequest) Descriptor 

func (*GetRequest) Descriptor() ([]byte, []int)

func (*GetRequest) GetKey 

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

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type HistoryInstanceRequest 

type HistoryInstanceRequest 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"`
}

HistoryInstanceRequest history instance request

func (*HistoryInstanceRequest) Descriptor 

func (*HistoryInstanceRequest) Descriptor() ([]byte, []int)

func (*HistoryInstanceRequest) GetInstanceID 

func (m *HistoryInstanceRequest) GetInstanceID() uint64

func (*HistoryInstanceRequest) GetWorkflowID 

func (m *HistoryInstanceRequest) GetWorkflowID() uint64

func (*HistoryInstanceRequest) Marshal 

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

func (*HistoryInstanceRequest) MarshalTo 

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

func (*HistoryInstanceRequest) MarshalToSizedBuffer 

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

func (*HistoryInstanceRequest) ProtoMessage 

func (*HistoryInstanceRequest) ProtoMessage()

func (*HistoryInstanceRequest) Reset 

func (m *HistoryInstanceRequest) Reset()

func (*HistoryInstanceRequest) Size 

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

func (*HistoryInstanceRequest) String 

func (m *HistoryInstanceRequest) String() string

func (*HistoryInstanceRequest) Unmarshal 

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

func (*HistoryInstanceRequest) XXX_DiscardUnknown 

func (m *HistoryInstanceRequest) XXX_DiscardUnknown()

func (*HistoryInstanceRequest) XXX_Marshal 

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

func (*HistoryInstanceRequest) XXX_Merge 

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

func (*HistoryInstanceRequest) XXX_Size 

func (m *HistoryInstanceRequest) XXX_Size() int

func (*HistoryInstanceRequest) XXX_Unmarshal 

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

type InstanceCountStateRequest 

type InstanceCountStateRequest struct {
	WorkflowID uint64 `protobuf:"varint,1,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
}

InstanceCountStateRequest instance count state

func (*InstanceCountStateRequest) Descriptor 

func (*InstanceCountStateRequest) Descriptor() ([]byte, []int)

func (*InstanceCountStateRequest) GetWorkflowID 

func (m *InstanceCountStateRequest) GetWorkflowID() uint64

func (*InstanceCountStateRequest) Marshal 

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

func (*InstanceCountStateRequest) MarshalTo 

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

func (*InstanceCountStateRequest) MarshalToSizedBuffer 

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

func (*InstanceCountStateRequest) ProtoMessage 

func (*InstanceCountStateRequest) ProtoMessage()

func (*InstanceCountStateRequest) Reset 

func (m *InstanceCountStateRequest) Reset()

func (*InstanceCountStateRequest) Size 

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

func (*InstanceCountStateRequest) String 

func (m *InstanceCountStateRequest) String() string

func (*InstanceCountStateRequest) Unmarshal 

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

func (*InstanceCountStateRequest) XXX_DiscardUnknown 

func (m *InstanceCountStateRequest) XXX_DiscardUnknown()

func (*InstanceCountStateRequest) XXX_Marshal 

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

func (*InstanceCountStateRequest) XXX_Merge 

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

func (*InstanceCountStateRequest) XXX_Size 

func (m *InstanceCountStateRequest) XXX_Size() int

func (*InstanceCountStateRequest) XXX_Unmarshal 

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

type InstanceCrowdStateRequest 

type InstanceCrowdStateRequest struct {
	WorkflowID uint64 `protobuf:"varint,1,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

InstanceCrowdStateRequest instance crowd state

func (*InstanceCrowdStateRequest) Descriptor 

func (*InstanceCrowdStateRequest) Descriptor() ([]byte, []int)

func (*InstanceCrowdStateRequest) GetName 

func (m *InstanceCrowdStateRequest) GetName() string

func (*InstanceCrowdStateRequest) GetWorkflowID 

func (m *InstanceCrowdStateRequest) GetWorkflowID() uint64

func (*InstanceCrowdStateRequest) Marshal 

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

func (*InstanceCrowdStateRequest) MarshalTo 

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

func (*InstanceCrowdStateRequest) MarshalToSizedBuffer 

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

func (*InstanceCrowdStateRequest) ProtoMessage 

func (*InstanceCrowdStateRequest) ProtoMessage()

func (*InstanceCrowdStateRequest) Reset 

func (m *InstanceCrowdStateRequest) Reset()

func (*InstanceCrowdStateRequest) Size 

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

func (*InstanceCrowdStateRequest) String 

func (m *InstanceCrowdStateRequest) String() string

func (*InstanceCrowdStateRequest) Unmarshal 

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

func (*InstanceCrowdStateRequest) XXX_DiscardUnknown 

func (m *InstanceCrowdStateRequest) XXX_DiscardUnknown()

func (*InstanceCrowdStateRequest) XXX_Marshal 

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

func (*InstanceCrowdStateRequest) XXX_Merge 

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

func (*InstanceCrowdStateRequest) XXX_Size 

func (m *InstanceCrowdStateRequest) XXX_Size() int

func (*InstanceCrowdStateRequest) XXX_Unmarshal 

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

type LastInstanceRequest 

type LastInstanceRequest struct {
	WorkflowID uint64 `protobuf:"varint,1,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
}

LastInstanceRequest last instance request

func (*LastInstanceRequest) Descriptor 

func (*LastInstanceRequest) Descriptor() ([]byte, []int)

func (*LastInstanceRequest) GetWorkflowID 

func (m *LastInstanceRequest) GetWorkflowID() uint64

func (*LastInstanceRequest) Marshal 

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

func (*LastInstanceRequest) MarshalTo 

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

func (*LastInstanceRequest) MarshalToSizedBuffer 

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

func (*LastInstanceRequest) ProtoMessage 

func (*LastInstanceRequest) ProtoMessage()

func (*LastInstanceRequest) Reset 

func (m *LastInstanceRequest) Reset()

func (*LastInstanceRequest) Size 

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

func (*LastInstanceRequest) String 

func (m *LastInstanceRequest) String() string

func (*LastInstanceRequest) Unmarshal 

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

func (*LastInstanceRequest) XXX_DiscardUnknown 

func (m *LastInstanceRequest) XXX_DiscardUnknown()

func (*LastInstanceRequest) XXX_Marshal 

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

func (*LastInstanceRequest) XXX_Merge 

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

func (*LastInstanceRequest) XXX_Size 

func (m *LastInstanceRequest) XXX_Size() int

func (*LastInstanceRequest) XXX_Unmarshal 

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

type LockRequest 

type LockRequest 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"`
	ExpireAt int64  `protobuf:"varint,3,opt,name=expireAt,proto3" json:"expireAt,omitempty"`
}

LockRequest lock

func AcquireLockRequest 

func AcquireLockRequest() *LockRequest

AcquireLockRequest returns value from pool

func (*LockRequest) Descriptor 

func (*LockRequest) Descriptor() ([]byte, []int)

func (*LockRequest) GetExpireAt 

func (m *LockRequest) GetExpireAt() int64

func (*LockRequest) GetKey 

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

func (*LockRequest) GetValue 

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

func (*LockRequest) Marshal 

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

func (*LockRequest) MarshalTo 

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

func (*LockRequest) MarshalToSizedBuffer 

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

func (*LockRequest) ProtoMessage 

func (*LockRequest) ProtoMessage()

func (*LockRequest) Reset 

func (m *LockRequest) Reset()

func (*LockRequest) Size 

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

func (*LockRequest) String 

func (m *LockRequest) String() string

func (*LockRequest) Unmarshal 

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

func (*LockRequest) XXX_DiscardUnknown 

func (m *LockRequest) XXX_DiscardUnknown()

func (*LockRequest) XXX_Marshal 

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

func (*LockRequest) XXX_Merge 

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

func (*LockRequest) XXX_Size 

func (m *LockRequest) XXX_Size() int

func (*LockRequest) XXX_Unmarshal 

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

type QueueAddRequest 

type QueueAddRequest struct {
	Key            []byte     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Items          [][]byte   `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	KVS            [][]byte   `protobuf:"bytes,3,rep,name=kvs,proto3" json:"kvs,omitempty"`
	Condition      *Condition `protobuf:"bytes,4,opt,name=condition,proto3" json:"condition,omitempty"`
	AllocPartition bool       `protobuf:"varint,5,opt,name=allocPartition,proto3" json:"allocPartition,omitempty"`
}

QueueAddRequest add items into a queue

func AcquireQueueAddRequest 

func AcquireQueueAddRequest() *QueueAddRequest

AcquireQueueAddRequest returns value from pool

func (*QueueAddRequest) Descriptor 

func (*QueueAddRequest) Descriptor() ([]byte, []int)

func (*QueueAddRequest) GetAllocPartition 

func (m *QueueAddRequest) GetAllocPartition() bool

func (*QueueAddRequest) GetCondition 

func (m *QueueAddRequest) GetCondition() *Condition

func (*QueueAddRequest) GetItems 

func (m *QueueAddRequest) GetItems() [][]byte

func (*QueueAddRequest) GetKVS 

func (m *QueueAddRequest) GetKVS() [][]byte

func (*QueueAddRequest) GetKey 

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

func (*QueueAddRequest) Marshal 

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

func (*QueueAddRequest) MarshalTo 

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

func (*QueueAddRequest) MarshalToSizedBuffer 

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

func (*QueueAddRequest) ProtoMessage 

func (*QueueAddRequest) ProtoMessage()

func (*QueueAddRequest) Reset 

func (m *QueueAddRequest) Reset()

func (*QueueAddRequest) Size 

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

func (*QueueAddRequest) String 

func (m *QueueAddRequest) String() string

func (*QueueAddRequest) Unmarshal 

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

func (*QueueAddRequest) XXX_DiscardUnknown 

func (m *QueueAddRequest) XXX_DiscardUnknown()

func (*QueueAddRequest) XXX_Marshal 

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

func (*QueueAddRequest) XXX_Merge 

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

func (*QueueAddRequest) XXX_Size 

func (m *QueueAddRequest) XXX_Size() int

func (*QueueAddRequest) XXX_Unmarshal 

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

type QueueCommitRequest 

type QueueCommitRequest struct {
	ID              uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Key             []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Partition       uint32 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	Consumer        []byte `protobuf:"bytes,4,opt,name=consumer,proto3" json:"consumer,omitempty"`
	CompletedOffset uint64 `protobuf:"varint,5,opt,name=completedOffset,proto3" json:"completedOffset,omitempty"`
}

QueueCommitRequest queue commit completed offset

func AcquireQueueCommitRequest 

func AcquireQueueCommitRequest() *QueueCommitRequest

AcquireQueueCommitRequest returns value from pool

func (*QueueCommitRequest) Descriptor 

func (*QueueCommitRequest) Descriptor() ([]byte, []int)

func (*QueueCommitRequest) GetCompletedOffset 

func (m *QueueCommitRequest) GetCompletedOffset() uint64

func (*QueueCommitRequest) GetConsumer 

func (m *QueueCommitRequest) GetConsumer() []byte

func (*QueueCommitRequest) GetID 

func (m *QueueCommitRequest) GetID() uint64

func (*QueueCommitRequest) GetKey 

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

func (*QueueCommitRequest) GetPartition 

func (m *QueueCommitRequest) GetPartition() uint32

func (*QueueCommitRequest) Marshal 

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

func (*QueueCommitRequest) MarshalTo 

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

func (*QueueCommitRequest) MarshalToSizedBuffer 

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

func (*QueueCommitRequest) ProtoMessage 

func (*QueueCommitRequest) ProtoMessage()

func (*QueueCommitRequest) Reset 

func (m *QueueCommitRequest) Reset()

func (*QueueCommitRequest) Size 

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

func (*QueueCommitRequest) String 

func (m *QueueCommitRequest) String() string

func (*QueueCommitRequest) Unmarshal 

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

func (*QueueCommitRequest) XXX_DiscardUnknown 

func (m *QueueCommitRequest) XXX_DiscardUnknown()

func (*QueueCommitRequest) XXX_Marshal 

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

func (*QueueCommitRequest) XXX_Merge 

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

func (*QueueCommitRequest) XXX_Size 

func (m *QueueCommitRequest) XXX_Size() int

func (*QueueCommitRequest) XXX_Unmarshal 

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

type QueueDeleteRequest 

type QueueDeleteRequest struct {
	Key       []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ID        uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Partition uint32 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	From      uint64 `protobuf:"varint,4,opt,name=from,proto3" json:"from,omitempty"`
	To        uint64 `protobuf:"varint,5,opt,name=to,proto3" json:"to,omitempty"`
}

QueueDeleteRequest queue delete range

func AcquireQueueDeleteRequest 

func AcquireQueueDeleteRequest() *QueueDeleteRequest

AcquireQueueDeleteRequest returns value from pool

func (*QueueDeleteRequest) Descriptor 

func (*QueueDeleteRequest) Descriptor() ([]byte, []int)

func (*QueueDeleteRequest) GetFrom 

func (m *QueueDeleteRequest) GetFrom() uint64

func (*QueueDeleteRequest) GetID 

func (m *QueueDeleteRequest) GetID() uint64

func (*QueueDeleteRequest) GetKey 

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

func (*QueueDeleteRequest) GetPartition 

func (m *QueueDeleteRequest) GetPartition() uint32

func (*QueueDeleteRequest) GetTo 

func (m *QueueDeleteRequest) GetTo() uint64

func (*QueueDeleteRequest) Marshal 

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

func (*QueueDeleteRequest) MarshalTo 

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

func (*QueueDeleteRequest) MarshalToSizedBuffer 

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

func (*QueueDeleteRequest) ProtoMessage 

func (*QueueDeleteRequest) ProtoMessage()

func (*QueueDeleteRequest) Reset 

func (m *QueueDeleteRequest) Reset()

func (*QueueDeleteRequest) Size 

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

func (*QueueDeleteRequest) String 

func (m *QueueDeleteRequest) String() string

func (*QueueDeleteRequest) Unmarshal 

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

func (*QueueDeleteRequest) XXX_DiscardUnknown 

func (m *QueueDeleteRequest) XXX_DiscardUnknown()

func (*QueueDeleteRequest) XXX_Marshal 

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

func (*QueueDeleteRequest) XXX_Merge 

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

func (*QueueDeleteRequest) XXX_Size 

func (m *QueueDeleteRequest) XXX_Size() int

func (*QueueDeleteRequest) XXX_Unmarshal 

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

type QueueFetchRequest 

type QueueFetchRequest struct {
	ID              uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Key             []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Group           []byte `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Partition       uint32 `protobuf:"varint,4,opt,name=partition,proto3" json:"partition,omitempty"`
	Consumer        uint32 `protobuf:"varint,5,opt,name=consumer,proto3" json:"consumer,omitempty"`
	Version         uint64 `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	CompletedOffset uint64 `protobuf:"varint,7,opt,name=completedOffset,proto3" json:"completedOffset,omitempty"`
	Count           uint64 `protobuf:"varint,8,opt,name=count,proto3" json:"count,omitempty"`
	MaxBytes        uint64 `protobuf:"varint,9,opt,name=maxBytes,proto3" json:"maxBytes,omitempty"`
}

QueueFetchRequest concurrency fetch items from a queue

func AcquireQueueFetchRequest 

func AcquireQueueFetchRequest() *QueueFetchRequest

AcquireQueueFetchRequest returns value from pool

func (*QueueFetchRequest) Descriptor 

func (*QueueFetchRequest) Descriptor() ([]byte, []int)

func (*QueueFetchRequest) GetCompletedOffset 

func (m *QueueFetchRequest) GetCompletedOffset() uint64

func (*QueueFetchRequest) GetConsumer 

func (m *QueueFetchRequest) GetConsumer() uint32

func (*QueueFetchRequest) GetCount 

func (m *QueueFetchRequest) GetCount() uint64

func (*QueueFetchRequest) GetGroup 

func (m *QueueFetchRequest) GetGroup() []byte

func (*QueueFetchRequest) GetID 

func (m *QueueFetchRequest) GetID() uint64

func (*QueueFetchRequest) GetKey 

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

func (*QueueFetchRequest) GetMaxBytes 

func (m *QueueFetchRequest) GetMaxBytes() uint64

func (*QueueFetchRequest) GetPartition 

func (m *QueueFetchRequest) GetPartition() uint32

func (*QueueFetchRequest) GetVersion 

func (m *QueueFetchRequest) GetVersion() uint64

func (*QueueFetchRequest) Marshal 

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

func (*QueueFetchRequest) MarshalTo 

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

func (*QueueFetchRequest) MarshalToSizedBuffer 

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

func (*QueueFetchRequest) ProtoMessage 

func (*QueueFetchRequest) ProtoMessage()

func (*QueueFetchRequest) Reset 

func (m *QueueFetchRequest) Reset()

func (*QueueFetchRequest) Size 

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

func (*QueueFetchRequest) String 

func (m *QueueFetchRequest) String() string

func (*QueueFetchRequest) Unmarshal 

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

func (*QueueFetchRequest) XXX_DiscardUnknown 

func (m *QueueFetchRequest) XXX_DiscardUnknown()

func (*QueueFetchRequest) XXX_Marshal 

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

func (*QueueFetchRequest) XXX_Merge 

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

func (*QueueFetchRequest) XXX_Size 

func (m *QueueFetchRequest) XXX_Size() int

func (*QueueFetchRequest) XXX_Unmarshal 

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

type QueueFetchResponse 

type QueueFetchResponse struct {
	Removed    bool     `protobuf:"varint,1,opt,name=removed,proto3" json:"removed,omitempty"`
	Items      [][]byte `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	LastOffset uint64   `protobuf:"varint,3,opt,name=lastOffset,proto3" json:"lastOffset,omitempty"`
}

QueueFetchResponse fetch response

func (*QueueFetchResponse) Descriptor 

func (*QueueFetchResponse) Descriptor() ([]byte, []int)

func (*QueueFetchResponse) GetItems 

func (m *QueueFetchResponse) GetItems() [][]byte

func (*QueueFetchResponse) GetLastOffset 

func (m *QueueFetchResponse) GetLastOffset() uint64

func (*QueueFetchResponse) GetRemoved 

func (m *QueueFetchResponse) GetRemoved() bool

func (*QueueFetchResponse) Marshal 

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

func (*QueueFetchResponse) MarshalTo 

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

func (*QueueFetchResponse) MarshalToSizedBuffer 

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

func (*QueueFetchResponse) ProtoMessage 

func (*QueueFetchResponse) ProtoMessage()

func (*QueueFetchResponse) Reset 

func (m *QueueFetchResponse) Reset()

func (*QueueFetchResponse) Size 

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

func (*QueueFetchResponse) String 

func (m *QueueFetchResponse) String() string

func (*QueueFetchResponse) Unmarshal 

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

func (*QueueFetchResponse) XXX_DiscardUnknown 

func (m *QueueFetchResponse) XXX_DiscardUnknown()

func (*QueueFetchResponse) XXX_Marshal 

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

func (*QueueFetchResponse) XXX_Merge 

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

func (*QueueFetchResponse) XXX_Size 

func (m *QueueFetchResponse) XXX_Size() int

func (*QueueFetchResponse) XXX_Unmarshal 

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

type QueueJoinGroupRequest 

type QueueJoinGroupRequest struct {
	ID    uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Key   []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Group []byte `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
}

QueueJoinGroupRequest join a group

func AcquireQueueJoinGroupRequest 

func AcquireQueueJoinGroupRequest() *QueueJoinGroupRequest

AcquireQueueJoinGroupRequest returns value from pool

func (*QueueJoinGroupRequest) Descriptor 

func (*QueueJoinGroupRequest) Descriptor() ([]byte, []int)

func (*QueueJoinGroupRequest) GetGroup 

func (m *QueueJoinGroupRequest) GetGroup() []byte

func (*QueueJoinGroupRequest) GetID 

func (m *QueueJoinGroupRequest) GetID() uint64

func (*QueueJoinGroupRequest) GetKey 

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

func (*QueueJoinGroupRequest) Marshal 

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

func (*QueueJoinGroupRequest) MarshalTo 

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

func (*QueueJoinGroupRequest) MarshalToSizedBuffer 

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

func (*QueueJoinGroupRequest) ProtoMessage 

func (*QueueJoinGroupRequest) ProtoMessage()

func (*QueueJoinGroupRequest) Reset 

func (m *QueueJoinGroupRequest) Reset()

func (*QueueJoinGroupRequest) Size 

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

func (*QueueJoinGroupRequest) String 

func (m *QueueJoinGroupRequest) String() string

func (*QueueJoinGroupRequest) Unmarshal 

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

func (*QueueJoinGroupRequest) XXX_DiscardUnknown 

func (m *QueueJoinGroupRequest) XXX_DiscardUnknown()

func (*QueueJoinGroupRequest) XXX_Marshal 

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

func (*QueueJoinGroupRequest) XXX_Merge 

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

func (*QueueJoinGroupRequest) XXX_Size 

func (m *QueueJoinGroupRequest) XXX_Size() int

func (*QueueJoinGroupRequest) XXX_Unmarshal 

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

type QueueJoinGroupResponse 

type QueueJoinGroupResponse struct {
	Index      uint32   `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Partitions []uint32 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"`
	Versions   []uint64 `protobuf:"varint,3,rep,packed,name=versions,proto3" json:"versions,omitempty"`
}

QueueJoinGroupResponse queue join group response

func (*QueueJoinGroupResponse) Descriptor 

func (*QueueJoinGroupResponse) Descriptor() ([]byte, []int)

func (*QueueJoinGroupResponse) GetIndex 

func (m *QueueJoinGroupResponse) GetIndex() uint32

func (*QueueJoinGroupResponse) GetPartitions 

func (m *QueueJoinGroupResponse) GetPartitions() []uint32

func (*QueueJoinGroupResponse) GetVersions 

func (m *QueueJoinGroupResponse) GetVersions() []uint64

func (*QueueJoinGroupResponse) Marshal 

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

func (*QueueJoinGroupResponse) MarshalTo 

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

func (*QueueJoinGroupResponse) MarshalToSizedBuffer 

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

func (*QueueJoinGroupResponse) ProtoMessage 

func (*QueueJoinGroupResponse) ProtoMessage()

func (*QueueJoinGroupResponse) Reset 

func (m *QueueJoinGroupResponse) Reset()

func (*QueueJoinGroupResponse) Size 

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

func (*QueueJoinGroupResponse) String 

func (m *QueueJoinGroupResponse) String() string

func (*QueueJoinGroupResponse) Unmarshal 

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

func (*QueueJoinGroupResponse) XXX_DiscardUnknown 

func (m *QueueJoinGroupResponse) XXX_DiscardUnknown()

func (*QueueJoinGroupResponse) XXX_Marshal 

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

func (*QueueJoinGroupResponse) XXX_Merge 

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

func (*QueueJoinGroupResponse) XXX_Size 

func (m *QueueJoinGroupResponse) XXX_Size() int

func (*QueueJoinGroupResponse) XXX_Unmarshal 

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

type QueueScanRequest 

type QueueScanRequest struct {
	ID              uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Key             []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Partition       uint32 `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	Consumer        []byte `protobuf:"bytes,4,opt,name=consumer,proto3" json:"consumer,omitempty"`
	CompletedOffset uint64 `protobuf:"varint,5,opt,name=completedOffset,proto3" json:"completedOffset,omitempty"`
	Count           uint64 `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	MaxBytes        uint64 `protobuf:"varint,7,opt,name=maxBytes,proto3" json:"maxBytes,omitempty"`
}

QueueScanRequest queue scan request

func AcquireQueueScanRequest 

func AcquireQueueScanRequest() *QueueScanRequest

AcquireQueueScanRequest returns value from pool

func (*QueueScanRequest) Descriptor 

func (*QueueScanRequest) Descriptor() ([]byte, []int)

func (*QueueScanRequest) GetCompletedOffset 

func (m *QueueScanRequest) GetCompletedOffset() uint64

func (*QueueScanRequest) GetConsumer 

func (m *QueueScanRequest) GetConsumer() []byte

func (*QueueScanRequest) GetCount 

func (m *QueueScanRequest) GetCount() uint64

func (*QueueScanRequest) GetID 

func (m *QueueScanRequest) GetID() uint64

func (*QueueScanRequest) GetKey 

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

func (*QueueScanRequest) GetMaxBytes 

func (m *QueueScanRequest) GetMaxBytes() uint64

func (*QueueScanRequest) GetPartition 

func (m *QueueScanRequest) GetPartition() uint32

func (*QueueScanRequest) Marshal 

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

func (*QueueScanRequest) MarshalTo 

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

func (*QueueScanRequest) MarshalToSizedBuffer 

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

func (*QueueScanRequest) ProtoMessage 

func (*QueueScanRequest) ProtoMessage()

func (*QueueScanRequest) Reset 

func (m *QueueScanRequest) Reset()

func (*QueueScanRequest) Size 

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

func (*QueueScanRequest) String 

func (m *QueueScanRequest) String() string

func (*QueueScanRequest) Unmarshal 

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

func (*QueueScanRequest) XXX_DiscardUnknown 

func (m *QueueScanRequest) XXX_DiscardUnknown()

func (*QueueScanRequest) XXX_Marshal 

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

func (*QueueScanRequest) XXX_Merge 

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

func (*QueueScanRequest) XXX_Size 

func (m *QueueScanRequest) XXX_Size() int

func (*QueueScanRequest) XXX_Unmarshal 

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

type RemoveInstanceStateShardRequest 

type RemoveInstanceStateShardRequest 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"`
	Runner     uint64 `protobuf:"varint,5,opt,name=runner,proto3" json:"runner,omitempty"`
}

RemoveInstanceStateShardRequest remove a instance state

func AcquireRemoveInstanceStateShardRequest 

func AcquireRemoveInstanceStateShardRequest() *RemoveInstanceStateShardRequest

AcquireRemoveInstanceStateShardRequest returns value from pool

func (*RemoveInstanceStateShardRequest) Descriptor 

func (*RemoveInstanceStateShardRequest) Descriptor() ([]byte, []int)

func (*RemoveInstanceStateShardRequest) GetIndex 

func (m *RemoveInstanceStateShardRequest) GetIndex() uint32

func (*RemoveInstanceStateShardRequest) GetInstanceID 

func (m *RemoveInstanceStateShardRequest) GetInstanceID() uint64

func (*RemoveInstanceStateShardRequest) GetRunner 

func (m *RemoveInstanceStateShardRequest) GetRunner() uint64

func (*RemoveInstanceStateShardRequest) GetTenantID 

func (m *RemoveInstanceStateShardRequest) GetTenantID() uint64

func (*RemoveInstanceStateShardRequest) GetWorkflowID 

func (m *RemoveInstanceStateShardRequest) GetWorkflowID() uint64

func (*RemoveInstanceStateShardRequest) Marshal 

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

func (*RemoveInstanceStateShardRequest) MarshalTo 

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

func (*RemoveInstanceStateShardRequest) MarshalToSizedBuffer 

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

func (*RemoveInstanceStateShardRequest) ProtoMessage 

func (*RemoveInstanceStateShardRequest) ProtoMessage()

func (*RemoveInstanceStateShardRequest) Reset 

func (m *RemoveInstanceStateShardRequest) Reset()

func (*RemoveInstanceStateShardRequest) Size 

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

func (*RemoveInstanceStateShardRequest) String 

func (m *RemoveInstanceStateShardRequest) String() string

func (*RemoveInstanceStateShardRequest) Unmarshal 

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

func (*RemoveInstanceStateShardRequest) XXX_DiscardUnknown 

func (m *RemoveInstanceStateShardRequest) XXX_DiscardUnknown()

func (*RemoveInstanceStateShardRequest) XXX_Marshal 

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

func (*RemoveInstanceStateShardRequest) XXX_Merge 

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

func (*RemoveInstanceStateShardRequest) XXX_Size 

func (m *RemoveInstanceStateShardRequest) XXX_Size() int

func (*RemoveInstanceStateShardRequest) XXX_Unmarshal 

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

type Request 

type Request struct {
	ID              uint64                    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type            Type                      `protobuf:"varint,2,opt,name=type,proto3,enum=rpcpb.Type" json:"type,omitempty"`
	Set             SetRequest                `protobuf:"bytes,3,opt,name=set,proto3" json:"set"`
	Get             GetRequest                `protobuf:"bytes,4,opt,name=get,proto3" json:"get"`
	Delete          DeleteRequest             `protobuf:"bytes,5,opt,name=delete,proto3" json:"delete"`
	Scan            ScanRequest               `protobuf:"bytes,6,opt,name=scan,proto3" json:"scan"`
	BmCreate        BMCreateRequest           `protobuf:"bytes,7,opt,name=bmCreate,proto3" json:"bmCreate"`
	BmAdd           BMAddRequest              `protobuf:"bytes,8,opt,name=bmAdd,proto3" json:"bmAdd"`
	BmRemove        BMRemoveRequest           `protobuf:"bytes,9,opt,name=bmRemove,proto3" json:"bmRemove"`
	BmClear         BMClearRequest            `protobuf:"bytes,10,opt,name=bmClear,proto3" json:"bmClear"`
	BmRange         BMRangeRequest            `protobuf:"bytes,11,opt,name=bmRange,proto3" json:"bmRange"`
	BmCount         BMCountRequest            `protobuf:"bytes,12,opt,name=bmCount,proto3" json:"bmCount"`
	BmContains      BMContainsRequest         `protobuf:"bytes,13,opt,name=bmContains,proto3" json:"bmContains"`
	TenantInit      TenantInitRequest         `protobuf:"bytes,14,opt,name=tenantInit,proto3" json:"tenantInit"`
	StartInstance   StartingInstanceRequest   `protobuf:"bytes,15,opt,name=startInstance,proto3" json:"startInstance"`
	LastInstance    LastInstanceRequest       `protobuf:"bytes,16,opt,name=lastInstance,proto3" json:"lastInstance"`
	HistoryInstance HistoryInstanceRequest    `protobuf:"bytes,17,opt,name=historyInstance,proto3" json:"historyInstance"`
	UpdateCrowd     UpdateCrowdRequest        `protobuf:"bytes,18,opt,name=updateCrowd,proto3" json:"updateCrowd"`
	UpdateWorkflow  UpdateWorkflowRequest     `protobuf:"bytes,19,opt,name=updateWorkflow,proto3" json:"updateWorkflow"`
	StopInstance    StopInstanceRequest       `protobuf:"bytes,20,opt,name=stopInstance,proto3" json:"stopInstance"`
	CountInstance   InstanceCountStateRequest `protobuf:"bytes,21,opt,name=countInstance,proto3" json:"countInstance"`
	CrowdInstance   InstanceCrowdStateRequest `protobuf:"bytes,22,opt,name=crowdInstance,proto3" json:"crowdInstance"`
	UpdateMapping   UpdateMappingRequest      `protobuf:"bytes,23,opt,name=updateMapping,proto3" json:"updateMapping"`
	GetMapping      GetMappingRequest         `protobuf:"bytes,24,opt,name=getMapping,proto3" json:"getMapping"`
	UpdateProfile   UpdateProfileRequest      `protobuf:"bytes,25,opt,name=updateProfile,proto3" json:"updateProfile"`
	GetProfile      GetProfileRequest         `protobuf:"bytes,26,opt,name=getProfile,proto3" json:"getProfile"`
	AddEvent        AddEventRequest           `protobuf:"bytes,27,opt,name=addEvent,proto3" json:"addEvent"`
	QueueJoin       QueueJoinGroupRequest     `protobuf:"bytes,28,opt,name=queueJoin,proto3" json:"queueJoin"`
	QueueFetch      QueueFetchRequest         `protobuf:"bytes,29,opt,name=queueFetch,proto3" json:"queueFetch"`
	AllocID         AllocIDRequest            `protobuf:"bytes,30,opt,name=allocID,proto3" json:"allocID"`
	ResetID         ResetIDRequest            `protobuf:"bytes,31,opt,name=resetID,proto3" json:"resetID"`
	ScanMapping     ScanMappingRequest        `protobuf:"bytes,32,opt,name=scanMapping,proto3" json:"scanMapping"`
	GetIDSet        GetIDSetRequest           `protobuf:"bytes,33,opt,name=getIDSet,proto3" json:"getIDSet"`
	SetIf           SetIfRequest              `protobuf:"bytes,34,opt,name=setIf,proto3" json:"setIf"`
	DeleteIf        DeleteIfRequest           `protobuf:"bytes,35,opt,name=deleteIf,proto3" json:"deleteIf"`
	QueueScan       QueueScanRequest          `protobuf:"bytes,36,opt,name=queueScan,proto3" json:"queueScan"`
	QueueCommit     QueueCommitRequest        `protobuf:"bytes,37,opt,name=queueCommit,proto3" json:"queueCommit"`
	QueueDelete     QueueDeleteRequest        `protobuf:"bytes,38,opt,name=queueDelete,proto3" json:"queueDelete"`
	Lock            LockRequest               `protobuf:"bytes,39,opt,name=lock,proto3" json:"lock"`
	Unlock          UnlockRequest             `protobuf:"bytes,40,opt,name=unlock,proto3" json:"unlock"`
}

Request the busybee request

func AcquireRequest 

func AcquireRequest() *Request

AcquireRequest returns value from pool

func (*Request) Descriptor 

func (*Request) Descriptor() ([]byte, []int)

func (*Request) GetAddEvent 

func (m *Request) GetAddEvent() AddEventRequest

func (*Request) GetAllocID 

func (m *Request) GetAllocID() AllocIDRequest

func (*Request) GetBmAdd 

func (m *Request) GetBmAdd() BMAddRequest

func (*Request) GetBmClear 

func (m *Request) GetBmClear() BMClearRequest

func (*Request) GetBmContains 

func (m *Request) GetBmContains() BMContainsRequest

func (*Request) GetBmCount 

func (m *Request) GetBmCount() BMCountRequest

func (*Request) GetBmCreate 

func (m *Request) GetBmCreate() BMCreateRequest

func (*Request) GetBmRange 

func (m *Request) GetBmRange() BMRangeRequest

func (*Request) GetBmRemove 

func (m *Request) GetBmRemove() BMRemoveRequest

func (*Request) GetCountInstance 

func (m *Request) GetCountInstance() InstanceCountStateRequest

func (*Request) GetCrowdInstance 

func (m *Request) GetCrowdInstance() InstanceCrowdStateRequest

func (*Request) GetDelete 

func (m *Request) GetDelete() DeleteRequest

func (*Request) GetDeleteIf 

func (m *Request) GetDeleteIf() DeleteIfRequest

func (*Request) GetGet 

func (m *Request) GetGet() GetRequest

func (*Request) GetGetIDSet 

func (m *Request) GetGetIDSet() GetIDSetRequest

func (*Request) GetGetMapping 

func (m *Request) GetGetMapping() GetMappingRequest

func (*Request) GetGetProfile 

func (m *Request) GetGetProfile() GetProfileRequest

func (*Request) GetHistoryInstance 

func (m *Request) GetHistoryInstance() HistoryInstanceRequest

func (*Request) GetID 

func (m *Request) GetID() uint64

func (*Request) GetLastInstance 

func (m *Request) GetLastInstance() LastInstanceRequest

func (*Request) GetLock 

func (m *Request) GetLock() LockRequest

func (*Request) GetQueueCommit 

func (m *Request) GetQueueCommit() QueueCommitRequest

func (*Request) GetQueueDelete 

func (m *Request) GetQueueDelete() QueueDeleteRequest

func (*Request) GetQueueFetch 

func (m *Request) GetQueueFetch() QueueFetchRequest

func (*Request) GetQueueJoin 

func (m *Request) GetQueueJoin() QueueJoinGroupRequest

func (*Request) GetQueueScan 

func (m *Request) GetQueueScan() QueueScanRequest

func (*Request) GetResetID 

func (m *Request) GetResetID() ResetIDRequest

func (*Request) GetScan 

func (m *Request) GetScan() ScanRequest

func (*Request) GetScanMapping 

func (m *Request) GetScanMapping() ScanMappingRequest

func (*Request) GetSet 

func (m *Request) GetSet() SetRequest

func (*Request) GetSetIf 

func (m *Request) GetSetIf() SetIfRequest

func (*Request) GetStartInstance 

func (m *Request) GetStartInstance() StartingInstanceRequest

func (*Request) GetStopInstance 

func (m *Request) GetStopInstance() StopInstanceRequest

func (*Request) GetTenantInit 

func (m *Request) GetTenantInit() TenantInitRequest

func (*Request) GetType 

func (m *Request) GetType() Type

func (*Request) GetUnlock 

func (m *Request) GetUnlock() UnlockRequest

func (*Request) GetUpdateCrowd 

func (m *Request) GetUpdateCrowd() UpdateCrowdRequest

func (*Request) GetUpdateMapping 

func (m *Request) GetUpdateMapping() UpdateMappingRequest

func (*Request) GetUpdateProfile 

func (m *Request) GetUpdateProfile() UpdateProfileRequest

func (*Request) GetUpdateWorkflow 

func (m *Request) GetUpdateWorkflow() UpdateWorkflowRequest

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer 

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

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type ResetIDRequest 

type ResetIDRequest struct {
	Key       []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	StartWith uint64 `protobuf:"varint,2,opt,name=startWith,proto3" json:"startWith,omitempty"`
}

ResetIDRequest reset alloc id request

func AcquireResetIDRequest 

func AcquireResetIDRequest() *ResetIDRequest

AcquireResetIDRequest returns value from pool

func (*ResetIDRequest) Descriptor 

func (*ResetIDRequest) Descriptor() ([]byte, []int)

func (*ResetIDRequest) GetKey 

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

func (*ResetIDRequest) GetStartWith 

func (m *ResetIDRequest) GetStartWith() uint64

func (*ResetIDRequest) Marshal 

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

func (*ResetIDRequest) MarshalTo 

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

func (*ResetIDRequest) MarshalToSizedBuffer 

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

func (*ResetIDRequest) ProtoMessage 

func (*ResetIDRequest) ProtoMessage()

func (*ResetIDRequest) Reset 

func (m *ResetIDRequest) Reset()

func (*ResetIDRequest) Size 

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

func (*ResetIDRequest) String 

func (m *ResetIDRequest) String() string

func (*ResetIDRequest) Unmarshal 

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

func (*ResetIDRequest) XXX_DiscardUnknown 

func (m *ResetIDRequest) XXX_DiscardUnknown()

func (*ResetIDRequest) XXX_Marshal 

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

func (*ResetIDRequest) XXX_Merge 

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

func (*ResetIDRequest) XXX_Size 

func (m *ResetIDRequest) XXX_Size() int

func (*ResetIDRequest) XXX_Unmarshal 

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

type Response 

type Response struct {
	ID              uint64                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type            Type                   `protobuf:"varint,2,opt,name=type,proto3,enum=rpcpb.Type" json:"type,omitempty"`
	Error           ErrorResponse          `protobuf:"bytes,3,opt,name=error,proto3" json:"error"`
	BytesResp       BytesResponse          `protobuf:"bytes,4,opt,name=bytesResp,proto3" json:"bytesResp"`
	BoolResp        BoolResponse           `protobuf:"bytes,5,opt,name=boolResp,proto3" json:"boolResp"`
	Uint64Resp      Uint64Response         `protobuf:"bytes,6,opt,name=uint64Resp,proto3" json:"uint64Resp"`
	Uint32Resp      Uint32Response         `protobuf:"bytes,7,opt,name=uint32Resp,proto3" json:"uint32Resp"`
	Uint32RangeResp Uint32RangeResponse    `protobuf:"bytes,8,opt,name=uint32RangeResp,proto3" json:"uint32RangeResp"`
	Uint32SliceResp Uint32SliceResponse    `protobuf:"bytes,9,opt,name=uint32SliceResp,proto3" json:"uint32SliceResp"`
	BytesSliceResp  BytesSliceResponse     `protobuf:"bytes,10,opt,name=bytesSliceResp,proto3" json:"bytesSliceResp"`
	StringResp      StringResponse         `protobuf:"bytes,11,opt,name=stringResp,proto3" json:"stringResp"`
	JoinResp        QueueJoinGroupResponse `protobuf:"bytes,12,opt,name=joinResp,proto3" json:"joinResp"`
	FetchResp       QueueFetchResponse     `protobuf:"bytes,13,opt,name=fetchResp,proto3" json:"fetchResp"`
}

Response the busybee response

func AcquireResponse 

func AcquireResponse() *Response

AcquireResponse returns value from pool

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetBoolResp 

func (m *Response) GetBoolResp() BoolResponse

func (*Response) GetBytesResp 

func (m *Response) GetBytesResp() BytesResponse

func (*Response) GetBytesSliceResp 

func (m *Response) GetBytesSliceResp() BytesSliceResponse

func (*Response) GetError 

func (m *Response) GetError() ErrorResponse

func (*Response) GetFetchResp 

func (m *Response) GetFetchResp() QueueFetchResponse

func (*Response) GetID 

func (m *Response) GetID() uint64

func (*Response) GetJoinResp 

func (m *Response) GetJoinResp() QueueJoinGroupResponse

func (*Response) GetStringResp 

func (m *Response) GetStringResp() StringResponse

func (*Response) GetType 

func (m *Response) GetType() Type

func (*Response) GetUint32RangeResp 

func (m *Response) GetUint32RangeResp() Uint32RangeResponse

func (*Response) GetUint32Resp 

func (m *Response) GetUint32Resp() Uint32Response

func (*Response) GetUint32SliceResp 

func (m *Response) GetUint32SliceResp() Uint32SliceResponse

func (*Response) GetUint64Resp 

func (m *Response) GetUint64Resp() Uint64Response

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type ScanMappingRequest 

type ScanMappingRequest struct {
	ID    uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	From  uint32 `protobuf:"varint,2,opt,name=from,proto3" json:"from,omitempty"`
	To    uint32 `protobuf:"varint,3,opt,name=to,proto3" json:"to,omitempty"`
	Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
}

ScanMappingRequest scan tenant all mappinged id values

func AcquireScanMappingRequest 

func AcquireScanMappingRequest() *ScanMappingRequest

AcquireScanMappingRequest returns value from pool

func (*ScanMappingRequest) Descriptor 

func (*ScanMappingRequest) Descriptor() ([]byte, []int)

func (*ScanMappingRequest) GetFrom 

func (m *ScanMappingRequest) GetFrom() uint32

func (*ScanMappingRequest) GetID 

func (m *ScanMappingRequest) GetID() uint64

func (*ScanMappingRequest) GetLimit 

func (m *ScanMappingRequest) GetLimit() uint64

func (*ScanMappingRequest) GetTo 

func (m *ScanMappingRequest) GetTo() uint32

func (*ScanMappingRequest) Marshal 

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

func (*ScanMappingRequest) MarshalTo 

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

func (*ScanMappingRequest) MarshalToSizedBuffer 

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

func (*ScanMappingRequest) ProtoMessage 

func (*ScanMappingRequest) ProtoMessage()

func (*ScanMappingRequest) Reset 

func (m *ScanMappingRequest) Reset()

func (*ScanMappingRequest) Size 

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

func (*ScanMappingRequest) String 

func (m *ScanMappingRequest) String() string

func (*ScanMappingRequest) Unmarshal 

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

func (*ScanMappingRequest) XXX_DiscardUnknown 

func (m *ScanMappingRequest) XXX_DiscardUnknown()

func (*ScanMappingRequest) XXX_Marshal 

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

func (*ScanMappingRequest) XXX_Merge 

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

func (*ScanMappingRequest) XXX_Size 

func (m *ScanMappingRequest) XXX_Size() int

func (*ScanMappingRequest) XXX_Unmarshal 

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

type ScanRequest 

type ScanRequest struct {
	Start []byte       `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End   []byte       `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	Limit uint64       `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Group metapb.Group `protobuf:"varint,4,opt,name=group,proto3,enum=metapb.Group" json:"group,omitempty"`
}

ScanRequest scan request

func AcquireScanRequest 

func AcquireScanRequest() *ScanRequest

AcquireScanRequest returns value from pool

func (*ScanRequest) Descriptor 

func (*ScanRequest) Descriptor() ([]byte, []int)

func (*ScanRequest) GetEnd 

func (m *ScanRequest) GetEnd() []byte

func (*ScanRequest) GetGroup 

func (m *ScanRequest) GetGroup() metapb.Group

func (*ScanRequest) GetLimit 

func (m *ScanRequest) GetLimit() uint64

func (*ScanRequest) GetStart 

func (m *ScanRequest) GetStart() []byte

func (*ScanRequest) Marshal 

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

func (*ScanRequest) MarshalTo 

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

func (*ScanRequest) MarshalToSizedBuffer 

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

func (*ScanRequest) ProtoMessage 

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) Reset 

func (m *ScanRequest) Reset()

func (*ScanRequest) Size 

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

func (*ScanRequest) String 

func (m *ScanRequest) String() string

func (*ScanRequest) Unmarshal 

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

func (*ScanRequest) XXX_DiscardUnknown 

func (m *ScanRequest) XXX_DiscardUnknown()

func (*ScanRequest) XXX_Marshal 

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

func (*ScanRequest) XXX_Merge 

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

func (*ScanRequest) XXX_Size 

func (m *ScanRequest) XXX_Size() int

func (*ScanRequest) XXX_Unmarshal 

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

type SetIfRequest 

type SetIfRequest 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"`
	TTL        int64            `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	Conditions []ConditionGroup `protobuf:"bytes,4,rep,name=conditions,proto3" json:"conditions"`
}

SetIfRequest set with condition

func AcquireSetIfRequest 

func AcquireSetIfRequest() *SetIfRequest

AcquireSetIfRequest returns value from pool

func (*SetIfRequest) Descriptor 

func (*SetIfRequest) Descriptor() ([]byte, []int)

func (*SetIfRequest) GetConditions 

func (m *SetIfRequest) GetConditions() []ConditionGroup

func (*SetIfRequest) GetKey 

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

func (*SetIfRequest) GetTTL 

func (m *SetIfRequest) GetTTL() int64

func (*SetIfRequest) GetValue 

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

func (*SetIfRequest) Marshal 

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

func (*SetIfRequest) MarshalTo 

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

func (*SetIfRequest) MarshalToSizedBuffer 

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

func (*SetIfRequest) ProtoMessage 

func (*SetIfRequest) ProtoMessage()

func (*SetIfRequest) Reset 

func (m *SetIfRequest) Reset()

func (*SetIfRequest) Size 

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

func (*SetIfRequest) String 

func (m *SetIfRequest) String() string

func (*SetIfRequest) Unmarshal 

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

func (*SetIfRequest) XXX_DiscardUnknown 

func (m *SetIfRequest) XXX_DiscardUnknown()

func (*SetIfRequest) XXX_Marshal 

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

func (*SetIfRequest) XXX_Merge 

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

func (*SetIfRequest) XXX_Size 

func (m *SetIfRequest) XXX_Size() int

func (*SetIfRequest) XXX_Unmarshal 

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

type SetRequest 

type SetRequest 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"`
	TTL   int64  `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
}

SetRequest set a key value pair

func AcquireSetRequest 

func AcquireSetRequest() *SetRequest

AcquireSetRequest returns value from pool

func (*SetRequest) Descriptor 

func (*SetRequest) Descriptor() ([]byte, []int)

func (*SetRequest) GetKey 

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

func (*SetRequest) GetTTL 

func (m *SetRequest) GetTTL() int64

func (*SetRequest) GetValue 

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

func (*SetRequest) Marshal 

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

func (*SetRequest) MarshalTo 

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

func (*SetRequest) MarshalToSizedBuffer 

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

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) Reset 

func (m *SetRequest) Reset()

func (*SetRequest) Size 

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

func (*SetRequest) String 

func (m *SetRequest) String() string

func (*SetRequest) Unmarshal 

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

func (*SetRequest) XXX_DiscardUnknown 

func (m *SetRequest) XXX_DiscardUnknown()

func (*SetRequest) XXX_Marshal 

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

func (*SetRequest) XXX_Merge 

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

func (*SetRequest) XXX_Size 

func (m *SetRequest) XXX_Size() int

func (*SetRequest) XXX_Unmarshal 

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

type StartedInstanceRequest 

type StartedInstanceRequest struct {
	WorkflowID uint64 `protobuf:"varint,1,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
}

StartedInstanceRequest remove a workflow

func AcquireStartedInstanceRequest 

func AcquireStartedInstanceRequest() *StartedInstanceRequest

AcquireStartedInstanceRequest returns value from pool

func (*StartedInstanceRequest) Descriptor 

func (*StartedInstanceRequest) Descriptor() ([]byte, []int)

func (*StartedInstanceRequest) GetWorkflowID 

func (m *StartedInstanceRequest) GetWorkflowID() uint64

func (*StartedInstanceRequest) Marshal 

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

func (*StartedInstanceRequest) MarshalTo 

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

func (*StartedInstanceRequest) MarshalToSizedBuffer 

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

func (*StartedInstanceRequest) ProtoMessage 

func (*StartedInstanceRequest) ProtoMessage()

func (*StartedInstanceRequest) Reset 

func (m *StartedInstanceRequest) Reset()

func (*StartedInstanceRequest) Size 

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

func (*StartedInstanceRequest) String 

func (m *StartedInstanceRequest) String() string

func (*StartedInstanceRequest) Unmarshal 

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

func (*StartedInstanceRequest) XXX_DiscardUnknown 

func (m *StartedInstanceRequest) XXX_DiscardUnknown()

func (*StartedInstanceRequest) XXX_Marshal 

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

func (*StartedInstanceRequest) XXX_Merge 

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

func (*StartedInstanceRequest) XXX_Size 

func (m *StartedInstanceRequest) XXX_Size() int

func (*StartedInstanceRequest) XXX_Unmarshal 

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

type StartingInstanceRequest 

type StartingInstanceRequest struct {
	Instance metapb.WorkflowInstance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance"`
}

StartingInstanceRequest start a workflow instance

func AcquireStartingInstanceRequest 

func AcquireStartingInstanceRequest() *StartingInstanceRequest

AcquireStartingInstanceRequest returns value from pool

func (*StartingInstanceRequest) Descriptor 

func (*StartingInstanceRequest) Descriptor() ([]byte, []int)

func (*StartingInstanceRequest) GetInstance 

func (m *StartingInstanceRequest) GetInstance() metapb.WorkflowInstance

func (*StartingInstanceRequest) Marshal 

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

func (*StartingInstanceRequest) MarshalTo 

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

func (*StartingInstanceRequest) MarshalToSizedBuffer 

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

func (*StartingInstanceRequest) ProtoMessage 

func (*StartingInstanceRequest) ProtoMessage()

func (*StartingInstanceRequest) Reset 

func (m *StartingInstanceRequest) Reset()

func (*StartingInstanceRequest) Size 

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

func (*StartingInstanceRequest) String 

func (m *StartingInstanceRequest) String() string

func (*StartingInstanceRequest) Unmarshal 

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

func (*StartingInstanceRequest) XXX_DiscardUnknown 

func (m *StartingInstanceRequest) XXX_DiscardUnknown()

func (*StartingInstanceRequest) XXX_Marshal 

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

func (*StartingInstanceRequest) XXX_Merge 

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

func (*StartingInstanceRequest) XXX_Size 

func (m *StartingInstanceRequest) XXX_Size() int

func (*StartingInstanceRequest) XXX_Unmarshal 

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

type StopInstanceRequest 

type StopInstanceRequest struct {
	WorkflowID uint64 `protobuf:"varint,1,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
}

StopInstanceRequest stop a workflow

func AcquireStopInstanceRequest 

func AcquireStopInstanceRequest() *StopInstanceRequest

AcquireStopInstanceRequest returns value from pool

func (*StopInstanceRequest) Descriptor 

func (*StopInstanceRequest) Descriptor() ([]byte, []int)

func (*StopInstanceRequest) GetWorkflowID 

func (m *StopInstanceRequest) GetWorkflowID() uint64

func (*StopInstanceRequest) Marshal 

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

func (*StopInstanceRequest) MarshalTo 

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

func (*StopInstanceRequest) MarshalToSizedBuffer 

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

func (*StopInstanceRequest) ProtoMessage 

func (*StopInstanceRequest) ProtoMessage()

func (*StopInstanceRequest) Reset 

func (m *StopInstanceRequest) Reset()

func (*StopInstanceRequest) Size 

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

func (*StopInstanceRequest) String 

func (m *StopInstanceRequest) String() string

func (*StopInstanceRequest) Unmarshal 

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

func (*StopInstanceRequest) XXX_DiscardUnknown 

func (m *StopInstanceRequest) XXX_DiscardUnknown()

func (*StopInstanceRequest) XXX_Marshal 

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

func (*StopInstanceRequest) XXX_Merge 

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

func (*StopInstanceRequest) XXX_Size 

func (m *StopInstanceRequest) XXX_Size() int

func (*StopInstanceRequest) XXX_Unmarshal 

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

type StoppedInstanceRequest 

type StoppedInstanceRequest struct {
	WorkflowID uint64 `protobuf:"varint,1,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
}

StoppedInstanceRequest workflow stopped

func AcquireStoppedInstanceRequest 

func AcquireStoppedInstanceRequest() *StoppedInstanceRequest

AcquireStoppedInstanceRequest returns value from pool

func (*StoppedInstanceRequest) Descriptor 

func (*StoppedInstanceRequest) Descriptor() ([]byte, []int)

func (*StoppedInstanceRequest) GetWorkflowID 

func (m *StoppedInstanceRequest) GetWorkflowID() uint64

func (*StoppedInstanceRequest) Marshal 

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

func (*StoppedInstanceRequest) MarshalTo 

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

func (*StoppedInstanceRequest) MarshalToSizedBuffer 

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

func (*StoppedInstanceRequest) ProtoMessage 

func (*StoppedInstanceRequest) ProtoMessage()

func (*StoppedInstanceRequest) Reset 

func (m *StoppedInstanceRequest) Reset()

func (*StoppedInstanceRequest) Size 

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

func (*StoppedInstanceRequest) String 

func (m *StoppedInstanceRequest) String() string

func (*StoppedInstanceRequest) Unmarshal 

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

func (*StoppedInstanceRequest) XXX_DiscardUnknown 

func (m *StoppedInstanceRequest) XXX_DiscardUnknown()

func (*StoppedInstanceRequest) XXX_Marshal 

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

func (*StoppedInstanceRequest) XXX_Merge 

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

func (*StoppedInstanceRequest) XXX_Size 

func (m *StoppedInstanceRequest) XXX_Size() int

func (*StoppedInstanceRequest) XXX_Unmarshal 

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

type StringResponse 

type StringResponse struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

StringResponse response

func (*StringResponse) Descriptor 

func (*StringResponse) Descriptor() ([]byte, []int)

func (*StringResponse) GetValue 

func (m *StringResponse) GetValue() string

func (*StringResponse) Marshal 

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

func (*StringResponse) MarshalTo 

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

func (*StringResponse) MarshalToSizedBuffer 

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

func (*StringResponse) ProtoMessage 

func (*StringResponse) ProtoMessage()

func (*StringResponse) Reset 

func (m *StringResponse) Reset()

func (*StringResponse) Size 

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

func (*StringResponse) String 

func (m *StringResponse) String() string

func (*StringResponse) Unmarshal 

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

func (*StringResponse) XXX_DiscardUnknown 

func (m *StringResponse) XXX_DiscardUnknown()

func (*StringResponse) XXX_Marshal 

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

func (*StringResponse) XXX_Merge 

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

func (*StringResponse) XXX_Size 

func (m *StringResponse) XXX_Size() int

func (*StringResponse) XXX_Unmarshal 

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

type TenantInitRequest 

type TenantInitRequest struct {
	Metadata metapb.Tenant `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata"`
}

TenantInitRequest init tenant

func AcquireTenantInitRequest 

func AcquireTenantInitRequest() *TenantInitRequest

AcquireTenantInitRequest returns value from pool

func (*TenantInitRequest) Descriptor 

func (*TenantInitRequest) Descriptor() ([]byte, []int)

func (*TenantInitRequest) GetMetadata 

func (m *TenantInitRequest) GetMetadata() metapb.Tenant

func (*TenantInitRequest) Marshal 

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

func (*TenantInitRequest) MarshalTo 

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

func (*TenantInitRequest) MarshalToSizedBuffer 

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

func (*TenantInitRequest) ProtoMessage 

func (*TenantInitRequest) ProtoMessage()

func (*TenantInitRequest) Reset 

func (m *TenantInitRequest) Reset()

func (*TenantInitRequest) Size 

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

func (*TenantInitRequest) String 

func (m *TenantInitRequest) String() string

func (*TenantInitRequest) Unmarshal 

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

func (*TenantInitRequest) XXX_DiscardUnknown 

func (m *TenantInitRequest) XXX_DiscardUnknown()

func (*TenantInitRequest) XXX_Marshal 

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

func (*TenantInitRequest) XXX_Merge 

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

func (*TenantInitRequest) XXX_Size 

func (m *TenantInitRequest) XXX_Size() int

func (*TenantInitRequest) XXX_Unmarshal 

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

type TenantInitStateUpdateRequest 

type TenantInitStateUpdateRequest 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 metapb.Group `protobuf:"varint,3,opt,name=group,proto3,enum=metapb.Group" json:"group,omitempty"`
}

TenantInitStateUpdateRequest

func AcquireTenantInitStateUpdateRequest 

func AcquireTenantInitStateUpdateRequest() *TenantInitStateUpdateRequest

AcquireTenantInitStateUpdateRequest returns value from pool

func (*TenantInitStateUpdateRequest) Descriptor 

func (*TenantInitStateUpdateRequest) Descriptor() ([]byte, []int)

func (*TenantInitStateUpdateRequest) GetGroup 

func (m *TenantInitStateUpdateRequest) GetGroup() metapb.Group

func (*TenantInitStateUpdateRequest) GetID 

func (m *TenantInitStateUpdateRequest) GetID() uint64

func (*TenantInitStateUpdateRequest) GetIndex 

func (m *TenantInitStateUpdateRequest) GetIndex() int32

func (*TenantInitStateUpdateRequest) Marshal 

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

func (*TenantInitStateUpdateRequest) MarshalTo 

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

func (*TenantInitStateUpdateRequest) MarshalToSizedBuffer 

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

func (*TenantInitStateUpdateRequest) ProtoMessage 

func (*TenantInitStateUpdateRequest) ProtoMessage()

func (*TenantInitStateUpdateRequest) Reset 

func (m *TenantInitStateUpdateRequest) Reset()

func (*TenantInitStateUpdateRequest) Size 

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

func (*TenantInitStateUpdateRequest) String 

func (m *TenantInitStateUpdateRequest) String() string

func (*TenantInitStateUpdateRequest) Unmarshal 

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

func (*TenantInitStateUpdateRequest) XXX_DiscardUnknown 

func (m *TenantInitStateUpdateRequest) XXX_DiscardUnknown()

func (*TenantInitStateUpdateRequest) XXX_Marshal 

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

func (*TenantInitStateUpdateRequest) XXX_Merge 

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

func (*TenantInitStateUpdateRequest) XXX_Size 

func (m *TenantInitStateUpdateRequest) XXX_Size() int

func (*TenantInitStateUpdateRequest) XXX_Unmarshal 

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

type Type 

type Type int32
const (
	Set                      Type = 0
	Get                      Type = 1
	Delete                   Type = 2
	Scan                     Type = 3
	SetIf                    Type = 4
	DeleteIf                 Type = 5
	BMCreate                 Type = 100
	BMAdd                    Type = 101
	BMRemove                 Type = 102
	BMClear                  Type = 103
	BMContains               Type = 104
	BMCount                  Type = 105
	BMRange                  Type = 106
	StartingInstance         Type = 200
	LastInstance             Type = 201
	HistoryInstance          Type = 202
	UpdateWorkflow           Type = 203
	UpdateCrowd              Type = 204
	StartedInstance          Type = 205
	StopInstance             Type = 206
	StoppedInstance          Type = 207
	CreateInstanceStateShard Type = 208
	UpdateInstanceStateShard Type = 209
	RemoveInstanceStateShard Type = 210
	InstanceCountState       Type = 211
	InstanceCrowdState       Type = 212
	QueueAdd                 Type = 300
	QueueFetch               Type = 301
	QueueJoin                Type = 302
	QueueScan                Type = 303
	QueueCommit              Type = 304
	QueueDelete              Type = 305
	TenantInit               Type = 400
	UpdateMapping            Type = 401
	GetMapping               Type = 402
	UpdateProfile            Type = 403
	GetProfile               Type = 404
	AddEvent                 Type = 405
	FetchNotify              Type = 406
	ScanMapping              Type = 407
	GetIDSet                 Type = 408
	TenantInitStateUpdate    Type = 409
	AllocID                  Type = 501
	ResetID                  Type = 502
	Lock                     Type = 601
	Unlock                   Type = 602
)

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) String() string

type Uint32RangeResponse 

type Uint32RangeResponse struct {
	From uint32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To   uint32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
}

Uint32RangeResponse uint32 range response

func AcquireUint32RangeResponse 

func AcquireUint32RangeResponse() *Uint32RangeResponse

AcquireUint32RangeResponse returns value from pool

func (*Uint32RangeResponse) Descriptor 

func (*Uint32RangeResponse) Descriptor() ([]byte, []int)

func (*Uint32RangeResponse) GetFrom 

func (m *Uint32RangeResponse) GetFrom() uint32

func (*Uint32RangeResponse) GetTo 

func (m *Uint32RangeResponse) GetTo() uint32

func (*Uint32RangeResponse) Marshal 

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

func (*Uint32RangeResponse) MarshalTo 

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

func (*Uint32RangeResponse) MarshalToSizedBuffer 

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

func (*Uint32RangeResponse) ProtoMessage 

func (*Uint32RangeResponse) ProtoMessage()

func (*Uint32RangeResponse) Reset 

func (m *Uint32RangeResponse) Reset()

func (*Uint32RangeResponse) Size 

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

func (*Uint32RangeResponse) String 

func (m *Uint32RangeResponse) String() string

func (*Uint32RangeResponse) Unmarshal 

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

func (*Uint32RangeResponse) XXX_DiscardUnknown 

func (m *Uint32RangeResponse) XXX_DiscardUnknown()

func (*Uint32RangeResponse) XXX_Marshal 

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

func (*Uint32RangeResponse) XXX_Merge 

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

func (*Uint32RangeResponse) XXX_Size 

func (m *Uint32RangeResponse) XXX_Size() int

func (*Uint32RangeResponse) XXX_Unmarshal 

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

type Uint32Response 

type Uint32Response struct {
	Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}

Uint32Response uint32 response

func AcquireUint32Response 

func AcquireUint32Response() *Uint32Response

AcquireUint32Response returns value from pool

func (*Uint32Response) Descriptor 

func (*Uint32Response) Descriptor() ([]byte, []int)

func (*Uint32Response) GetValue 

func (m *Uint32Response) GetValue() uint32

func (*Uint32Response) Marshal 

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

func (*Uint32Response) MarshalTo 

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

func (*Uint32Response) MarshalToSizedBuffer 

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

func (*Uint32Response) ProtoMessage 

func (*Uint32Response) ProtoMessage()

func (*Uint32Response) Reset 

func (m *Uint32Response) Reset()

func (*Uint32Response) Size 

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

func (*Uint32Response) String 

func (m *Uint32Response) String() string

func (*Uint32Response) Unmarshal 

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

func (*Uint32Response) XXX_DiscardUnknown 

func (m *Uint32Response) XXX_DiscardUnknown()

func (*Uint32Response) XXX_Marshal 

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

func (*Uint32Response) XXX_Merge 

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

func (*Uint32Response) XXX_Size 

func (m *Uint32Response) XXX_Size() int

func (*Uint32Response) XXX_Unmarshal 

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

type Uint32SliceResponse 

type Uint32SliceResponse struct {
	Values []uint32 `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
}

Uint32SliceResponse response

func AcquireUint32SliceResponse 

func AcquireUint32SliceResponse() *Uint32SliceResponse

AcquireUint32SliceResponse returns value from pool

func (*Uint32SliceResponse) Descriptor 

func (*Uint32SliceResponse) Descriptor() ([]byte, []int)

func (*Uint32SliceResponse) GetValues 

func (m *Uint32SliceResponse) GetValues() []uint32

func (*Uint32SliceResponse) Marshal 

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

func (*Uint32SliceResponse) MarshalTo 

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

func (*Uint32SliceResponse) MarshalToSizedBuffer 

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

func (*Uint32SliceResponse) ProtoMessage 

func (*Uint32SliceResponse) ProtoMessage()

func (*Uint32SliceResponse) Reset 

func (m *Uint32SliceResponse) Reset()

func (*Uint32SliceResponse) Size 

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

func (*Uint32SliceResponse) String 

func (m *Uint32SliceResponse) String() string

func (*Uint32SliceResponse) Unmarshal 

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

func (*Uint32SliceResponse) XXX_DiscardUnknown 

func (m *Uint32SliceResponse) XXX_DiscardUnknown()

func (*Uint32SliceResponse) XXX_Marshal 

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

func (*Uint32SliceResponse) XXX_Merge 

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

func (*Uint32SliceResponse) XXX_Size 

func (m *Uint32SliceResponse) XXX_Size() int

func (*Uint32SliceResponse) XXX_Unmarshal 

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

type Uint64Response 

type Uint64Response struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}

Uint64Response response

func AcquireUint64Response 

func AcquireUint64Response() *Uint64Response

AcquireUint64Response returns value from pool

func (*Uint64Response) Descriptor 

func (*Uint64Response) Descriptor() ([]byte, []int)

func (*Uint64Response) GetValue 

func (m *Uint64Response) GetValue() uint64

func (*Uint64Response) Marshal 

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

func (*Uint64Response) MarshalTo 

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

func (*Uint64Response) MarshalToSizedBuffer 

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

func (*Uint64Response) ProtoMessage 

func (*Uint64Response) ProtoMessage()

func (*Uint64Response) Reset 

func (m *Uint64Response) Reset()

func (*Uint64Response) Size 

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

func (*Uint64Response) String 

func (m *Uint64Response) String() string

func (*Uint64Response) Unmarshal 

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

func (*Uint64Response) XXX_DiscardUnknown 

func (m *Uint64Response) XXX_DiscardUnknown()

func (*Uint64Response) XXX_Marshal 

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

func (*Uint64Response) XXX_Merge 

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

func (*Uint64Response) XXX_Size 

func (m *Uint64Response) XXX_Size() int

func (*Uint64Response) XXX_Unmarshal 

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

type UnlockRequest 

type UnlockRequest 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"`
}

UnlockRequest unlock

func AcquireUnlockRequest 

func AcquireUnlockRequest() *UnlockRequest

AcquireUnlockRequest returns value from pool

func (*UnlockRequest) Descriptor 

func (*UnlockRequest) Descriptor() ([]byte, []int)

func (*UnlockRequest) GetKey 

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

func (*UnlockRequest) GetValue 

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

func (*UnlockRequest) Marshal 

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

func (*UnlockRequest) MarshalTo 

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

func (*UnlockRequest) MarshalToSizedBuffer 

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

func (*UnlockRequest) ProtoMessage 

func (*UnlockRequest) ProtoMessage()

func (*UnlockRequest) Reset 

func (m *UnlockRequest) Reset()

func (*UnlockRequest) Size 

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

func (*UnlockRequest) String 

func (m *UnlockRequest) String() string

func (*UnlockRequest) Unmarshal 

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

func (*UnlockRequest) XXX_DiscardUnknown 

func (m *UnlockRequest) XXX_DiscardUnknown()

func (*UnlockRequest) XXX_Marshal 

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

func (*UnlockRequest) XXX_Merge 

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

func (*UnlockRequest) XXX_Size 

func (m *UnlockRequest) XXX_Size() int

func (*UnlockRequest) XXX_Unmarshal 

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

type UpdateCrowdRequest 

type UpdateCrowdRequest struct {
	ID         uint64          `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Loader     metapb.BMLoader `protobuf:"varint,2,opt,name=loader,proto3,enum=metapb.BMLoader" json:"loader,omitempty"`
	LoaderMeta []byte          `protobuf:"bytes,3,opt,name=loaderMeta,proto3" json:"loaderMeta,omitempty"`
}

UpdateCrowdRequest update crowd request

func (*UpdateCrowdRequest) Descriptor 

func (*UpdateCrowdRequest) Descriptor() ([]byte, []int)

func (*UpdateCrowdRequest) GetID 

func (m *UpdateCrowdRequest) GetID() uint64

func (*UpdateCrowdRequest) GetLoader 

func (m *UpdateCrowdRequest) GetLoader() metapb.BMLoader

func (*UpdateCrowdRequest) GetLoaderMeta 

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

func (*UpdateCrowdRequest) Marshal 

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

func (*UpdateCrowdRequest) MarshalTo 

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

func (*UpdateCrowdRequest) MarshalToSizedBuffer 

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

func (*UpdateCrowdRequest) ProtoMessage 

func (*UpdateCrowdRequest) ProtoMessage()

func (*UpdateCrowdRequest) Reset 

func (m *UpdateCrowdRequest) Reset()

func (*UpdateCrowdRequest) Size 

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

func (*UpdateCrowdRequest) String 

func (m *UpdateCrowdRequest) String() string

func (*UpdateCrowdRequest) Unmarshal 

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

func (*UpdateCrowdRequest) XXX_DiscardUnknown 

func (m *UpdateCrowdRequest) XXX_DiscardUnknown()

func (*UpdateCrowdRequest) XXX_Marshal 

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

func (*UpdateCrowdRequest) XXX_Merge 

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

func (*UpdateCrowdRequest) XXX_Size 

func (m *UpdateCrowdRequest) XXX_Size() int

func (*UpdateCrowdRequest) XXX_Unmarshal 

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

type UpdateInstanceStateShardRequest 

type UpdateInstanceStateShardRequest struct {
	State           metapb.WorkflowInstanceWorkerState `protobuf:"bytes,1,opt,name=state,proto3" json:"state"`
	LockKey         []byte                             `protobuf:"bytes,2,opt,name=lockKey,proto3" json:"lockKey,omitempty"`
	LockExpectValue []byte                             `protobuf:"bytes,3,opt,name=lockExpectValue,proto3" json:"lockExpectValue,omitempty"`
	Ts              int64                              `protobuf:"varint,4,opt,name=ts,proto3" json:"ts,omitempty"`
}

UpdateInstanceStateShardRequest update a instance state

func AcquireUpdateInstanceStateShardRequest 

func AcquireUpdateInstanceStateShardRequest() *UpdateInstanceStateShardRequest

AcquireUpdateInstanceStateShardRequest returns value from pool

func (*UpdateInstanceStateShardRequest) Descriptor 

func (*UpdateInstanceStateShardRequest) Descriptor() ([]byte, []int)

func (*UpdateInstanceStateShardRequest) GetLockExpectValue 

func (m *UpdateInstanceStateShardRequest) GetLockExpectValue() []byte

func (*UpdateInstanceStateShardRequest) GetLockKey 

func (m *UpdateInstanceStateShardRequest) GetLockKey() []byte

func (*UpdateInstanceStateShardRequest) GetState 

func (m *UpdateInstanceStateShardRequest) GetState() metapb.WorkflowInstanceWorkerState

func (*UpdateInstanceStateShardRequest) GetTs 

func (m *UpdateInstanceStateShardRequest) GetTs() int64

func (*UpdateInstanceStateShardRequest) Marshal 

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

func (*UpdateInstanceStateShardRequest) MarshalTo 

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

func (*UpdateInstanceStateShardRequest) MarshalToSizedBuffer 

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

func (*UpdateInstanceStateShardRequest) ProtoMessage 

func (*UpdateInstanceStateShardRequest) ProtoMessage()

func (*UpdateInstanceStateShardRequest) Reset 

func (m *UpdateInstanceStateShardRequest) Reset()

func (*UpdateInstanceStateShardRequest) Size 

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

func (*UpdateInstanceStateShardRequest) String 

func (m *UpdateInstanceStateShardRequest) String() string

func (*UpdateInstanceStateShardRequest) Unmarshal 

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

func (*UpdateInstanceStateShardRequest) XXX_DiscardUnknown 

func (m *UpdateInstanceStateShardRequest) XXX_DiscardUnknown()

func (*UpdateInstanceStateShardRequest) XXX_Marshal 

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

func (*UpdateInstanceStateShardRequest) XXX_Merge 

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

func (*UpdateInstanceStateShardRequest) XXX_Size 

func (m *UpdateInstanceStateShardRequest) XXX_Size() int

func (*UpdateInstanceStateShardRequest) XXX_Unmarshal 

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

type UpdateMappingRequest 

type UpdateMappingRequest struct {
	ID     uint64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserID uint32       `protobuf:"varint,2,opt,name=userID,proto3" json:"userID,omitempty"`
	Set    metapb.IDSet `protobuf:"bytes,3,opt,name=set,proto3" json:"set"`
}

UpdateMappingRequest update id mapping request

func AcquireUpdateMappingRequest 

func AcquireUpdateMappingRequest() *UpdateMappingRequest

AcquireUpdateMappingRequest returns value from pool

func (*UpdateMappingRequest) Descriptor 

func (*UpdateMappingRequest) Descriptor() ([]byte, []int)

func (*UpdateMappingRequest) GetID 

func (m *UpdateMappingRequest) GetID() uint64

func (*UpdateMappingRequest) GetSet 

func (m *UpdateMappingRequest) GetSet() metapb.IDSet

func (*UpdateMappingRequest) GetUserID 

func (m *UpdateMappingRequest) GetUserID() uint32

func (*UpdateMappingRequest) Marshal 

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

func (*UpdateMappingRequest) MarshalTo 

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

func (*UpdateMappingRequest) MarshalToSizedBuffer 

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

func (*UpdateMappingRequest) ProtoMessage 

func (*UpdateMappingRequest) ProtoMessage()

func (*UpdateMappingRequest) Reset 

func (m *UpdateMappingRequest) Reset()

func (*UpdateMappingRequest) Size 

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

func (*UpdateMappingRequest) String 

func (m *UpdateMappingRequest) String() string

func (*UpdateMappingRequest) Unmarshal 

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

func (*UpdateMappingRequest) XXX_DiscardUnknown 

func (m *UpdateMappingRequest) XXX_DiscardUnknown()

func (*UpdateMappingRequest) XXX_Marshal 

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

func (*UpdateMappingRequest) XXX_Merge 

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

func (*UpdateMappingRequest) XXX_Size 

func (m *UpdateMappingRequest) XXX_Size() int

func (*UpdateMappingRequest) XXX_Unmarshal 

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

type UpdateProfileRequest 

type UpdateProfileRequest struct {
	ID     uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UserID uint32 `protobuf:"varint,2,opt,name=userID,proto3" json:"userID,omitempty"`
	Value  []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

UpdateProfileRequest update profile request

func (*UpdateProfileRequest) Descriptor 

func (*UpdateProfileRequest) Descriptor() ([]byte, []int)

func (*UpdateProfileRequest) GetID 

func (m *UpdateProfileRequest) GetID() uint64

func (*UpdateProfileRequest) GetUserID 

func (m *UpdateProfileRequest) GetUserID() uint32

func (*UpdateProfileRequest) GetValue 

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

func (*UpdateProfileRequest) Marshal 

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

func (*UpdateProfileRequest) MarshalTo 

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

func (*UpdateProfileRequest) MarshalToSizedBuffer 

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

func (*UpdateProfileRequest) ProtoMessage 

func (*UpdateProfileRequest) ProtoMessage()

func (*UpdateProfileRequest) Reset 

func (m *UpdateProfileRequest) Reset()

func (*UpdateProfileRequest) Size 

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

func (*UpdateProfileRequest) String 

func (m *UpdateProfileRequest) String() string

func (*UpdateProfileRequest) Unmarshal 

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

func (*UpdateProfileRequest) XXX_DiscardUnknown 

func (m *UpdateProfileRequest) XXX_DiscardUnknown()

func (*UpdateProfileRequest) XXX_Marshal 

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

func (*UpdateProfileRequest) XXX_Merge 

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

func (*UpdateProfileRequest) XXX_Size 

func (m *UpdateProfileRequest) XXX_Size() int

func (*UpdateProfileRequest) XXX_Unmarshal 

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

type UpdateWorkflowRequest 

type UpdateWorkflowRequest struct {
	Workflow metapb.Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow"`
}

UpdateWorkflowRequest update instance request

func (*UpdateWorkflowRequest) Descriptor 

func (*UpdateWorkflowRequest) Descriptor() ([]byte, []int)

func (*UpdateWorkflowRequest) GetWorkflow 

func (m *UpdateWorkflowRequest) GetWorkflow() metapb.Workflow

func (*UpdateWorkflowRequest) Marshal 

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

func (*UpdateWorkflowRequest) MarshalTo 

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

func (*UpdateWorkflowRequest) MarshalToSizedBuffer 

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

func (*UpdateWorkflowRequest) ProtoMessage 

func (*UpdateWorkflowRequest) ProtoMessage()

func (*UpdateWorkflowRequest) Reset 

func (m *UpdateWorkflowRequest) Reset()

func (*UpdateWorkflowRequest) Size 

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

func (*UpdateWorkflowRequest) String 

func (m *UpdateWorkflowRequest) String() string

func (*UpdateWorkflowRequest) Unmarshal 

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

func (*UpdateWorkflowRequest) XXX_DiscardUnknown 

func (m *UpdateWorkflowRequest) XXX_DiscardUnknown()

func (*UpdateWorkflowRequest) XXX_Marshal 

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

func (*UpdateWorkflowRequest) XXX_Merge 

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

func (*UpdateWorkflowRequest) XXX_Size 

func (m *UpdateWorkflowRequest) XXX_Size() int

func (*UpdateWorkflowRequest) XXX_Unmarshal 

func (m *UpdateWorkflowRequest) 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.