api

package
v0.14.4 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2023 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthFlow        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFlow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFlow = fmt.Errorf("proto: unexpected end of group")
)
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 ErrHandleMode_name = map[int32]string{
	0: "ERR_HANDLE_MODE_UNKNOWN",
	1: "ERR_HANDLE_MODE_SKIP",
	2: "ERR_HANDLE_MODE_RETRY",
	3: "ERR_HANDLE_MODE_EXIT",
}
View Source 
var ErrHandleMode_value = map[string]int32{
	"ERR_HANDLE_MODE_UNKNOWN": 0,
	"ERR_HANDLE_MODE_SKIP":    1,
	"ERR_HANDLE_MODE_RETRY":   2,
	"ERR_HANDLE_MODE_EXIT":    3,
}
View Source 
var EventType_name = map[int32]string{
	0:  "ET_UNKNOWN",
	1:  "ET_WORKFLOW",
	2:  "ET_STATUS",
	3:  "ET_STEP",
	4:  "ET_ENTITY",
	5:  "ET_ITEM",
	6:  "ET_TRACE",
	7:  "ET_BPMN",
	11: "ET_RESULT",
}
View Source 
var EventType_value = map[string]int32{
	"ET_UNKNOWN":  0,
	"ET_WORKFLOW": 1,
	"ET_STATUS":   2,
	"ET_STEP":     3,
	"ET_ENTITY":   4,
	"ET_ITEM":     5,
	"ET_TRACE":    6,
	"ET_BPMN":     7,
	"ET_RESULT":   11,
}
View Source 
var HookAction_name = map[int32]string{
	0: "HA_UNKNOWN",
	1: "HA_UP",
	2: "HA_DOWN",
}
View Source 
var HookAction_value = map[string]int32{
	"HA_UNKNOWN": 0,
	"HA_UP":      1,
	"HA_DOWN":    2,
}
View Source 
var PropertyType_name = map[int32]string{
	0: "PYUnknown",
	1: "PYInteger",
	2: "PYFloat",
	3: "PYString",
	4: "PYObject",
}
View Source 
var PropertyType_value = map[string]int32{
	"PYUnknown": 0,
	"PYInteger": 1,
	"PYFloat":   2,
	"PYString":  3,
	"PYObject":  4,
}
View Source 
var StepAction_name = map[int32]string{
	0: "SA_UNKNOWN",
	1: "SC_PREPARE",
	2: "SC_COMMIT",
	3: "SC_ROLLBACK",
	4: "SC_CANCEL",
}
View Source 
var StepAction_value = map[string]int32{
	"SA_UNKNOWN":  0,
	"SC_PREPARE":  1,
	"SC_COMMIT":   2,
	"SC_ROLLBACK": 3,
	"SC_CANCEL":   4,
}
View Source 
var Topic_name = map[int32]string{
	0: "T_UNKNOWN",
	1: "T_CONN",
	2: "T_PING",
	3: "T_CALL",
	4: "T_STEP",
}
View Source 
var Topic_value = map[string]int32{
	"T_UNKNOWN": 0,
	"T_CONN":    1,
	"T_PING":    2,
	"T_CALL":    3,
	"T_STEP":    4,
}
View Source 
var TraceLevel_name = map[int32]string{
	0: "TL_TRACE",
	1: "TL_DEBUG",
	2: "TL_INFO",
	3: "TL_WARN",
	4: "TL_ERROR",
}
View Source 
var TraceLevel_value = map[string]int32{
	"TL_TRACE": 0,
	"TL_DEBUG": 1,
	"TL_INFO":  2,
	"TL_WARN":  3,
	"TL_ERROR": 4,
}
View Source 
var WorkflowState_name = map[int32]string{
	0: "SW_UNKNOWN",
	1: "SW_PAUSE",
	2: "SW_RUNNING",
	3: "SW_SUCCESS",
	4: "SW_WARN",
	5: "SW_FAILED",
}
View Source 
var WorkflowState_value = map[string]int32{
	"SW_UNKNOWN": 0,
	"SW_PAUSE":   1,
	"SW_RUNNING": 2,
	"SW_SUCCESS": 3,
	"SW_WARN":    4,
	"SW_FAILED":  5,
}

Functions

func Equal 

func Equal(err1 error, err2 error) bool

Equal tries to compare errors

func NewFlowRpcEndpoints 

func NewFlowRpcEndpoints() []api.Endpoint

API Endpoints for FlowRpc service

func RegisterFlowRpcHandler 

func RegisterFlowRpcHandler(s server.Server, hdlr FlowRpcHandler, opts ...server.HandlerOption) error

func RegisterFlowRpcServer 

func RegisterFlowRpcServer(s *grpc.Server, srv FlowRpcServer)

Types

type AbortWorkflowInstanceRequest added in v0.10.0 

type AbortWorkflowInstanceRequest struct {
	Wid string `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
}

func (*AbortWorkflowInstanceRequest) Descriptor added in v0.10.0 

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

func (*AbortWorkflowInstanceRequest) Marshal added in v0.10.0 

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

func (*AbortWorkflowInstanceRequest) MarshalTo added in v0.10.0 

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

func (*AbortWorkflowInstanceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*AbortWorkflowInstanceRequest) ProtoMessage added in v0.10.0 

func (*AbortWorkflowInstanceRequest) ProtoMessage()

func (*AbortWorkflowInstanceRequest) Reset added in v0.10.0 

func (m *AbortWorkflowInstanceRequest) Reset()

func (*AbortWorkflowInstanceRequest) String added in v0.10.0 

func (m *AbortWorkflowInstanceRequest) String() string

func (*AbortWorkflowInstanceRequest) Unmarshal added in v0.10.0 

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

func (*AbortWorkflowInstanceRequest) Validate added in v0.10.0 

func (m *AbortWorkflowInstanceRequest) Validate() error

func (*AbortWorkflowInstanceRequest) ValidateE added in v0.10.0 

func (m *AbortWorkflowInstanceRequest) ValidateE(prefix string) error

func (*AbortWorkflowInstanceRequest) XSize added in v0.10.0 

func (m *AbortWorkflowInstanceRequest) XSize() (n int)

func (*AbortWorkflowInstanceRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *AbortWorkflowInstanceRequest) XXX_DiscardUnknown()

func (*AbortWorkflowInstanceRequest) XXX_Marshal added in v0.10.0 

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

func (*AbortWorkflowInstanceRequest) XXX_Merge added in v0.10.0 

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

func (*AbortWorkflowInstanceRequest) XXX_Size added in v0.10.0 

func (m *AbortWorkflowInstanceRequest) XXX_Size() int

func (*AbortWorkflowInstanceRequest) XXX_Unmarshal added in v0.10.0 

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

type AbortWorkflowInstanceResponse added in v0.10.0 

type AbortWorkflowInstanceResponse struct {
}

func (*AbortWorkflowInstanceResponse) Descriptor added in v0.10.0 

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

func (*AbortWorkflowInstanceResponse) Marshal added in v0.10.0 

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

func (*AbortWorkflowInstanceResponse) MarshalTo added in v0.10.0 

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

func (*AbortWorkflowInstanceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*AbortWorkflowInstanceResponse) ProtoMessage added in v0.10.0 

func (*AbortWorkflowInstanceResponse) ProtoMessage()

func (*AbortWorkflowInstanceResponse) Reset added in v0.10.0 

func (m *AbortWorkflowInstanceResponse) Reset()

func (*AbortWorkflowInstanceResponse) String added in v0.10.0 

func (m *AbortWorkflowInstanceResponse) String() string

func (*AbortWorkflowInstanceResponse) Unmarshal added in v0.10.0 

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

func (*AbortWorkflowInstanceResponse) Validate added in v0.10.0 

func (m *AbortWorkflowInstanceResponse) Validate() error

func (*AbortWorkflowInstanceResponse) ValidateE added in v0.10.0 

func (m *AbortWorkflowInstanceResponse) ValidateE(prefix string) error

func (*AbortWorkflowInstanceResponse) XSize added in v0.10.0 

func (m *AbortWorkflowInstanceResponse) XSize() (n int)

func (*AbortWorkflowInstanceResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *AbortWorkflowInstanceResponse) XXX_DiscardUnknown()

func (*AbortWorkflowInstanceResponse) XXX_Marshal added in v0.10.0 

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

func (*AbortWorkflowInstanceResponse) XXX_Merge added in v0.10.0 

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

func (*AbortWorkflowInstanceResponse) XXX_Size added in v0.10.0 

func (m *AbortWorkflowInstanceResponse) XXX_Size() int

func (*AbortWorkflowInstanceResponse) XXX_Unmarshal added in v0.10.0 

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

type BpmnTrace added in v0.13.9 

type BpmnTrace struct {
	Wid       string `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
	FlowId    string `protobuf:"bytes,2,opt,name=flowId,proto3" json:"flowId,omitempty"`
	Stage     string `protobuf:"bytes,3,opt,name=stage,proto3" json:"stage,omitempty"`
	Action    string `protobuf:"bytes,4,opt,name=action,proto3" json:"action,omitempty"`
	Text      string `protobuf:"bytes,5,opt,name=text,proto3" json:"text,omitempty"`
	Timestamp int64  `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*BpmnTrace) DeepCopyInto added in v0.13.9 

func (in *BpmnTrace) DeepCopyInto(out *BpmnTrace)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*BpmnTrace) Descriptor added in v0.13.9 

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

func (*BpmnTrace) Marshal added in v0.13.9 

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

func (*BpmnTrace) MarshalTo added in v0.13.9 

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

func (*BpmnTrace) MarshalToSizedBuffer added in v0.13.9 

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

func (*BpmnTrace) ProtoMessage added in v0.13.9 

func (*BpmnTrace) ProtoMessage()

func (*BpmnTrace) Reset added in v0.13.9 

func (m *BpmnTrace) Reset()

func (*BpmnTrace) String added in v0.13.9 

func (m *BpmnTrace) String() string

func (*BpmnTrace) Unmarshal added in v0.13.9 

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

func (*BpmnTrace) Validate added in v0.13.9 

func (m *BpmnTrace) Validate() error

func (*BpmnTrace) ValidateE added in v0.13.9 

func (m *BpmnTrace) ValidateE(prefix string) error

func (*BpmnTrace) XSize added in v0.13.9 

func (m *BpmnTrace) XSize() (n int)

func (*BpmnTrace) XXX_DiscardUnknown added in v0.13.9 

func (m *BpmnTrace) XXX_DiscardUnknown()

func (*BpmnTrace) XXX_Marshal added in v0.13.9 

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

func (*BpmnTrace) XXX_Merge added in v0.13.9 

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

func (*BpmnTrace) XXX_Size added in v0.13.9 

func (m *BpmnTrace) XXX_Size() int

func (*BpmnTrace) XXX_Unmarshal added in v0.13.9 

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

type CallRequest 

type CallRequest struct {
	// +gen:required
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// +gen:required
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Request []byte `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
}

func (*CallRequest) Descriptor 

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

func (*CallRequest) Marshal 

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

func (*CallRequest) MarshalTo 

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

func (*CallRequest) MarshalToSizedBuffer 

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

func (*CallRequest) ProtoMessage 

func (*CallRequest) ProtoMessage()

func (*CallRequest) Reset 

func (m *CallRequest) Reset()

func (*CallRequest) String 

func (m *CallRequest) String() string

func (*CallRequest) Unmarshal 

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

func (*CallRequest) Validate 

func (m *CallRequest) Validate() error

func (*CallRequest) ValidateE 

func (m *CallRequest) ValidateE(prefix string) error

func (*CallRequest) XSize 

func (m *CallRequest) XSize() (n int)

func (*CallRequest) XXX_DiscardUnknown 

func (m *CallRequest) XXX_DiscardUnknown()

func (*CallRequest) XXX_Marshal 

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

func (*CallRequest) XXX_Merge 

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

func (*CallRequest) XXX_Size 

func (m *CallRequest) XXX_Size() int

func (*CallRequest) XXX_Unmarshal 

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

type CallResponse 

type CallResponse struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*CallResponse) Descriptor 

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

func (*CallResponse) Marshal 

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

func (*CallResponse) MarshalTo 

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

func (*CallResponse) MarshalToSizedBuffer 

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

func (*CallResponse) ProtoMessage 

func (*CallResponse) ProtoMessage()

func (*CallResponse) Reset 

func (m *CallResponse) Reset()

func (*CallResponse) String 

func (m *CallResponse) String() string

func (*CallResponse) Unmarshal 

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

func (*CallResponse) Validate 

func (m *CallResponse) Validate() error

func (*CallResponse) ValidateE 

func (m *CallResponse) ValidateE(prefix string) error

func (*CallResponse) XSize 

func (m *CallResponse) XSize() (n int)

func (*CallResponse) XXX_DiscardUnknown 

func (m *CallResponse) XXX_DiscardUnknown()

func (*CallResponse) XXX_Marshal 

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

func (*CallResponse) XXX_Merge 

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

func (*CallResponse) XXX_Size 

func (m *CallResponse) XXX_Size() int

func (*CallResponse) XXX_Unmarshal 

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

type CommitInteractiveRequest added in v0.10.0 

type CommitInteractiveRequest struct {
	Pid        string            `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Sid        string            `protobuf:"bytes,2,opt,name=sid,proto3" json:"sid,omitempty"`
	Properties map[string]string `` /* 161-byte string literal not displayed */
}

func (*CommitInteractiveRequest) Descriptor added in v0.10.0 

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

func (*CommitInteractiveRequest) Marshal added in v0.10.0 

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

func (*CommitInteractiveRequest) MarshalTo added in v0.10.0 

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

func (*CommitInteractiveRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*CommitInteractiveRequest) ProtoMessage added in v0.10.0 

func (*CommitInteractiveRequest) ProtoMessage()

func (*CommitInteractiveRequest) Reset added in v0.10.0 

func (m *CommitInteractiveRequest) Reset()

func (*CommitInteractiveRequest) String added in v0.10.0 

func (m *CommitInteractiveRequest) String() string

func (*CommitInteractiveRequest) Unmarshal added in v0.10.0 

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

func (*CommitInteractiveRequest) Validate added in v0.10.0 

func (m *CommitInteractiveRequest) Validate() error

func (*CommitInteractiveRequest) ValidateE added in v0.10.0 

func (m *CommitInteractiveRequest) ValidateE(prefix string) error

func (*CommitInteractiveRequest) XSize added in v0.10.0 

func (m *CommitInteractiveRequest) XSize() (n int)

func (*CommitInteractiveRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *CommitInteractiveRequest) XXX_DiscardUnknown()

func (*CommitInteractiveRequest) XXX_Marshal added in v0.10.0 

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

func (*CommitInteractiveRequest) XXX_Merge added in v0.10.0 

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

func (*CommitInteractiveRequest) XXX_Size added in v0.10.0 

func (m *CommitInteractiveRequest) XXX_Size() int

func (*CommitInteractiveRequest) XXX_Unmarshal added in v0.10.0 

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

type CommitInteractiveResponse added in v0.10.0 

type CommitInteractiveResponse struct {
}

func (*CommitInteractiveResponse) Descriptor added in v0.10.0 

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

func (*CommitInteractiveResponse) Marshal added in v0.10.0 

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

func (*CommitInteractiveResponse) MarshalTo added in v0.10.0 

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

func (*CommitInteractiveResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*CommitInteractiveResponse) ProtoMessage added in v0.10.0 

func (*CommitInteractiveResponse) ProtoMessage()

func (*CommitInteractiveResponse) Reset added in v0.10.0 

func (m *CommitInteractiveResponse) Reset()

func (*CommitInteractiveResponse) String added in v0.10.0 

func (m *CommitInteractiveResponse) String() string

func (*CommitInteractiveResponse) Unmarshal added in v0.10.0 

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

func (*CommitInteractiveResponse) Validate added in v0.10.0 

func (m *CommitInteractiveResponse) Validate() error

func (*CommitInteractiveResponse) ValidateE added in v0.10.0 

func (m *CommitInteractiveResponse) ValidateE(prefix string) error

func (*CommitInteractiveResponse) XSize added in v0.10.0 

func (m *CommitInteractiveResponse) XSize() (n int)

func (*CommitInteractiveResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *CommitInteractiveResponse) XXX_DiscardUnknown()

func (*CommitInteractiveResponse) XXX_Marshal added in v0.10.0 

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

func (*CommitInteractiveResponse) XXX_Merge added in v0.10.0 

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

func (*CommitInteractiveResponse) XXX_Size added in v0.10.0 

func (m *CommitInteractiveResponse) XXX_Size() int

func (*CommitInteractiveResponse) XXX_Unmarshal added in v0.10.0 

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

type Echo 

type Echo struct {
	Name     string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Entity   string             `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	Workers  map[string]*Worker `` /* 155-byte string literal not displayed */
	Describe string             `protobuf:"bytes,4,opt,name=describe,proto3" json:"describe,omitempty"`
}

+gen:deepcopy

func (*Echo) DeepCopy 

func (in *Echo) DeepCopy() *Echo

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new Echo.

func (*Echo) DeepCopyInto 

func (in *Echo) DeepCopyInto(out *Echo)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Echo) Descriptor 

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

func (*Echo) Marshal 

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

func (*Echo) MarshalTo 

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

func (*Echo) MarshalToSizedBuffer 

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

func (*Echo) ProtoMessage 

func (*Echo) ProtoMessage()

func (*Echo) Reset 

func (m *Echo) Reset()

func (*Echo) String 

func (m *Echo) String() string

func (*Echo) Unmarshal 

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

func (*Echo) Validate 

func (m *Echo) Validate() error

func (*Echo) ValidateE 

func (m *Echo) ValidateE(prefix string) error

func (*Echo) XSize 

func (m *Echo) XSize() (n int)

func (*Echo) XXX_DiscardUnknown 

func (m *Echo) XXX_DiscardUnknown()

func (*Echo) XXX_Marshal 

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

func (*Echo) XXX_Merge 

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

func (*Echo) XXX_Size 

func (m *Echo) XXX_Size() int

func (*Echo) XXX_Unmarshal 

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

type Entity 

type Entity struct {
	Kind            string             `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Id              string             `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	OwnerReferences []*OwnerReference  `protobuf:"bytes,3,rep,name=ownerReferences,proto3" json:"ownerReferences,omitempty"`
	Raw             string             `protobuf:"bytes,4,opt,name=raw,proto3" json:"raw,omitempty"`
	Workers         map[string]*Worker `` /* 155-byte string literal not displayed */
	Describe        string             `protobuf:"bytes,6,opt,name=describe,proto3" json:"describe,omitempty"`
}

+gen:deepcopy

func (*Entity) DeepCopy 

func (in *Entity) DeepCopy() *Entity

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new Entity.

func (*Entity) DeepCopyInto 

func (in *Entity) DeepCopyInto(out *Entity)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Entity) Descriptor 

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

func (*Entity) Marshal 

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

func (*Entity) MarshalTo 

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

func (*Entity) MarshalToSizedBuffer 

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

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) Reset 

func (m *Entity) Reset()

func (*Entity) String 

func (m *Entity) String() string

func (*Entity) Unmarshal 

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

func (*Entity) Validate 

func (m *Entity) Validate() error

func (*Entity) ValidateE 

func (m *Entity) ValidateE(prefix string) error

func (*Entity) XSize 

func (m *Entity) XSize() (n int)

func (*Entity) XXX_DiscardUnknown 

func (m *Entity) XXX_DiscardUnknown()

func (*Entity) XXX_Marshal 

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

func (*Entity) XXX_Merge 

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

func (*Entity) XXX_Size 

func (m *Entity) XXX_Size() int

func (*Entity) XXX_Unmarshal 

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

type ErrHandleMode added in v0.14.0 

type ErrHandleMode int32
const (
	ErrHandleMode_ERR_HANDLE_MODE_UNKNOWN ErrHandleMode = 0
	ErrHandleMode_ERR_HANDLE_MODE_SKIP    ErrHandleMode = 1
	ErrHandleMode_ERR_HANDLE_MODE_RETRY   ErrHandleMode = 2
	ErrHandleMode_ERR_HANDLE_MODE_EXIT    ErrHandleMode = 3
)

func (ErrHandleMode) EnumDescriptor added in v0.14.0 

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

func (ErrHandleMode) String added in v0.14.0 

func (x ErrHandleMode) String() string

type ErrHandleRequest added in v0.14.0 

type ErrHandleRequest struct {
	Pid   string        `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Sid   string        `protobuf:"bytes,2,opt,name=sid,proto3" json:"sid,omitempty"`
	Mode  ErrHandleMode `protobuf:"varint,3,opt,name=mode,proto3,enum=api.ErrHandleMode" json:"mode,omitempty"`
	Retry int32         `protobuf:"varint,4,opt,name=retry,proto3" json:"retry,omitempty"`
}

func (*ErrHandleRequest) DeepCopyInto added in v0.14.0 

func (in *ErrHandleRequest) DeepCopyInto(out *ErrHandleRequest)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*ErrHandleRequest) Descriptor added in v0.14.0 

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

func (*ErrHandleRequest) Marshal added in v0.14.0 

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

func (*ErrHandleRequest) MarshalTo added in v0.14.0 

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

func (*ErrHandleRequest) MarshalToSizedBuffer added in v0.14.0 

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

func (*ErrHandleRequest) ProtoMessage added in v0.14.0 

func (*ErrHandleRequest) ProtoMessage()

func (*ErrHandleRequest) Reset added in v0.14.0 

func (m *ErrHandleRequest) Reset()

func (*ErrHandleRequest) String added in v0.14.0 

func (m *ErrHandleRequest) String() string

func (*ErrHandleRequest) Unmarshal added in v0.14.0 

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

func (*ErrHandleRequest) Validate added in v0.14.0 

func (m *ErrHandleRequest) Validate() error

func (*ErrHandleRequest) ValidateE added in v0.14.0 

func (m *ErrHandleRequest) ValidateE(prefix string) error

func (*ErrHandleRequest) XSize added in v0.14.0 

func (m *ErrHandleRequest) XSize() (n int)

func (*ErrHandleRequest) XXX_DiscardUnknown added in v0.14.0 

func (m *ErrHandleRequest) XXX_DiscardUnknown()

func (*ErrHandleRequest) XXX_Marshal added in v0.14.0 

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

func (*ErrHandleRequest) XXX_Merge added in v0.14.0 

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

func (*ErrHandleRequest) XXX_Size added in v0.14.0 

func (m *ErrHandleRequest) XXX_Size() int

func (*ErrHandleRequest) XXX_Unmarshal added in v0.14.0 

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

type Error 

type Error struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Status  string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Caller  string `protobuf:"bytes,3,opt,name=caller,proto3" json:"caller,omitempty"`
	Detail  string `protobuf:"bytes,4,opt,name=detail,proto3" json:"detail,omitempty"`
	Retries int32  `protobuf:"varint,5,opt,name=retries,proto3" json:"retries,omitempty"`
	Shadow  bool   `protobuf:"varint,6,opt,name=shadow,proto3" json:"shadow,omitempty"`
}

+gen:deepcopy

func ErrBadGateway 

func ErrBadGateway(format string, a ...interface{}) *Error

ErrBadGateway generates a 502 error

func ErrBadRequest 

func ErrBadRequest(format string, a ...interface{}) *Error

ErrBadRequest generates a 400 error.

func ErrCancel 

func ErrCancel(format string, a ...interface{}) *Error

ErrCancel generates a 408 error.

func ErrClientException 

func ErrClientException(format string, a ...interface{}) *Error

ErrClientException generates a custom client exception.

func ErrConflict 

func ErrConflict(format string, a ...interface{}) *Error

ErrConflict generates a 409 error.

func ErrForbidden 

func ErrForbidden(format string, a ...interface{}) *Error

ErrForbidden generates a 403 error.

func ErrGatewayTimeout 

func ErrGatewayTimeout(format string, a ...interface{}) *Error

ErrGatewayTimeout generates a 504 error

func ErrInsufficientStorage added in v0.2.1 

func ErrInsufficientStorage(format string, a ...interface{}) *Error

ErrInsufficientStorage generates a 507 error

func ErrInternalServerError 

func ErrInternalServerError(format string, a ...interface{}) *Error

ErrInternalServerError generates a 500 error.

func ErrMethodNotAllowed 

func ErrMethodNotAllowed(format string, a ...interface{}) *Error

ErrMethodNotAllowed generates a 405 error.

func ErrNotFound 

func ErrNotFound(format string, a ...interface{}) *Error

ErrNotFound generates a 404 error.

func ErrNotImplemented 

func ErrNotImplemented(format string, a ...interface{}) *Error

ErrNotImplemented generates a 501 error

func ErrPreconditionFailed 

func ErrPreconditionFailed(format string, a ...interface{}) *Error

ErrPreconditionFailed generates a 412 error.

func ErrServiceUnavailable 

func ErrServiceUnavailable(format string, a ...interface{}) *Error

ErrServiceUnavailable generates a 503 error

func ErrUnauthorized 

func ErrUnauthorized(format string, a ...interface{}) *Error

ErrUnauthorized generates a 401 error.

func FromErr 

func FromErr(err error) *Error

FromErr try to convert go error go *Error

func New 

func New(detail string, code StatusCode) *Error

New generates a custom error.

func Parse 

func Parse(err string) *Error

Parse tries to parse a JSON string into an error. If that fails, it will set the given string as the error detail.

func (*Error) DeepCopy 

func (in *Error) DeepCopy() *Error

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new Error.

func (*Error) DeepCopyInto 

func (in *Error) DeepCopyInto(out *Error)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Error) Descriptor 

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

func (Error) Error 

func (e Error) Error() string

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (Error) ToGRPC 

func (e Error) ToGRPC() *status.Status

func (*Error) Unmarshal 

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

func (*Error) Validate 

func (m *Error) Validate() error

func (*Error) ValidateE 

func (m *Error) ValidateE(prefix string) error

func (*Error) WithCaller 

func (e *Error) WithCaller() *Error

WithCaller fills Error.Caller

func (*Error) WithCode 

func (e *Error) WithCode(code StatusCode) *Error

func (*Error) WithRetry added in v0.10.0 

func (e *Error) WithRetry(retry int32) *Error

func (*Error) WithShadow added in v0.10.0 

func (e *Error) WithShadow() *Error

func (*Error) XSize 

func (m *Error) XSize() (n int)

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type EventType 

type EventType int32
const (
	EventType_ET_UNKNOWN  EventType = 0
	EventType_ET_WORKFLOW EventType = 1
	EventType_ET_STATUS   EventType = 2
	EventType_ET_STEP     EventType = 3
	EventType_ET_ENTITY   EventType = 4
	EventType_ET_ITEM     EventType = 5
	EventType_ET_TRACE    EventType = 6
	EventType_ET_BPMN     EventType = 7
	EventType_ET_RESULT   EventType = 11
)

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type ExecuteWorkflowInstanceRequest added in v0.13.2 

type ExecuteWorkflowInstanceRequest struct {
	// +gen:required
	Id          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Definitions string            `protobuf:"bytes,3,opt,name=definitions,proto3" json:"definitions,omitempty"`
	Properties  map[string]string `` /* 161-byte string literal not displayed */
	DataObjects map[string]string `` /* 163-byte string literal not displayed */
	Watch       bool              `protobuf:"varint,6,opt,name=watch,proto3" json:"watch,omitempty"`
}

func (*ExecuteWorkflowInstanceRequest) Descriptor added in v0.13.2 

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

func (*ExecuteWorkflowInstanceRequest) Marshal added in v0.13.2 

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

func (*ExecuteWorkflowInstanceRequest) MarshalTo added in v0.13.2 

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

func (*ExecuteWorkflowInstanceRequest) MarshalToSizedBuffer added in v0.13.2 

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

func (*ExecuteWorkflowInstanceRequest) ProtoMessage added in v0.13.2 

func (*ExecuteWorkflowInstanceRequest) ProtoMessage()

func (*ExecuteWorkflowInstanceRequest) Reset added in v0.13.2 

func (m *ExecuteWorkflowInstanceRequest) Reset()

func (*ExecuteWorkflowInstanceRequest) String added in v0.13.2 

func (m *ExecuteWorkflowInstanceRequest) String() string

func (*ExecuteWorkflowInstanceRequest) Unmarshal added in v0.13.2 

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

func (*ExecuteWorkflowInstanceRequest) Validate added in v0.13.2 

func (m *ExecuteWorkflowInstanceRequest) Validate() error

func (*ExecuteWorkflowInstanceRequest) ValidateE added in v0.13.2 

func (m *ExecuteWorkflowInstanceRequest) ValidateE(prefix string) error

func (*ExecuteWorkflowInstanceRequest) XSize added in v0.13.2 

func (m *ExecuteWorkflowInstanceRequest) XSize() (n int)

func (*ExecuteWorkflowInstanceRequest) XXX_DiscardUnknown added in v0.13.2 

func (m *ExecuteWorkflowInstanceRequest) XXX_DiscardUnknown()

func (*ExecuteWorkflowInstanceRequest) XXX_Marshal added in v0.13.2 

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

func (*ExecuteWorkflowInstanceRequest) XXX_Merge added in v0.13.2 

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

func (*ExecuteWorkflowInstanceRequest) XXX_Size added in v0.13.2 

func (m *ExecuteWorkflowInstanceRequest) XXX_Size() int

func (*ExecuteWorkflowInstanceRequest) XXX_Unmarshal added in v0.13.2 

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

type ExecuteWorkflowInstanceResponse added in v0.13.2 

type ExecuteWorkflowInstanceResponse struct {
	Result *WorkflowWatchResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*ExecuteWorkflowInstanceResponse) Descriptor added in v0.13.2 

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

func (*ExecuteWorkflowInstanceResponse) Marshal added in v0.13.2 

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

func (*ExecuteWorkflowInstanceResponse) MarshalTo added in v0.13.2 

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

func (*ExecuteWorkflowInstanceResponse) MarshalToSizedBuffer added in v0.13.2 

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

func (*ExecuteWorkflowInstanceResponse) ProtoMessage added in v0.13.2 

func (*ExecuteWorkflowInstanceResponse) ProtoMessage()

func (*ExecuteWorkflowInstanceResponse) Reset added in v0.13.2 

func (m *ExecuteWorkflowInstanceResponse) Reset()

func (*ExecuteWorkflowInstanceResponse) String added in v0.13.2 

func (m *ExecuteWorkflowInstanceResponse) String() string

func (*ExecuteWorkflowInstanceResponse) Unmarshal added in v0.13.2 

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

func (*ExecuteWorkflowInstanceResponse) Validate added in v0.13.2 

func (m *ExecuteWorkflowInstanceResponse) Validate() error

func (*ExecuteWorkflowInstanceResponse) ValidateE added in v0.13.2 

func (m *ExecuteWorkflowInstanceResponse) ValidateE(prefix string) error

func (*ExecuteWorkflowInstanceResponse) XSize added in v0.13.2 

func (m *ExecuteWorkflowInstanceResponse) XSize() (n int)

func (*ExecuteWorkflowInstanceResponse) XXX_DiscardUnknown added in v0.13.2 

func (m *ExecuteWorkflowInstanceResponse) XXX_DiscardUnknown()

func (*ExecuteWorkflowInstanceResponse) XXX_Marshal added in v0.13.2 

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

func (*ExecuteWorkflowInstanceResponse) XXX_Merge added in v0.13.2 

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

func (*ExecuteWorkflowInstanceResponse) XXX_Size added in v0.13.2 

func (m *ExecuteWorkflowInstanceResponse) XXX_Size() int

func (*ExecuteWorkflowInstanceResponse) XXX_Unmarshal added in v0.13.2 

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

type FlowRpcClient 

type FlowRpcClient interface {
	ListWorker(ctx context.Context, in *ListWorkerRequest, opts ...grpc.CallOption) (*ListWorkerResponse, error)
	GetWorker(ctx context.Context, in *GetWorkerRequest, opts ...grpc.CallOption) (*GetWorkerResponse, error)
	ListRegistry(ctx context.Context, in *ListRegistryRequest, opts ...grpc.CallOption) (*ListRegistryResponse, error)
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	WorkHook(ctx context.Context, in *WorkHookRequest, opts ...grpc.CallOption) (FlowRpc_WorkHookClient, error)
	Call(ctx context.Context, in *CallRequest, opts ...grpc.CallOption) (*CallResponse, error)
	Step(ctx context.Context, in *StepRequest, opts ...grpc.CallOption) (*StepResponse, error)
	Pipe(ctx context.Context, opts ...grpc.CallOption) (FlowRpc_PipeClient, error)
	ExecuteWorkflowInstance(ctx context.Context, in *ExecuteWorkflowInstanceRequest, opts ...grpc.CallOption) (FlowRpc_ExecuteWorkflowInstanceClient, error)
	ListWorkflowInstance(ctx context.Context, in *ListWorkflowInstanceRequest, opts ...grpc.CallOption) (*ListWorkflowInstanceResponse, error)
	InspectWorkflowInstance(ctx context.Context, in *InspectWorkflowInstanceRequest, opts ...grpc.CallOption) (*InspectWorkflowInstanceResponse, error)
	AbortWorkflowInstance(ctx context.Context, in *AbortWorkflowInstanceRequest, opts ...grpc.CallOption) (*AbortWorkflowInstanceResponse, error)
	PauseWorkflowInstance(ctx context.Context, in *PauseWorkflowInstanceRequest, opts ...grpc.CallOption) (*PauseWorkflowInstanceResponse, error)
	ResumeWorkflowInstance(ctx context.Context, in *ResumeWorkflowInstanceRequest, opts ...grpc.CallOption) (*ResumeWorkflowInstanceResponse, error)
	HandleServiceErr(ctx context.Context, in *HandleServiceErrRequest, opts ...grpc.CallOption) (*HandleServiceErrResponse, error)
	ListInteractive(ctx context.Context, in *ListInteractiveRequest, opts ...grpc.CallOption) (*ListInteractiveResponse, error)
	CommitInteractive(ctx context.Context, in *CommitInteractiveRequest, opts ...grpc.CallOption) (*CommitInteractiveResponse, error)
	WatchWorkflowInstance(ctx context.Context, in *WatchWorkflowInstanceRequest, opts ...grpc.CallOption) (FlowRpc_WatchWorkflowInstanceClient, error)
	StepGet(ctx context.Context, in *StepGetRequest, opts ...grpc.CallOption) (*StepGetResponse, error)
	StepPut(ctx context.Context, in *StepPutRequest, opts ...grpc.CallOption) (*StepPutResponse, error)
	StepTrace(ctx context.Context, in *StepTraceRequest, opts ...grpc.CallOption) (*StepTraceResponse, error)
}

FlowRpcClient is the client API for FlowRpc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFlowRpcClient 

func NewFlowRpcClient(cc *grpc.ClientConn) FlowRpcClient

type FlowRpcHandler 

type FlowRpcHandler interface {
	ListWorker(context.Context, *ListWorkerRequest, *ListWorkerResponse) error
	GetWorker(context.Context, *GetWorkerRequest, *GetWorkerResponse) error
	ListRegistry(context.Context, *ListRegistryRequest, *ListRegistryResponse) error
	Register(context.Context, *RegisterRequest, *RegisterResponse) error
	WorkHook(context.Context, *WorkHookRequest, FlowRpc_WorkHookStream) error
	Call(context.Context, *CallRequest, *CallResponse) error
	Step(context.Context, *StepRequest, *StepResponse) error
	Pipe(context.Context, FlowRpc_PipeStream) error
	ExecuteWorkflowInstance(context.Context, *ExecuteWorkflowInstanceRequest, FlowRpc_ExecuteWorkflowInstanceStream) error
	ListWorkflowInstance(context.Context, *ListWorkflowInstanceRequest, *ListWorkflowInstanceResponse) error
	InspectWorkflowInstance(context.Context, *InspectWorkflowInstanceRequest, *InspectWorkflowInstanceResponse) error
	AbortWorkflowInstance(context.Context, *AbortWorkflowInstanceRequest, *AbortWorkflowInstanceResponse) error
	PauseWorkflowInstance(context.Context, *PauseWorkflowInstanceRequest, *PauseWorkflowInstanceResponse) error
	ResumeWorkflowInstance(context.Context, *ResumeWorkflowInstanceRequest, *ResumeWorkflowInstanceResponse) error
	HandleServiceErr(context.Context, *HandleServiceErrRequest, *HandleServiceErrResponse) error
	ListInteractive(context.Context, *ListInteractiveRequest, *ListInteractiveResponse) error
	CommitInteractive(context.Context, *CommitInteractiveRequest, *CommitInteractiveResponse) error
	WatchWorkflowInstance(context.Context, *WatchWorkflowInstanceRequest, FlowRpc_WatchWorkflowInstanceStream) error
	StepGet(context.Context, *StepGetRequest, *StepGetResponse) error
	StepPut(context.Context, *StepPutRequest, *StepPutResponse) error
	StepTrace(context.Context, *StepTraceRequest, *StepTraceResponse) error
}

Server API for FlowRpc service

type FlowRpcServer 

type FlowRpcServer interface {
	ListWorker(context.Context, *ListWorkerRequest) (*ListWorkerResponse, error)
	GetWorker(context.Context, *GetWorkerRequest) (*GetWorkerResponse, error)
	ListRegistry(context.Context, *ListRegistryRequest) (*ListRegistryResponse, error)
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	WorkHook(*WorkHookRequest, FlowRpc_WorkHookServer) error
	Call(context.Context, *CallRequest) (*CallResponse, error)
	Step(context.Context, *StepRequest) (*StepResponse, error)
	Pipe(FlowRpc_PipeServer) error
	ExecuteWorkflowInstance(*ExecuteWorkflowInstanceRequest, FlowRpc_ExecuteWorkflowInstanceServer) error
	ListWorkflowInstance(context.Context, *ListWorkflowInstanceRequest) (*ListWorkflowInstanceResponse, error)
	InspectWorkflowInstance(context.Context, *InspectWorkflowInstanceRequest) (*InspectWorkflowInstanceResponse, error)
	AbortWorkflowInstance(context.Context, *AbortWorkflowInstanceRequest) (*AbortWorkflowInstanceResponse, error)
	PauseWorkflowInstance(context.Context, *PauseWorkflowInstanceRequest) (*PauseWorkflowInstanceResponse, error)
	ResumeWorkflowInstance(context.Context, *ResumeWorkflowInstanceRequest) (*ResumeWorkflowInstanceResponse, error)
	HandleServiceErr(context.Context, *HandleServiceErrRequest) (*HandleServiceErrResponse, error)
	ListInteractive(context.Context, *ListInteractiveRequest) (*ListInteractiveResponse, error)
	CommitInteractive(context.Context, *CommitInteractiveRequest) (*CommitInteractiveResponse, error)
	WatchWorkflowInstance(*WatchWorkflowInstanceRequest, FlowRpc_WatchWorkflowInstanceServer) error
	StepGet(context.Context, *StepGetRequest) (*StepGetResponse, error)
	StepPut(context.Context, *StepPutRequest) (*StepPutResponse, error)
	StepTrace(context.Context, *StepTraceRequest) (*StepTraceResponse, error)
}

FlowRpcServer is the server API for FlowRpc service.

type FlowRpcService 

type FlowRpcService interface {
	ListWorker(ctx context.Context, in *ListWorkerRequest, opts ...client.CallOption) (*ListWorkerResponse, error)
	GetWorker(ctx context.Context, in *GetWorkerRequest, opts ...client.CallOption) (*GetWorkerResponse, error)
	ListRegistry(ctx context.Context, in *ListRegistryRequest, opts ...client.CallOption) (*ListRegistryResponse, error)
	Register(ctx context.Context, in *RegisterRequest, opts ...client.CallOption) (*RegisterResponse, error)
	WorkHook(ctx context.Context, in *WorkHookRequest, opts ...client.CallOption) (FlowRpc_WorkHookService, error)
	Call(ctx context.Context, in *CallRequest, opts ...client.CallOption) (*CallResponse, error)
	Step(ctx context.Context, in *StepRequest, opts ...client.CallOption) (*StepResponse, error)
	Pipe(ctx context.Context, opts ...client.CallOption) (FlowRpc_PipeService, error)
	ExecuteWorkflowInstance(ctx context.Context, in *ExecuteWorkflowInstanceRequest, opts ...client.CallOption) (FlowRpc_ExecuteWorkflowInstanceService, error)
	ListWorkflowInstance(ctx context.Context, in *ListWorkflowInstanceRequest, opts ...client.CallOption) (*ListWorkflowInstanceResponse, error)
	InspectWorkflowInstance(ctx context.Context, in *InspectWorkflowInstanceRequest, opts ...client.CallOption) (*InspectWorkflowInstanceResponse, error)
	AbortWorkflowInstance(ctx context.Context, in *AbortWorkflowInstanceRequest, opts ...client.CallOption) (*AbortWorkflowInstanceResponse, error)
	PauseWorkflowInstance(ctx context.Context, in *PauseWorkflowInstanceRequest, opts ...client.CallOption) (*PauseWorkflowInstanceResponse, error)
	ResumeWorkflowInstance(ctx context.Context, in *ResumeWorkflowInstanceRequest, opts ...client.CallOption) (*ResumeWorkflowInstanceResponse, error)
	HandleServiceErr(ctx context.Context, in *HandleServiceErrRequest, opts ...client.CallOption) (*HandleServiceErrResponse, error)
	ListInteractive(ctx context.Context, in *ListInteractiveRequest, opts ...client.CallOption) (*ListInteractiveResponse, error)
	CommitInteractive(ctx context.Context, in *CommitInteractiveRequest, opts ...client.CallOption) (*CommitInteractiveResponse, error)
	WatchWorkflowInstance(ctx context.Context, in *WatchWorkflowInstanceRequest, opts ...client.CallOption) (FlowRpc_WatchWorkflowInstanceService, error)
	StepGet(ctx context.Context, in *StepGetRequest, opts ...client.CallOption) (*StepGetResponse, error)
	StepPut(ctx context.Context, in *StepPutRequest, opts ...client.CallOption) (*StepPutResponse, error)
	StepTrace(ctx context.Context, in *StepTraceRequest, opts ...client.CallOption) (*StepTraceResponse, error)
}

Client API for FlowRpc service

func NewFlowRpcService 

func NewFlowRpcService(name string, c client.Client) FlowRpcService

type FlowRpc_ExecuteWorkflowInstanceClient added in v0.13.2 

type FlowRpc_ExecuteWorkflowInstanceClient interface {
	Recv() (*ExecuteWorkflowInstanceResponse, error)
	grpc.ClientStream
}

type FlowRpc_ExecuteWorkflowInstanceServer added in v0.13.2 

type FlowRpc_ExecuteWorkflowInstanceServer interface {
	Send(*ExecuteWorkflowInstanceResponse) error
	grpc.ServerStream
}

type FlowRpc_ExecuteWorkflowInstanceService added in v0.13.2 

type FlowRpc_ExecuteWorkflowInstanceService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*ExecuteWorkflowInstanceResponse, error)
}

type FlowRpc_ExecuteWorkflowInstanceStream added in v0.13.2 

type FlowRpc_ExecuteWorkflowInstanceStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*ExecuteWorkflowInstanceResponse) error
}

type FlowRpc_PipeClient 

type FlowRpc_PipeClient interface {
	Send(*PipeRequest) error
	Recv() (*PipeResponse, error)
	grpc.ClientStream
}

type FlowRpc_PipeServer 

type FlowRpc_PipeServer interface {
	Send(*PipeResponse) error
	Recv() (*PipeRequest, error)
	grpc.ServerStream
}

type FlowRpc_PipeService 

type FlowRpc_PipeService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*PipeRequest) error
	Recv() (*PipeResponse, error)
}

type FlowRpc_PipeStream 

type FlowRpc_PipeStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*PipeResponse) error
	Recv() (*PipeRequest, error)
}

type FlowRpc_WatchWorkflowInstanceClient added in v0.10.0 

type FlowRpc_WatchWorkflowInstanceClient interface {
	Recv() (*WatchWorkflowInstanceResponse, error)
	grpc.ClientStream
}

type FlowRpc_WatchWorkflowInstanceServer added in v0.10.0 

type FlowRpc_WatchWorkflowInstanceServer interface {
	Send(*WatchWorkflowInstanceResponse) error
	grpc.ServerStream
}

type FlowRpc_WatchWorkflowInstanceService added in v0.10.0 

type FlowRpc_WatchWorkflowInstanceService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*WatchWorkflowInstanceResponse, error)
}

type FlowRpc_WatchWorkflowInstanceStream added in v0.10.0 

type FlowRpc_WatchWorkflowInstanceStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*WatchWorkflowInstanceResponse) error
}

type FlowRpc_WorkHookClient added in v0.12.2 

type FlowRpc_WorkHookClient interface {
	Recv() (*WorkHookResponse, error)
	grpc.ClientStream
}

type FlowRpc_WorkHookServer added in v0.12.2 

type FlowRpc_WorkHookServer interface {
	Send(*WorkHookResponse) error
	grpc.ServerStream
}

type FlowRpc_WorkHookService added in v0.12.2 

type FlowRpc_WorkHookService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*WorkHookResponse, error)
}

type FlowRpc_WorkHookStream added in v0.12.2 

type FlowRpc_WorkHookStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*WorkHookResponse) error
}

type GetWorkerRequest added in v0.12.2 

type GetWorkerRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*GetWorkerRequest) Descriptor added in v0.12.2 

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

func (*GetWorkerRequest) Marshal added in v0.12.2 

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

func (*GetWorkerRequest) MarshalTo added in v0.12.2 

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

func (*GetWorkerRequest) MarshalToSizedBuffer added in v0.12.2 

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

func (*GetWorkerRequest) ProtoMessage added in v0.12.2 

func (*GetWorkerRequest) ProtoMessage()

func (*GetWorkerRequest) Reset added in v0.12.2 

func (m *GetWorkerRequest) Reset()

func (*GetWorkerRequest) String added in v0.12.2 

func (m *GetWorkerRequest) String() string

func (*GetWorkerRequest) Unmarshal added in v0.12.2 

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

func (*GetWorkerRequest) Validate added in v0.12.2 

func (m *GetWorkerRequest) Validate() error

func (*GetWorkerRequest) ValidateE added in v0.12.2 

func (m *GetWorkerRequest) ValidateE(prefix string) error

func (*GetWorkerRequest) XSize added in v0.12.2 

func (m *GetWorkerRequest) XSize() (n int)

func (*GetWorkerRequest) XXX_DiscardUnknown added in v0.12.2 

func (m *GetWorkerRequest) XXX_DiscardUnknown()

func (*GetWorkerRequest) XXX_Marshal added in v0.12.2 

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

func (*GetWorkerRequest) XXX_Merge added in v0.12.2 

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

func (*GetWorkerRequest) XXX_Size added in v0.12.2 

func (m *GetWorkerRequest) XXX_Size() int

func (*GetWorkerRequest) XXX_Unmarshal added in v0.12.2 

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

type GetWorkerResponse added in v0.12.2 

type GetWorkerResponse struct {
	Worker *Worker `protobuf:"bytes,1,opt,name=worker,proto3" json:"worker,omitempty"`
}

func (*GetWorkerResponse) Descriptor added in v0.12.2 

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

func (*GetWorkerResponse) Marshal added in v0.12.2 

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

func (*GetWorkerResponse) MarshalTo added in v0.12.2 

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

func (*GetWorkerResponse) MarshalToSizedBuffer added in v0.12.2 

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

func (*GetWorkerResponse) ProtoMessage added in v0.12.2 

func (*GetWorkerResponse) ProtoMessage()

func (*GetWorkerResponse) Reset added in v0.12.2 

func (m *GetWorkerResponse) Reset()

func (*GetWorkerResponse) String added in v0.12.2 

func (m *GetWorkerResponse) String() string

func (*GetWorkerResponse) Unmarshal added in v0.12.2 

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

func (*GetWorkerResponse) Validate added in v0.12.2 

func (m *GetWorkerResponse) Validate() error

func (*GetWorkerResponse) ValidateE added in v0.12.2 

func (m *GetWorkerResponse) ValidateE(prefix string) error

func (*GetWorkerResponse) XSize added in v0.12.2 

func (m *GetWorkerResponse) XSize() (n int)

func (*GetWorkerResponse) XXX_DiscardUnknown added in v0.12.2 

func (m *GetWorkerResponse) XXX_DiscardUnknown()

func (*GetWorkerResponse) XXX_Marshal added in v0.12.2 

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

func (*GetWorkerResponse) XXX_Merge added in v0.12.2 

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

func (*GetWorkerResponse) XXX_Size added in v0.12.2 

func (m *GetWorkerResponse) XXX_Size() int

func (*GetWorkerResponse) XXX_Unmarshal added in v0.12.2 

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

type HandleServiceErrRequest added in v0.14.0 

type HandleServiceErrRequest struct {
	Req *ErrHandleRequest `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"`
}

func (*HandleServiceErrRequest) Descriptor added in v0.14.0 

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

func (*HandleServiceErrRequest) Marshal added in v0.14.0 

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

func (*HandleServiceErrRequest) MarshalTo added in v0.14.0 

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

func (*HandleServiceErrRequest) MarshalToSizedBuffer added in v0.14.0 

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

func (*HandleServiceErrRequest) ProtoMessage added in v0.14.0 

func (*HandleServiceErrRequest) ProtoMessage()

func (*HandleServiceErrRequest) Reset added in v0.14.0 

func (m *HandleServiceErrRequest) Reset()

func (*HandleServiceErrRequest) String added in v0.14.0 

func (m *HandleServiceErrRequest) String() string

func (*HandleServiceErrRequest) Unmarshal added in v0.14.0 

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

func (*HandleServiceErrRequest) Validate added in v0.14.0 

func (m *HandleServiceErrRequest) Validate() error

func (*HandleServiceErrRequest) ValidateE added in v0.14.0 

func (m *HandleServiceErrRequest) ValidateE(prefix string) error

func (*HandleServiceErrRequest) XSize added in v0.14.0 

func (m *HandleServiceErrRequest) XSize() (n int)

func (*HandleServiceErrRequest) XXX_DiscardUnknown added in v0.14.0 

func (m *HandleServiceErrRequest) XXX_DiscardUnknown()

func (*HandleServiceErrRequest) XXX_Marshal added in v0.14.0 

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

func (*HandleServiceErrRequest) XXX_Merge added in v0.14.0 

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

func (*HandleServiceErrRequest) XXX_Size added in v0.14.0 

func (m *HandleServiceErrRequest) XXX_Size() int

func (*HandleServiceErrRequest) XXX_Unmarshal added in v0.14.0 

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

type HandleServiceErrResponse added in v0.14.0 

type HandleServiceErrResponse struct {
}

func (*HandleServiceErrResponse) Descriptor added in v0.14.0 

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

func (*HandleServiceErrResponse) Marshal added in v0.14.0 

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

func (*HandleServiceErrResponse) MarshalTo added in v0.14.0 

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

func (*HandleServiceErrResponse) MarshalToSizedBuffer added in v0.14.0 

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

func (*HandleServiceErrResponse) ProtoMessage added in v0.14.0 

func (*HandleServiceErrResponse) ProtoMessage()

func (*HandleServiceErrResponse) Reset added in v0.14.0 

func (m *HandleServiceErrResponse) Reset()

func (*HandleServiceErrResponse) String added in v0.14.0 

func (m *HandleServiceErrResponse) String() string

func (*HandleServiceErrResponse) Unmarshal added in v0.14.0 

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

func (*HandleServiceErrResponse) Validate added in v0.14.0 

func (m *HandleServiceErrResponse) Validate() error

func (*HandleServiceErrResponse) ValidateE added in v0.14.0 

func (m *HandleServiceErrResponse) ValidateE(prefix string) error

func (*HandleServiceErrResponse) XSize added in v0.14.0 

func (m *HandleServiceErrResponse) XSize() (n int)

func (*HandleServiceErrResponse) XXX_DiscardUnknown added in v0.14.0 

func (m *HandleServiceErrResponse) XXX_DiscardUnknown()

func (*HandleServiceErrResponse) XXX_Marshal added in v0.14.0 

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

func (*HandleServiceErrResponse) XXX_Merge added in v0.14.0 

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

func (*HandleServiceErrResponse) XXX_Size added in v0.14.0 

func (m *HandleServiceErrResponse) XXX_Size() int

func (*HandleServiceErrResponse) XXX_Unmarshal added in v0.14.0 

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

type HookAction added in v0.12.2 

type HookAction int32
const (
	HookAction_HA_UNKNOWN HookAction = 0
	HookAction_HA_UP      HookAction = 1
	HookAction_HA_DOWN    HookAction = 2
)

func (HookAction) EnumDescriptor added in v0.12.2 

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

func (HookAction) String added in v0.12.2 

func (x HookAction) String() string

type InspectWorkflowInstanceRequest added in v0.10.0 

type InspectWorkflowInstanceRequest struct {
	// +gen:required
	Wid string `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
}

func (*InspectWorkflowInstanceRequest) Descriptor added in v0.10.0 

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

func (*InspectWorkflowInstanceRequest) Marshal added in v0.10.0 

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

func (*InspectWorkflowInstanceRequest) MarshalTo added in v0.10.0 

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

func (*InspectWorkflowInstanceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*InspectWorkflowInstanceRequest) ProtoMessage added in v0.10.0 

func (*InspectWorkflowInstanceRequest) ProtoMessage()

func (*InspectWorkflowInstanceRequest) Reset added in v0.10.0 

func (m *InspectWorkflowInstanceRequest) Reset()

func (*InspectWorkflowInstanceRequest) String added in v0.10.0 

func (m *InspectWorkflowInstanceRequest) String() string

func (*InspectWorkflowInstanceRequest) Unmarshal added in v0.10.0 

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

func (*InspectWorkflowInstanceRequest) Validate added in v0.10.0 

func (m *InspectWorkflowInstanceRequest) Validate() error

func (*InspectWorkflowInstanceRequest) ValidateE added in v0.10.0 

func (m *InspectWorkflowInstanceRequest) ValidateE(prefix string) error

func (*InspectWorkflowInstanceRequest) XSize added in v0.10.0 

func (m *InspectWorkflowInstanceRequest) XSize() (n int)

func (*InspectWorkflowInstanceRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *InspectWorkflowInstanceRequest) XXX_DiscardUnknown()

func (*InspectWorkflowInstanceRequest) XXX_Marshal added in v0.10.0 

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

func (*InspectWorkflowInstanceRequest) XXX_Merge added in v0.10.0 

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

func (*InspectWorkflowInstanceRequest) XXX_Size added in v0.10.0 

func (m *InspectWorkflowInstanceRequest) XXX_Size() int

func (*InspectWorkflowInstanceRequest) XXX_Unmarshal added in v0.10.0 

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

type InspectWorkflowInstanceResponse added in v0.10.0 

type InspectWorkflowInstanceResponse struct {
	Workflow *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
}

func (*InspectWorkflowInstanceResponse) Descriptor added in v0.10.0 

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

func (*InspectWorkflowInstanceResponse) Marshal added in v0.10.0 

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

func (*InspectWorkflowInstanceResponse) MarshalTo added in v0.10.0 

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

func (*InspectWorkflowInstanceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*InspectWorkflowInstanceResponse) ProtoMessage added in v0.10.0 

func (*InspectWorkflowInstanceResponse) ProtoMessage()

func (*InspectWorkflowInstanceResponse) Reset added in v0.10.0 

func (m *InspectWorkflowInstanceResponse) Reset()

func (*InspectWorkflowInstanceResponse) String added in v0.10.0 

func (m *InspectWorkflowInstanceResponse) String() string

func (*InspectWorkflowInstanceResponse) Unmarshal added in v0.10.0 

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

func (*InspectWorkflowInstanceResponse) Validate added in v0.10.0 

func (m *InspectWorkflowInstanceResponse) Validate() error

func (*InspectWorkflowInstanceResponse) ValidateE added in v0.10.0 

func (m *InspectWorkflowInstanceResponse) ValidateE(prefix string) error

func (*InspectWorkflowInstanceResponse) XSize added in v0.10.0 

func (m *InspectWorkflowInstanceResponse) XSize() (n int)

func (*InspectWorkflowInstanceResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *InspectWorkflowInstanceResponse) XXX_DiscardUnknown()

func (*InspectWorkflowInstanceResponse) XXX_Marshal added in v0.10.0 

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

func (*InspectWorkflowInstanceResponse) XXX_Merge added in v0.10.0 

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

func (*InspectWorkflowInstanceResponse) XXX_Size added in v0.10.0 

func (m *InspectWorkflowInstanceResponse) XXX_Size() int

func (*InspectWorkflowInstanceResponse) XXX_Unmarshal added in v0.10.0 

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

type Interactive added in v0.10.0 

type Interactive struct {
	Pid        string      `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Sid        string      `protobuf:"bytes,2,opt,name=sid,proto3" json:"sid,omitempty"`
	Describe   string      `protobuf:"bytes,3,opt,name=describe,proto3" json:"describe,omitempty"`
	Properties []*Property `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
}

func (*Interactive) DeepCopyInto added in v0.10.0 

func (in *Interactive) DeepCopyInto(out *Interactive)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Interactive) Descriptor added in v0.10.0 

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

func (*Interactive) Marshal added in v0.10.0 

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

func (*Interactive) MarshalTo added in v0.10.0 

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

func (*Interactive) MarshalToSizedBuffer added in v0.10.0 

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

func (*Interactive) ProtoMessage added in v0.10.0 

func (*Interactive) ProtoMessage()

func (*Interactive) Reset added in v0.10.0 

func (m *Interactive) Reset()

func (*Interactive) String added in v0.10.0 

func (m *Interactive) String() string

func (*Interactive) Unmarshal added in v0.10.0 

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

func (*Interactive) Validate added in v0.10.0 

func (m *Interactive) Validate() error

func (*Interactive) ValidateE added in v0.10.0 

func (m *Interactive) ValidateE(prefix string) error

func (*Interactive) XSize added in v0.10.0 

func (m *Interactive) XSize() (n int)

func (*Interactive) XXX_DiscardUnknown added in v0.10.0 

func (m *Interactive) XXX_DiscardUnknown()

func (*Interactive) XXX_Marshal added in v0.10.0 

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

func (*Interactive) XXX_Merge added in v0.10.0 

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

func (*Interactive) XXX_Size added in v0.10.0 

func (m *Interactive) XXX_Size() int

func (*Interactive) XXX_Unmarshal added in v0.10.0 

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

type ListInteractiveRequest added in v0.10.0 

type ListInteractiveRequest struct {
	Pid string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
}

func (*ListInteractiveRequest) Descriptor added in v0.10.0 

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

func (*ListInteractiveRequest) Marshal added in v0.10.0 

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

func (*ListInteractiveRequest) MarshalTo added in v0.10.0 

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

func (*ListInteractiveRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ListInteractiveRequest) ProtoMessage added in v0.10.0 

func (*ListInteractiveRequest) ProtoMessage()

func (*ListInteractiveRequest) Reset added in v0.10.0 

func (m *ListInteractiveRequest) Reset()

func (*ListInteractiveRequest) String added in v0.10.0 

func (m *ListInteractiveRequest) String() string

func (*ListInteractiveRequest) Unmarshal added in v0.10.0 

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

func (*ListInteractiveRequest) Validate added in v0.10.0 

func (m *ListInteractiveRequest) Validate() error

func (*ListInteractiveRequest) ValidateE added in v0.10.0 

func (m *ListInteractiveRequest) ValidateE(prefix string) error

func (*ListInteractiveRequest) XSize added in v0.10.0 

func (m *ListInteractiveRequest) XSize() (n int)

func (*ListInteractiveRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *ListInteractiveRequest) XXX_DiscardUnknown()

func (*ListInteractiveRequest) XXX_Marshal added in v0.10.0 

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

func (*ListInteractiveRequest) XXX_Merge added in v0.10.0 

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

func (*ListInteractiveRequest) XXX_Size added in v0.10.0 

func (m *ListInteractiveRequest) XXX_Size() int

func (*ListInteractiveRequest) XXX_Unmarshal added in v0.10.0 

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

type ListInteractiveResponse added in v0.10.0 

type ListInteractiveResponse struct {
	Interactive []*Interactive `protobuf:"bytes,1,rep,name=interactive,proto3" json:"interactive,omitempty"`
}

func (*ListInteractiveResponse) Descriptor added in v0.10.0 

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

func (*ListInteractiveResponse) Marshal added in v0.10.0 

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

func (*ListInteractiveResponse) MarshalTo added in v0.10.0 

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

func (*ListInteractiveResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ListInteractiveResponse) ProtoMessage added in v0.10.0 

func (*ListInteractiveResponse) ProtoMessage()

func (*ListInteractiveResponse) Reset added in v0.10.0 

func (m *ListInteractiveResponse) Reset()

func (*ListInteractiveResponse) String added in v0.10.0 

func (m *ListInteractiveResponse) String() string

func (*ListInteractiveResponse) Unmarshal added in v0.10.0 

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

func (*ListInteractiveResponse) Validate added in v0.10.0 

func (m *ListInteractiveResponse) Validate() error

func (*ListInteractiveResponse) ValidateE added in v0.10.0 

func (m *ListInteractiveResponse) ValidateE(prefix string) error

func (*ListInteractiveResponse) XSize added in v0.10.0 

func (m *ListInteractiveResponse) XSize() (n int)

func (*ListInteractiveResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *ListInteractiveResponse) XXX_DiscardUnknown()

func (*ListInteractiveResponse) XXX_Marshal added in v0.10.0 

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

func (*ListInteractiveResponse) XXX_Merge added in v0.10.0 

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

func (*ListInteractiveResponse) XXX_Size added in v0.10.0 

func (m *ListInteractiveResponse) XXX_Size() int

func (*ListInteractiveResponse) XXX_Unmarshal added in v0.10.0 

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

type ListRegistryRequest added in v0.2.0 

type ListRegistryRequest struct {
}

func (*ListRegistryRequest) Descriptor added in v0.2.0 

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

func (*ListRegistryRequest) Marshal added in v0.2.0 

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

func (*ListRegistryRequest) MarshalTo added in v0.2.0 

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

func (*ListRegistryRequest) MarshalToSizedBuffer added in v0.2.0 

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

func (*ListRegistryRequest) ProtoMessage added in v0.2.0 

func (*ListRegistryRequest) ProtoMessage()

func (*ListRegistryRequest) Reset added in v0.2.0 

func (m *ListRegistryRequest) Reset()

func (*ListRegistryRequest) String added in v0.2.0 

func (m *ListRegistryRequest) String() string

func (*ListRegistryRequest) Unmarshal added in v0.2.0 

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

func (*ListRegistryRequest) Validate added in v0.2.0 

func (m *ListRegistryRequest) Validate() error

func (*ListRegistryRequest) ValidateE added in v0.2.0 

func (m *ListRegistryRequest) ValidateE(prefix string) error

func (*ListRegistryRequest) XSize added in v0.2.0 

func (m *ListRegistryRequest) XSize() (n int)

func (*ListRegistryRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *ListRegistryRequest) XXX_DiscardUnknown()

func (*ListRegistryRequest) XXX_Marshal added in v0.2.0 

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

func (*ListRegistryRequest) XXX_Merge added in v0.2.0 

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

func (*ListRegistryRequest) XXX_Size added in v0.2.0 

func (m *ListRegistryRequest) XXX_Size() int

func (*ListRegistryRequest) XXX_Unmarshal added in v0.2.0 

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

type ListRegistryResponse added in v0.2.0 

type ListRegistryResponse struct {
	Entities []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	Echoes   []*Echo   `protobuf:"bytes,2,rep,name=echoes,proto3" json:"echoes,omitempty"`
	Steps    []*Step   `protobuf:"bytes,3,rep,name=steps,proto3" json:"steps,omitempty"`
}

func (*ListRegistryResponse) Descriptor added in v0.2.0 

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

func (*ListRegistryResponse) Marshal added in v0.2.0 

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

func (*ListRegistryResponse) MarshalTo added in v0.2.0 

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

func (*ListRegistryResponse) MarshalToSizedBuffer added in v0.2.0 

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

func (*ListRegistryResponse) ProtoMessage added in v0.2.0 

func (*ListRegistryResponse) ProtoMessage()

func (*ListRegistryResponse) Reset added in v0.2.0 

func (m *ListRegistryResponse) Reset()

func (*ListRegistryResponse) String added in v0.2.0 

func (m *ListRegistryResponse) String() string

func (*ListRegistryResponse) Unmarshal added in v0.2.0 

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

func (*ListRegistryResponse) Validate added in v0.2.0 

func (m *ListRegistryResponse) Validate() error

func (*ListRegistryResponse) ValidateE added in v0.2.0 

func (m *ListRegistryResponse) ValidateE(prefix string) error

func (*ListRegistryResponse) XSize added in v0.2.0 

func (m *ListRegistryResponse) XSize() (n int)

func (*ListRegistryResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *ListRegistryResponse) XXX_DiscardUnknown()

func (*ListRegistryResponse) XXX_Marshal added in v0.2.0 

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

func (*ListRegistryResponse) XXX_Merge added in v0.2.0 

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

func (*ListRegistryResponse) XXX_Size added in v0.2.0 

func (m *ListRegistryResponse) XXX_Size() int

func (*ListRegistryResponse) XXX_Unmarshal added in v0.2.0 

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

type ListWorkerRequest added in v0.2.0 

type ListWorkerRequest struct {
}

func (*ListWorkerRequest) Descriptor added in v0.2.0 

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

func (*ListWorkerRequest) Marshal added in v0.2.0 

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

func (*ListWorkerRequest) MarshalTo added in v0.2.0 

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

func (*ListWorkerRequest) MarshalToSizedBuffer added in v0.2.0 

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

func (*ListWorkerRequest) ProtoMessage added in v0.2.0 

func (*ListWorkerRequest) ProtoMessage()

func (*ListWorkerRequest) Reset added in v0.2.0 

func (m *ListWorkerRequest) Reset()

func (*ListWorkerRequest) String added in v0.2.0 

func (m *ListWorkerRequest) String() string

func (*ListWorkerRequest) Unmarshal added in v0.2.0 

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

func (*ListWorkerRequest) Validate added in v0.2.0 

func (m *ListWorkerRequest) Validate() error

func (*ListWorkerRequest) ValidateE added in v0.2.0 

func (m *ListWorkerRequest) ValidateE(prefix string) error

func (*ListWorkerRequest) XSize added in v0.2.0 

func (m *ListWorkerRequest) XSize() (n int)

func (*ListWorkerRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *ListWorkerRequest) XXX_DiscardUnknown()

func (*ListWorkerRequest) XXX_Marshal added in v0.2.0 

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

func (*ListWorkerRequest) XXX_Merge added in v0.2.0 

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

func (*ListWorkerRequest) XXX_Size added in v0.2.0 

func (m *ListWorkerRequest) XXX_Size() int

func (*ListWorkerRequest) XXX_Unmarshal added in v0.2.0 

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

type ListWorkerResponse added in v0.2.0 

type ListWorkerResponse struct {
	Workers []*Worker `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
}

func (*ListWorkerResponse) Descriptor added in v0.2.0 

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

func (*ListWorkerResponse) Marshal added in v0.2.0 

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

func (*ListWorkerResponse) MarshalTo added in v0.2.0 

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

func (*ListWorkerResponse) MarshalToSizedBuffer added in v0.2.0 

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

func (*ListWorkerResponse) ProtoMessage added in v0.2.0 

func (*ListWorkerResponse) ProtoMessage()

func (*ListWorkerResponse) Reset added in v0.2.0 

func (m *ListWorkerResponse) Reset()

func (*ListWorkerResponse) String added in v0.2.0 

func (m *ListWorkerResponse) String() string

func (*ListWorkerResponse) Unmarshal added in v0.2.0 

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

func (*ListWorkerResponse) Validate added in v0.2.0 

func (m *ListWorkerResponse) Validate() error

func (*ListWorkerResponse) ValidateE added in v0.2.0 

func (m *ListWorkerResponse) ValidateE(prefix string) error

func (*ListWorkerResponse) XSize added in v0.2.0 

func (m *ListWorkerResponse) XSize() (n int)

func (*ListWorkerResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *ListWorkerResponse) XXX_DiscardUnknown()

func (*ListWorkerResponse) XXX_Marshal added in v0.2.0 

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

func (*ListWorkerResponse) XXX_Merge added in v0.2.0 

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

func (*ListWorkerResponse) XXX_Size added in v0.2.0 

func (m *ListWorkerResponse) XXX_Size() int

func (*ListWorkerResponse) XXX_Unmarshal added in v0.2.0 

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

type ListWorkflowInstanceRequest added in v0.10.0 

type ListWorkflowInstanceRequest struct {
}

func (*ListWorkflowInstanceRequest) Descriptor added in v0.10.0 

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

func (*ListWorkflowInstanceRequest) Marshal added in v0.10.0 

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

func (*ListWorkflowInstanceRequest) MarshalTo added in v0.10.0 

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

func (*ListWorkflowInstanceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ListWorkflowInstanceRequest) ProtoMessage added in v0.10.0 

func (*ListWorkflowInstanceRequest) ProtoMessage()

func (*ListWorkflowInstanceRequest) Reset added in v0.10.0 

func (m *ListWorkflowInstanceRequest) Reset()

func (*ListWorkflowInstanceRequest) String added in v0.10.0 

func (m *ListWorkflowInstanceRequest) String() string

func (*ListWorkflowInstanceRequest) Unmarshal added in v0.10.0 

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

func (*ListWorkflowInstanceRequest) Validate added in v0.10.0 

func (m *ListWorkflowInstanceRequest) Validate() error

func (*ListWorkflowInstanceRequest) ValidateE added in v0.10.0 

func (m *ListWorkflowInstanceRequest) ValidateE(prefix string) error

func (*ListWorkflowInstanceRequest) XSize added in v0.10.0 

func (m *ListWorkflowInstanceRequest) XSize() (n int)

func (*ListWorkflowInstanceRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *ListWorkflowInstanceRequest) XXX_DiscardUnknown()

func (*ListWorkflowInstanceRequest) XXX_Marshal added in v0.10.0 

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

func (*ListWorkflowInstanceRequest) XXX_Merge added in v0.10.0 

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

func (*ListWorkflowInstanceRequest) XXX_Size added in v0.10.0 

func (m *ListWorkflowInstanceRequest) XXX_Size() int

func (*ListWorkflowInstanceRequest) XXX_Unmarshal added in v0.10.0 

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

type ListWorkflowInstanceResponse added in v0.10.0 

type ListWorkflowInstanceResponse struct {
	Snapshots []*WorkflowSnapshot `protobuf:"bytes,1,rep,name=snapshots,proto3" json:"snapshots,omitempty"`
}

func (*ListWorkflowInstanceResponse) Descriptor added in v0.10.0 

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

func (*ListWorkflowInstanceResponse) Marshal added in v0.10.0 

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

func (*ListWorkflowInstanceResponse) MarshalTo added in v0.10.0 

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

func (*ListWorkflowInstanceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ListWorkflowInstanceResponse) ProtoMessage added in v0.10.0 

func (*ListWorkflowInstanceResponse) ProtoMessage()

func (*ListWorkflowInstanceResponse) Reset added in v0.10.0 

func (m *ListWorkflowInstanceResponse) Reset()

func (*ListWorkflowInstanceResponse) String added in v0.10.0 

func (m *ListWorkflowInstanceResponse) String() string

func (*ListWorkflowInstanceResponse) Unmarshal added in v0.10.0 

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

func (*ListWorkflowInstanceResponse) Validate added in v0.10.0 

func (m *ListWorkflowInstanceResponse) Validate() error

func (*ListWorkflowInstanceResponse) ValidateE added in v0.10.0 

func (m *ListWorkflowInstanceResponse) ValidateE(prefix string) error

func (*ListWorkflowInstanceResponse) XSize added in v0.10.0 

func (m *ListWorkflowInstanceResponse) XSize() (n int)

func (*ListWorkflowInstanceResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *ListWorkflowInstanceResponse) XXX_DiscardUnknown()

func (*ListWorkflowInstanceResponse) XXX_Marshal added in v0.10.0 

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

func (*ListWorkflowInstanceResponse) XXX_Merge added in v0.10.0 

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

func (*ListWorkflowInstanceResponse) XXX_Size added in v0.10.0 

func (m *ListWorkflowInstanceResponse) XXX_Size() int

func (*ListWorkflowInstanceResponse) XXX_Unmarshal added in v0.10.0 

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

type OwnerReference 

type OwnerReference struct {
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Uid  string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
}

+gen:deepcopy

func (*OwnerReference) DeepCopy 

func (in *OwnerReference) DeepCopy() *OwnerReference

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new OwnerReference.

func (*OwnerReference) DeepCopyInto 

func (in *OwnerReference) DeepCopyInto(out *OwnerReference)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*OwnerReference) Descriptor 

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

func (*OwnerReference) Marshal 

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

func (*OwnerReference) MarshalTo 

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

func (*OwnerReference) MarshalToSizedBuffer 

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

func (*OwnerReference) ProtoMessage 

func (*OwnerReference) ProtoMessage()

func (*OwnerReference) Reset 

func (m *OwnerReference) Reset()

func (*OwnerReference) String 

func (m *OwnerReference) String() string

func (*OwnerReference) Unmarshal 

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

func (*OwnerReference) Validate 

func (m *OwnerReference) Validate() error

func (*OwnerReference) ValidateE 

func (m *OwnerReference) ValidateE(prefix string) error

func (*OwnerReference) XSize 

func (m *OwnerReference) XSize() (n int)

func (*OwnerReference) XXX_DiscardUnknown 

func (m *OwnerReference) XXX_DiscardUnknown()

func (*OwnerReference) XXX_Marshal 

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

func (*OwnerReference) XXX_Merge 

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

func (*OwnerReference) XXX_Size 

func (m *OwnerReference) XXX_Size() int

func (*OwnerReference) XXX_Unmarshal 

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

type PauseWorkflowInstanceRequest added in v0.10.0 

type PauseWorkflowInstanceRequest struct {
	Wid string `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
}

func (*PauseWorkflowInstanceRequest) Descriptor added in v0.10.0 

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

func (*PauseWorkflowInstanceRequest) Marshal added in v0.10.0 

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

func (*PauseWorkflowInstanceRequest) MarshalTo added in v0.10.0 

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

func (*PauseWorkflowInstanceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*PauseWorkflowInstanceRequest) ProtoMessage added in v0.10.0 

func (*PauseWorkflowInstanceRequest) ProtoMessage()

func (*PauseWorkflowInstanceRequest) Reset added in v0.10.0 

func (m *PauseWorkflowInstanceRequest) Reset()

func (*PauseWorkflowInstanceRequest) String added in v0.10.0 

func (m *PauseWorkflowInstanceRequest) String() string

func (*PauseWorkflowInstanceRequest) Unmarshal added in v0.10.0 

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

func (*PauseWorkflowInstanceRequest) Validate added in v0.10.0 

func (m *PauseWorkflowInstanceRequest) Validate() error

func (*PauseWorkflowInstanceRequest) ValidateE added in v0.10.0 

func (m *PauseWorkflowInstanceRequest) ValidateE(prefix string) error

func (*PauseWorkflowInstanceRequest) XSize added in v0.10.0 

func (m *PauseWorkflowInstanceRequest) XSize() (n int)

func (*PauseWorkflowInstanceRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *PauseWorkflowInstanceRequest) XXX_DiscardUnknown()

func (*PauseWorkflowInstanceRequest) XXX_Marshal added in v0.10.0 

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

func (*PauseWorkflowInstanceRequest) XXX_Merge added in v0.10.0 

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

func (*PauseWorkflowInstanceRequest) XXX_Size added in v0.10.0 

func (m *PauseWorkflowInstanceRequest) XXX_Size() int

func (*PauseWorkflowInstanceRequest) XXX_Unmarshal added in v0.10.0 

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

type PauseWorkflowInstanceResponse added in v0.10.0 

type PauseWorkflowInstanceResponse struct {
}

func (*PauseWorkflowInstanceResponse) Descriptor added in v0.10.0 

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

func (*PauseWorkflowInstanceResponse) Marshal added in v0.10.0 

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

func (*PauseWorkflowInstanceResponse) MarshalTo added in v0.10.0 

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

func (*PauseWorkflowInstanceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*PauseWorkflowInstanceResponse) ProtoMessage added in v0.10.0 

func (*PauseWorkflowInstanceResponse) ProtoMessage()

func (*PauseWorkflowInstanceResponse) Reset added in v0.10.0 

func (m *PauseWorkflowInstanceResponse) Reset()

func (*PauseWorkflowInstanceResponse) String added in v0.10.0 

func (m *PauseWorkflowInstanceResponse) String() string

func (*PauseWorkflowInstanceResponse) Unmarshal added in v0.10.0 

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

func (*PauseWorkflowInstanceResponse) Validate added in v0.10.0 

func (m *PauseWorkflowInstanceResponse) Validate() error

func (*PauseWorkflowInstanceResponse) ValidateE added in v0.10.0 

func (m *PauseWorkflowInstanceResponse) ValidateE(prefix string) error

func (*PauseWorkflowInstanceResponse) XSize added in v0.10.0 

func (m *PauseWorkflowInstanceResponse) XSize() (n int)

func (*PauseWorkflowInstanceResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *PauseWorkflowInstanceResponse) XXX_DiscardUnknown()

func (*PauseWorkflowInstanceResponse) XXX_Marshal added in v0.10.0 

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

func (*PauseWorkflowInstanceResponse) XXX_Merge added in v0.10.0 

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

func (*PauseWorkflowInstanceResponse) XXX_Size added in v0.10.0 

func (m *PauseWorkflowInstanceResponse) XXX_Size() int

func (*PauseWorkflowInstanceResponse) XXX_Unmarshal added in v0.10.0 

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

type PipeCallRequest 

type PipeCallRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*PipeCallRequest) Descriptor 

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

func (*PipeCallRequest) Marshal 

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

func (*PipeCallRequest) MarshalTo 

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

func (*PipeCallRequest) MarshalToSizedBuffer 

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

func (*PipeCallRequest) ProtoMessage 

func (*PipeCallRequest) ProtoMessage()

func (*PipeCallRequest) Reset 

func (m *PipeCallRequest) Reset()

func (*PipeCallRequest) String 

func (m *PipeCallRequest) String() string

func (*PipeCallRequest) Unmarshal 

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

func (*PipeCallRequest) Validate 

func (m *PipeCallRequest) Validate() error

func (*PipeCallRequest) ValidateE 

func (m *PipeCallRequest) ValidateE(prefix string) error

func (*PipeCallRequest) XSize 

func (m *PipeCallRequest) XSize() (n int)

func (*PipeCallRequest) XXX_DiscardUnknown 

func (m *PipeCallRequest) XXX_DiscardUnknown()

func (*PipeCallRequest) XXX_Marshal 

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

func (*PipeCallRequest) XXX_Merge 

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

func (*PipeCallRequest) XXX_Size 

func (m *PipeCallRequest) XXX_Size() int

func (*PipeCallRequest) XXX_Unmarshal 

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

type PipeCallResponse 

type PipeCallResponse struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*PipeCallResponse) Descriptor 

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

func (*PipeCallResponse) Marshal 

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

func (*PipeCallResponse) MarshalTo 

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

func (*PipeCallResponse) MarshalToSizedBuffer 

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

func (*PipeCallResponse) ProtoMessage 

func (*PipeCallResponse) ProtoMessage()

func (*PipeCallResponse) Reset 

func (m *PipeCallResponse) Reset()

func (*PipeCallResponse) String 

func (m *PipeCallResponse) String() string

func (*PipeCallResponse) Unmarshal 

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

func (*PipeCallResponse) Validate 

func (m *PipeCallResponse) Validate() error

func (*PipeCallResponse) ValidateE 

func (m *PipeCallResponse) ValidateE(prefix string) error

func (*PipeCallResponse) XSize 

func (m *PipeCallResponse) XSize() (n int)

func (*PipeCallResponse) XXX_DiscardUnknown 

func (m *PipeCallResponse) XXX_DiscardUnknown()

func (*PipeCallResponse) XXX_Marshal 

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

func (*PipeCallResponse) XXX_Merge 

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

func (*PipeCallResponse) XXX_Size 

func (m *PipeCallResponse) XXX_Size() int

func (*PipeCallResponse) XXX_Unmarshal 

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

type PipeRequest 

type PipeRequest struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic    Topic             `protobuf:"varint,2,opt,name=topic,proto3,enum=api.Topic" json:"topic,omitempty"`
	Revision *Revision         `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"`
	Call     *PipeCallResponse `protobuf:"bytes,4,opt,name=call,proto3" json:"call,omitempty"`
	Step     *PipeStepResponse `protobuf:"bytes,5,opt,name=step,proto3" json:"step,omitempty"`
}

func (*PipeRequest) Descriptor 

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

func (*PipeRequest) Marshal 

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

func (*PipeRequest) MarshalTo 

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

func (*PipeRequest) MarshalToSizedBuffer 

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

func (*PipeRequest) ProtoMessage 

func (*PipeRequest) ProtoMessage()

func (*PipeRequest) Reset 

func (m *PipeRequest) Reset()

func (*PipeRequest) String 

func (m *PipeRequest) String() string

func (*PipeRequest) Unmarshal 

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

func (*PipeRequest) Validate 

func (m *PipeRequest) Validate() error

func (*PipeRequest) ValidateE 

func (m *PipeRequest) ValidateE(prefix string) error

func (*PipeRequest) XSize 

func (m *PipeRequest) XSize() (n int)

func (*PipeRequest) XXX_DiscardUnknown 

func (m *PipeRequest) XXX_DiscardUnknown()

func (*PipeRequest) XXX_Marshal 

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

func (*PipeRequest) XXX_Merge 

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

func (*PipeRequest) XXX_Size 

func (m *PipeRequest) XXX_Size() int

func (*PipeRequest) XXX_Unmarshal 

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

type PipeResponse 

type PipeResponse struct {
	Topic    Topic            `protobuf:"varint,1,opt,name=topic,proto3,enum=api.Topic" json:"topic,omitempty"`
	Revision *Revision        `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"`
	Call     *PipeCallRequest `protobuf:"bytes,3,opt,name=call,proto3" json:"call,omitempty"`
	Step     *PipeStepRequest `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"`
}

func (*PipeResponse) Descriptor 

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

func (*PipeResponse) Marshal 

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

func (*PipeResponse) MarshalTo 

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

func (*PipeResponse) MarshalToSizedBuffer 

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

func (*PipeResponse) ProtoMessage 

func (*PipeResponse) ProtoMessage()

func (*PipeResponse) Reset 

func (m *PipeResponse) Reset()

func (*PipeResponse) String 

func (m *PipeResponse) String() string

func (*PipeResponse) Unmarshal 

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

func (*PipeResponse) Validate 

func (m *PipeResponse) Validate() error

func (*PipeResponse) ValidateE 

func (m *PipeResponse) ValidateE(prefix string) error

func (*PipeResponse) XSize 

func (m *PipeResponse) XSize() (n int)

func (*PipeResponse) XXX_DiscardUnknown 

func (m *PipeResponse) XXX_DiscardUnknown()

func (*PipeResponse) XXX_Marshal 

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

func (*PipeResponse) XXX_Merge 

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

func (*PipeResponse) XXX_Size 

func (m *PipeResponse) XXX_Size() int

func (*PipeResponse) XXX_Unmarshal 

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

type PipeStepRequest 

type PipeStepRequest struct {
	Wid        string            `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
	InstanceId string            `protobuf:"bytes,2,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Name       string            `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Sid        string            `protobuf:"bytes,4,opt,name=sid,proto3" json:"sid,omitempty"`
	Action     StepAction        `protobuf:"varint,5,opt,name=action,proto3,enum=api.StepAction" json:"action,omitempty"`
	Items      map[string]string `` /* 151-byte string literal not displayed */
	Entity     string            `protobuf:"bytes,7,opt,name=entity,proto3" json:"entity,omitempty"`
}

func (*PipeStepRequest) Descriptor 

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

func (*PipeStepRequest) Marshal 

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

func (*PipeStepRequest) MarshalTo 

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

func (*PipeStepRequest) MarshalToSizedBuffer 

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

func (*PipeStepRequest) ProtoMessage 

func (*PipeStepRequest) ProtoMessage()

func (*PipeStepRequest) Reset 

func (m *PipeStepRequest) Reset()

func (*PipeStepRequest) String 

func (m *PipeStepRequest) String() string

func (*PipeStepRequest) Unmarshal 

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

func (*PipeStepRequest) Validate 

func (m *PipeStepRequest) Validate() error

func (*PipeStepRequest) ValidateE 

func (m *PipeStepRequest) ValidateE(prefix string) error

func (*PipeStepRequest) XSize 

func (m *PipeStepRequest) XSize() (n int)

func (*PipeStepRequest) XXX_DiscardUnknown 

func (m *PipeStepRequest) XXX_DiscardUnknown()

func (*PipeStepRequest) XXX_Marshal 

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

func (*PipeStepRequest) XXX_Merge 

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

func (*PipeStepRequest) XXX_Size 

func (m *PipeStepRequest) XXX_Size() int

func (*PipeStepRequest) XXX_Unmarshal 

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

type PipeStepResponse 

type PipeStepResponse struct {
	Name  string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Out   map[string]string `` /* 147-byte string literal not displayed */
	Error string            `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*PipeStepResponse) Descriptor 

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

func (*PipeStepResponse) Marshal 

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

func (*PipeStepResponse) MarshalTo 

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

func (*PipeStepResponse) MarshalToSizedBuffer 

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

func (*PipeStepResponse) ProtoMessage 

func (*PipeStepResponse) ProtoMessage()

func (*PipeStepResponse) Reset 

func (m *PipeStepResponse) Reset()

func (*PipeStepResponse) String 

func (m *PipeStepResponse) String() string

func (*PipeStepResponse) Unmarshal 

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

func (*PipeStepResponse) Validate 

func (m *PipeStepResponse) Validate() error

func (*PipeStepResponse) ValidateE 

func (m *PipeStepResponse) ValidateE(prefix string) error

func (*PipeStepResponse) XSize 

func (m *PipeStepResponse) XSize() (n int)

func (*PipeStepResponse) XXX_DiscardUnknown 

func (m *PipeStepResponse) XXX_DiscardUnknown()

func (*PipeStepResponse) XXX_Marshal 

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

func (*PipeStepResponse) XXX_Merge 

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

func (*PipeStepResponse) XXX_Size 

func (m *PipeStepResponse) XXX_Size() int

func (*PipeStepResponse) XXX_Unmarshal 

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

type Property added in v0.10.0 

type Property struct {
	Name  string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type  PropertyType `protobuf:"varint,2,opt,name=type,proto3,enum=api.PropertyType" json:"type,omitempty"`
	Value string       `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Property) DeepCopyInto added in v0.10.0 

func (in *Property) DeepCopyInto(out *Property)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Property) Descriptor added in v0.10.0 

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

func (*Property) Marshal added in v0.10.0 

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

func (*Property) MarshalTo added in v0.10.0 

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

func (*Property) MarshalToSizedBuffer added in v0.10.0 

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

func (*Property) ProtoMessage added in v0.10.0 

func (*Property) ProtoMessage()

func (*Property) Reset added in v0.10.0 

func (m *Property) Reset()

func (*Property) String added in v0.10.0 

func (m *Property) String() string

func (*Property) Unmarshal added in v0.10.0 

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

func (*Property) Validate added in v0.10.0 

func (m *Property) Validate() error

func (*Property) ValidateE added in v0.10.0 

func (m *Property) ValidateE(prefix string) error

func (*Property) XSize added in v0.10.0 

func (m *Property) XSize() (n int)

func (*Property) XXX_DiscardUnknown added in v0.10.0 

func (m *Property) XXX_DiscardUnknown()

func (*Property) XXX_Marshal added in v0.10.0 

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

func (*Property) XXX_Merge added in v0.10.0 

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

func (*Property) XXX_Size added in v0.10.0 

func (m *Property) XXX_Size() int

func (*Property) XXX_Unmarshal added in v0.10.0 

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

type PropertyType added in v0.10.0 

type PropertyType int32
const (
	PropertyType_PYUnknown PropertyType = 0
	PropertyType_PYInteger PropertyType = 1
	PropertyType_PYFloat   PropertyType = 2
	PropertyType_PYString  PropertyType = 3
	PropertyType_PYObject  PropertyType = 4
)

func (PropertyType) EnumDescriptor added in v0.10.0 

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

func (PropertyType) String added in v0.10.0 

func (x PropertyType) String() string

type RegisterRequest 

type RegisterRequest struct {
	// +gen:required
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Attrs    map[string]string `` /* 151-byte string literal not displayed */
	Entities []*Entity         `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"`
	Echoes   []*Echo           `protobuf:"bytes,4,rep,name=echoes,proto3" json:"echoes,omitempty"`
	Steps    []*Step           `protobuf:"bytes,5,rep,name=steps,proto3" json:"steps,omitempty"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) Marshal 

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

func (*RegisterRequest) MarshalTo 

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

func (*RegisterRequest) MarshalToSizedBuffer 

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

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

func (*RegisterRequest) Unmarshal 

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

func (*RegisterRequest) Validate 

func (m *RegisterRequest) Validate() error

func (*RegisterRequest) ValidateE 

func (m *RegisterRequest) ValidateE(prefix string) error

func (*RegisterRequest) XSize 

func (m *RegisterRequest) XSize() (n int)

func (*RegisterRequest) XXX_DiscardUnknown 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal 

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

func (*RegisterRequest) XXX_Merge 

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

func (*RegisterRequest) XXX_Size 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal 

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

type RegisterResponse 

type RegisterResponse struct {
}

func (*RegisterResponse) Descriptor 

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

func (*RegisterResponse) Marshal 

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

func (*RegisterResponse) MarshalTo 

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

func (*RegisterResponse) MarshalToSizedBuffer 

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

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (m *RegisterResponse) String() string

func (*RegisterResponse) Unmarshal 

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

func (*RegisterResponse) Validate 

func (m *RegisterResponse) Validate() error

func (*RegisterResponse) ValidateE 

func (m *RegisterResponse) ValidateE(prefix string) error

func (*RegisterResponse) XSize 

func (m *RegisterResponse) XSize() (n int)

func (*RegisterResponse) XXX_DiscardUnknown 

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal 

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

func (*RegisterResponse) XXX_Merge 

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

func (*RegisterResponse) XXX_Size 

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal 

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

type ResumeWorkflowInstanceRequest added in v0.10.0 

type ResumeWorkflowInstanceRequest struct {
	Wid string `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
}

func (*ResumeWorkflowInstanceRequest) Descriptor added in v0.10.0 

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

func (*ResumeWorkflowInstanceRequest) Marshal added in v0.10.0 

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

func (*ResumeWorkflowInstanceRequest) MarshalTo added in v0.10.0 

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

func (*ResumeWorkflowInstanceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ResumeWorkflowInstanceRequest) ProtoMessage added in v0.10.0 

func (*ResumeWorkflowInstanceRequest) ProtoMessage()

func (*ResumeWorkflowInstanceRequest) Reset added in v0.10.0 

func (m *ResumeWorkflowInstanceRequest) Reset()

func (*ResumeWorkflowInstanceRequest) String added in v0.10.0 

func (m *ResumeWorkflowInstanceRequest) String() string

func (*ResumeWorkflowInstanceRequest) Unmarshal added in v0.10.0 

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

func (*ResumeWorkflowInstanceRequest) Validate added in v0.10.0 

func (m *ResumeWorkflowInstanceRequest) Validate() error

func (*ResumeWorkflowInstanceRequest) ValidateE added in v0.10.0 

func (m *ResumeWorkflowInstanceRequest) ValidateE(prefix string) error

func (*ResumeWorkflowInstanceRequest) XSize added in v0.10.0 

func (m *ResumeWorkflowInstanceRequest) XSize() (n int)

func (*ResumeWorkflowInstanceRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *ResumeWorkflowInstanceRequest) XXX_DiscardUnknown()

func (*ResumeWorkflowInstanceRequest) XXX_Marshal added in v0.10.0 

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

func (*ResumeWorkflowInstanceRequest) XXX_Merge added in v0.10.0 

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

func (*ResumeWorkflowInstanceRequest) XXX_Size added in v0.10.0 

func (m *ResumeWorkflowInstanceRequest) XXX_Size() int

func (*ResumeWorkflowInstanceRequest) XXX_Unmarshal added in v0.10.0 

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

type ResumeWorkflowInstanceResponse added in v0.10.0 

type ResumeWorkflowInstanceResponse struct {
}

func (*ResumeWorkflowInstanceResponse) Descriptor added in v0.10.0 

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

func (*ResumeWorkflowInstanceResponse) Marshal added in v0.10.0 

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

func (*ResumeWorkflowInstanceResponse) MarshalTo added in v0.10.0 

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

func (*ResumeWorkflowInstanceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ResumeWorkflowInstanceResponse) ProtoMessage added in v0.10.0 

func (*ResumeWorkflowInstanceResponse) ProtoMessage()

func (*ResumeWorkflowInstanceResponse) Reset added in v0.10.0 

func (m *ResumeWorkflowInstanceResponse) Reset()

func (*ResumeWorkflowInstanceResponse) String added in v0.10.0 

func (m *ResumeWorkflowInstanceResponse) String() string

func (*ResumeWorkflowInstanceResponse) Unmarshal added in v0.10.0 

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

func (*ResumeWorkflowInstanceResponse) Validate added in v0.10.0 

func (m *ResumeWorkflowInstanceResponse) Validate() error

func (*ResumeWorkflowInstanceResponse) ValidateE added in v0.10.0 

func (m *ResumeWorkflowInstanceResponse) ValidateE(prefix string) error

func (*ResumeWorkflowInstanceResponse) XSize added in v0.10.0 

func (m *ResumeWorkflowInstanceResponse) XSize() (n int)

func (*ResumeWorkflowInstanceResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *ResumeWorkflowInstanceResponse) XXX_DiscardUnknown()

func (*ResumeWorkflowInstanceResponse) XXX_Marshal added in v0.10.0 

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

func (*ResumeWorkflowInstanceResponse) XXX_Merge added in v0.10.0 

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

func (*ResumeWorkflowInstanceResponse) XXX_Size added in v0.10.0 

func (m *ResumeWorkflowInstanceResponse) XXX_Size() int

func (*ResumeWorkflowInstanceResponse) XXX_Unmarshal added in v0.10.0 

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

type Revision 

type Revision struct {
	Main int64 `protobuf:"varint,1,opt,name=main,proto3" json:"main,omitempty"`
	Sub  int64 `protobuf:"varint,2,opt,name=sub,proto3" json:"sub,omitempty"`
}

+gen:deepcopy

func BytesToRev 

func BytesToRev(bytes []byte) Revision

func NewRevision 

func NewRevision() *Revision

func (*Revision) Add 

func (m *Revision) Add()

func (*Revision) DeepCopy 

func (in *Revision) DeepCopy() *Revision

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new Revision.

func (*Revision) DeepCopyInto 

func (in *Revision) DeepCopyInto(out *Revision)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Revision) Descriptor 

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

func (*Revision) GreaterThan 

func (m *Revision) GreaterThan(b *Revision) bool

func (*Revision) IsZone 

func (m *Revision) IsZone() bool

func (*Revision) Marshal 

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

func (*Revision) MarshalTo 

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

func (*Revision) MarshalToSizedBuffer 

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

func (*Revision) ProtoMessage 

func (*Revision) ProtoMessage()

func (*Revision) Readably 

func (m *Revision) Readably() string

func (*Revision) Reset 

func (m *Revision) Reset()

func (*Revision) String 

func (m *Revision) String() string

func (*Revision) ToBytes 

func (m *Revision) ToBytes() []byte

func (*Revision) Unmarshal 

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

func (*Revision) Validate 

func (m *Revision) Validate() error

func (*Revision) ValidateE 

func (m *Revision) ValidateE(prefix string) error

func (*Revision) XSize 

func (m *Revision) XSize() (n int)

func (*Revision) XXX_DiscardUnknown 

func (m *Revision) XXX_DiscardUnknown()

func (*Revision) XXX_Marshal 

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

func (*Revision) XXX_Merge 

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

func (*Revision) XXX_Size 

func (m *Revision) XXX_Size() int

func (*Revision) XXX_Unmarshal 

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

type StatusCode 

type StatusCode int32
const (
	StatusBadRequest          StatusCode = 400
	StatusUnauthorized        StatusCode = 401
	StatusForbidden           StatusCode = 403
	StatusNotFound            StatusCode = 404
	StatusMethodNotAllowed    StatusCode = 405
	StatusCancel              StatusCode = 408
	StatusConflict            StatusCode = 409
	StatusPreconditionFiled   StatusCode = 412
	StatusClientException     StatusCode = 499
	StatusInternalServerError StatusCode = 500
	StatusNotImplemented      StatusCode = 501
	StatusBadGateway          StatusCode = 502
	StatusServiceUnavailable  StatusCode = 503
	StatusGatewayTimeout      StatusCode = 504
	StatusInsufficientStorage StatusCode = 507
)

func (StatusCode) String 

func (c StatusCode) String() string

type Step 

type Step struct {
	Name     string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Entity   string             `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	Injects  []string           `protobuf:"bytes,3,rep,name=injects,proto3" json:"injects,omitempty"`
	Workers  map[string]*Worker `` /* 155-byte string literal not displayed */
	Describe string             `protobuf:"bytes,5,opt,name=describe,proto3" json:"describe,omitempty"`
}

+gen:deepcopy

func (*Step) DeepCopy 

func (in *Step) DeepCopy() *Step

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new Step.

func (*Step) DeepCopyInto 

func (in *Step) DeepCopyInto(out *Step)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Step) Descriptor 

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

func (*Step) Marshal 

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

func (*Step) MarshalTo 

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

func (*Step) MarshalToSizedBuffer 

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

func (*Step) ProtoMessage 

func (*Step) ProtoMessage()

func (*Step) Reset 

func (m *Step) Reset()

func (*Step) String 

func (m *Step) String() string

func (*Step) Unmarshal 

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

func (*Step) Validate 

func (m *Step) Validate() error

func (*Step) ValidateE 

func (m *Step) ValidateE(prefix string) error

func (*Step) XSize 

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

func (*Step) XXX_DiscardUnknown 

func (m *Step) XXX_DiscardUnknown()

func (*Step) XXX_Marshal 

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

func (*Step) XXX_Merge 

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

func (*Step) XXX_Size 

func (m *Step) XXX_Size() int

func (*Step) XXX_Unmarshal 

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

type StepAction 

type StepAction int32
const (
	StepAction_SA_UNKNOWN  StepAction = 0
	StepAction_SC_PREPARE  StepAction = 1
	StepAction_SC_COMMIT   StepAction = 2
	StepAction_SC_ROLLBACK StepAction = 3
	StepAction_SC_CANCEL   StepAction = 4
)

func (StepAction) EnumDescriptor 

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

func (*StepAction) MarshalJSON 

func (m *StepAction) MarshalJSON() ([]byte, error)

func (StepAction) Readably 

func (m StepAction) Readably() string

func (StepAction) String 

func (x StepAction) String() string

func (*StepAction) UnmarshalJSON 

func (m *StepAction) UnmarshalJSON(data []byte) error

type StepGetRequest 

type StepGetRequest struct {
	// +gen:required
	Wid string `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
	// +gen:required
	InstanceId string `protobuf:"bytes,2,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// +gen:required
	Step string `protobuf:"bytes,3,opt,name=step,proto3" json:"step,omitempty"`
	// +gen:required
	Key string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
}

func (*StepGetRequest) Descriptor 

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

func (*StepGetRequest) Marshal 

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

func (*StepGetRequest) MarshalTo 

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

func (*StepGetRequest) MarshalToSizedBuffer 

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

func (*StepGetRequest) ProtoMessage 

func (*StepGetRequest) ProtoMessage()

func (*StepGetRequest) Reset 

func (m *StepGetRequest) Reset()

func (*StepGetRequest) String 

func (m *StepGetRequest) String() string

func (*StepGetRequest) Unmarshal 

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

func (*StepGetRequest) Validate 

func (m *StepGetRequest) Validate() error

func (*StepGetRequest) ValidateE 

func (m *StepGetRequest) ValidateE(prefix string) error

func (*StepGetRequest) XSize 

func (m *StepGetRequest) XSize() (n int)

func (*StepGetRequest) XXX_DiscardUnknown 

func (m *StepGetRequest) XXX_DiscardUnknown()

func (*StepGetRequest) XXX_Marshal 

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

func (*StepGetRequest) XXX_Merge 

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

func (*StepGetRequest) XXX_Size 

func (m *StepGetRequest) XXX_Size() int

func (*StepGetRequest) XXX_Unmarshal 

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

type StepGetResponse 

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

func (*StepGetResponse) Descriptor 

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

func (*StepGetResponse) Marshal 

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

func (*StepGetResponse) MarshalTo 

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

func (*StepGetResponse) MarshalToSizedBuffer 

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

func (*StepGetResponse) ProtoMessage 

func (*StepGetResponse) ProtoMessage()

func (*StepGetResponse) Reset 

func (m *StepGetResponse) Reset()

func (*StepGetResponse) String 

func (m *StepGetResponse) String() string

func (*StepGetResponse) Unmarshal 

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

func (*StepGetResponse) Validate 

func (m *StepGetResponse) Validate() error

func (*StepGetResponse) ValidateE 

func (m *StepGetResponse) ValidateE(prefix string) error

func (*StepGetResponse) XSize 

func (m *StepGetResponse) XSize() (n int)

func (*StepGetResponse) XXX_DiscardUnknown 

func (m *StepGetResponse) XXX_DiscardUnknown()

func (*StepGetResponse) XXX_Marshal 

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

func (*StepGetResponse) XXX_Merge 

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

func (*StepGetResponse) XXX_Size 

func (m *StepGetResponse) XXX_Size() int

func (*StepGetResponse) XXX_Unmarshal 

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

type StepPutRequest 

type StepPutRequest struct {
	// +gen:required
	Wid string `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
	// +gen:required
	InstanceId string `protobuf:"bytes,2,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// +gen:required
	Step string `protobuf:"bytes,3,opt,name=step,proto3" json:"step,omitempty"`
	// +gen:required
	Key string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// +gen:required
	Value string `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
}

func (*StepPutRequest) Descriptor 

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

func (*StepPutRequest) Marshal 

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

func (*StepPutRequest) MarshalTo 

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

func (*StepPutRequest) MarshalToSizedBuffer 

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

func (*StepPutRequest) ProtoMessage 

func (*StepPutRequest) ProtoMessage()

func (*StepPutRequest) Reset 

func (m *StepPutRequest) Reset()

func (*StepPutRequest) String 

func (m *StepPutRequest) String() string

func (*StepPutRequest) Unmarshal 

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

func (*StepPutRequest) Validate 

func (m *StepPutRequest) Validate() error

func (*StepPutRequest) ValidateE 

func (m *StepPutRequest) ValidateE(prefix string) error

func (*StepPutRequest) XSize 

func (m *StepPutRequest) XSize() (n int)

func (*StepPutRequest) XXX_DiscardUnknown 

func (m *StepPutRequest) XXX_DiscardUnknown()

func (*StepPutRequest) XXX_Marshal 

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

func (*StepPutRequest) XXX_Merge 

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

func (*StepPutRequest) XXX_Size 

func (m *StepPutRequest) XXX_Size() int

func (*StepPutRequest) XXX_Unmarshal 

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

type StepPutResponse 

type StepPutResponse struct {
}

func (*StepPutResponse) Descriptor 

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

func (*StepPutResponse) Marshal 

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

func (*StepPutResponse) MarshalTo 

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

func (*StepPutResponse) MarshalToSizedBuffer 

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

func (*StepPutResponse) ProtoMessage 

func (*StepPutResponse) ProtoMessage()

func (*StepPutResponse) Reset 

func (m *StepPutResponse) Reset()

func (*StepPutResponse) String 

func (m *StepPutResponse) String() string

func (*StepPutResponse) Unmarshal 

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

func (*StepPutResponse) Validate 

func (m *StepPutResponse) Validate() error

func (*StepPutResponse) ValidateE 

func (m *StepPutResponse) ValidateE(prefix string) error

func (*StepPutResponse) XSize 

func (m *StepPutResponse) XSize() (n int)

func (*StepPutResponse) XXX_DiscardUnknown 

func (m *StepPutResponse) XXX_DiscardUnknown()

func (*StepPutResponse) XXX_Marshal 

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

func (*StepPutResponse) XXX_Merge 

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

func (*StepPutResponse) XXX_Size 

func (m *StepPutResponse) XXX_Size() int

func (*StepPutResponse) XXX_Unmarshal 

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

type StepRequest 

type StepRequest struct {
	// +gen:required
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// +gen:required
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// +gen:required
	Action StepAction        `protobuf:"varint,3,opt,name=action,proto3,enum=api.StepAction" json:"action,omitempty"`
	Items  map[string]string `` /* 151-byte string literal not displayed */
	Args   map[string]string `` /* 149-byte string literal not displayed */
	Entity []byte            `protobuf:"bytes,6,opt,name=entity,proto3" json:"entity,omitempty"`
}

func (*StepRequest) Descriptor 

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

func (*StepRequest) Marshal 

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

func (*StepRequest) MarshalTo 

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

func (*StepRequest) MarshalToSizedBuffer 

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

func (*StepRequest) ProtoMessage 

func (*StepRequest) ProtoMessage()

func (*StepRequest) Reset 

func (m *StepRequest) Reset()

func (*StepRequest) String 

func (m *StepRequest) String() string

func (*StepRequest) Unmarshal 

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

func (*StepRequest) Validate 

func (m *StepRequest) Validate() error

func (*StepRequest) ValidateE 

func (m *StepRequest) ValidateE(prefix string) error

func (*StepRequest) XSize 

func (m *StepRequest) XSize() (n int)

func (*StepRequest) XXX_DiscardUnknown 

func (m *StepRequest) XXX_DiscardUnknown()

func (*StepRequest) XXX_Marshal 

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

func (*StepRequest) XXX_Merge 

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

func (*StepRequest) XXX_Size 

func (m *StepRequest) XXX_Size() int

func (*StepRequest) XXX_Unmarshal 

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

type StepResponse 

type StepResponse struct {
	Name  string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Data  map[string]string `` /* 149-byte string literal not displayed */
	Error string            `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*StepResponse) Descriptor 

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

func (*StepResponse) Marshal 

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

func (*StepResponse) MarshalTo 

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

func (*StepResponse) MarshalToSizedBuffer 

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

func (*StepResponse) ProtoMessage 

func (*StepResponse) ProtoMessage()

func (*StepResponse) Reset 

func (m *StepResponse) Reset()

func (*StepResponse) String 

func (m *StepResponse) String() string

func (*StepResponse) Unmarshal 

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

func (*StepResponse) Validate 

func (m *StepResponse) Validate() error

func (*StepResponse) ValidateE 

func (m *StepResponse) ValidateE(prefix string) error

func (*StepResponse) XSize 

func (m *StepResponse) XSize() (n int)

func (*StepResponse) XXX_DiscardUnknown 

func (m *StepResponse) XXX_DiscardUnknown()

func (*StepResponse) XXX_Marshal 

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

func (*StepResponse) XXX_Merge 

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

func (*StepResponse) XXX_Size 

func (m *StepResponse) XXX_Size() int

func (*StepResponse) XXX_Unmarshal 

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

type StepTraceRequest 

type StepTraceRequest struct {
	// +gen:required
	TraceLog *TraceLog `protobuf:"bytes,1,opt,name=traceLog,proto3" json:"traceLog,omitempty"`
}

func (*StepTraceRequest) Descriptor 

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

func (*StepTraceRequest) Marshal 

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

func (*StepTraceRequest) MarshalTo 

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

func (*StepTraceRequest) MarshalToSizedBuffer 

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

func (*StepTraceRequest) ProtoMessage 

func (*StepTraceRequest) ProtoMessage()

func (*StepTraceRequest) Reset 

func (m *StepTraceRequest) Reset()

func (*StepTraceRequest) String 

func (m *StepTraceRequest) String() string

func (*StepTraceRequest) Unmarshal 

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

func (*StepTraceRequest) Validate 

func (m *StepTraceRequest) Validate() error

func (*StepTraceRequest) ValidateE 

func (m *StepTraceRequest) ValidateE(prefix string) error

func (*StepTraceRequest) XSize 

func (m *StepTraceRequest) XSize() (n int)

func (*StepTraceRequest) XXX_DiscardUnknown 

func (m *StepTraceRequest) XXX_DiscardUnknown()

func (*StepTraceRequest) XXX_Marshal 

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

func (*StepTraceRequest) XXX_Merge 

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

func (*StepTraceRequest) XXX_Size 

func (m *StepTraceRequest) XXX_Size() int

func (*StepTraceRequest) XXX_Unmarshal 

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

type StepTraceResponse 

type StepTraceResponse struct {
}

func (*StepTraceResponse) Descriptor 

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

func (*StepTraceResponse) Marshal 

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

func (*StepTraceResponse) MarshalTo 

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

func (*StepTraceResponse) MarshalToSizedBuffer 

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

func (*StepTraceResponse) ProtoMessage 

func (*StepTraceResponse) ProtoMessage()

func (*StepTraceResponse) Reset 

func (m *StepTraceResponse) Reset()

func (*StepTraceResponse) String 

func (m *StepTraceResponse) String() string

func (*StepTraceResponse) Unmarshal 

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

func (*StepTraceResponse) Validate 

func (m *StepTraceResponse) Validate() error

func (*StepTraceResponse) ValidateE 

func (m *StepTraceResponse) ValidateE(prefix string) error

func (*StepTraceResponse) XSize 

func (m *StepTraceResponse) XSize() (n int)

func (*StepTraceResponse) XXX_DiscardUnknown 

func (m *StepTraceResponse) XXX_DiscardUnknown()

func (*StepTraceResponse) XXX_Marshal 

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

func (*StepTraceResponse) XXX_Merge 

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

func (*StepTraceResponse) XXX_Size 

func (m *StepTraceResponse) XXX_Size() int

func (*StepTraceResponse) XXX_Unmarshal 

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

type Topic 

type Topic int32
const (
	Topic_T_UNKNOWN Topic = 0
	Topic_T_CONN    Topic = 1
	Topic_T_PING    Topic = 2
	Topic_T_CALL    Topic = 3
	Topic_T_STEP    Topic = 4
)

func (Topic) EnumDescriptor 

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

func (Topic) Readably added in v0.2.2 

func (m Topic) Readably() string

func (Topic) String 

func (x Topic) String() string

type TraceLevel added in v0.12.5 

type TraceLevel int32
const (
	TraceLevel_TL_TRACE TraceLevel = 0
	TraceLevel_TL_DEBUG TraceLevel = 1
	TraceLevel_TL_INFO  TraceLevel = 2
	TraceLevel_TL_WARN  TraceLevel = 3
	TraceLevel_TL_ERROR TraceLevel = 4
)

func (TraceLevel) EnumDescriptor added in v0.12.5 

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

func (TraceLevel) String added in v0.12.5 

func (x TraceLevel) String() string

type TraceLog added in v0.12.5 

type TraceLog struct {
	Level      TraceLevel `protobuf:"varint,1,opt,name=level,proto3,enum=api.TraceLevel" json:"level,omitempty"`
	Wid        string     `protobuf:"bytes,2,opt,name=wid,proto3" json:"wid,omitempty"`
	InstanceId string     `protobuf:"bytes,3,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Sid        string     `protobuf:"bytes,4,opt,name=sid,proto3" json:"sid,omitempty"`
	Text       string     `protobuf:"bytes,5,opt,name=text,proto3" json:"text,omitempty"`
	Timestamp  int64      `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*TraceLog) DeepCopyInto added in v0.12.5 

func (in *TraceLog) DeepCopyInto(out *TraceLog)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*TraceLog) Descriptor added in v0.12.5 

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

func (*TraceLog) Marshal added in v0.12.5 

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

func (*TraceLog) MarshalTo added in v0.12.5 

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

func (*TraceLog) MarshalToSizedBuffer added in v0.12.5 

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

func (*TraceLog) ProtoMessage added in v0.12.5 

func (*TraceLog) ProtoMessage()

func (*TraceLog) Reset added in v0.12.5 

func (m *TraceLog) Reset()

func (*TraceLog) String added in v0.12.5 

func (m *TraceLog) String() string

func (*TraceLog) Unmarshal added in v0.12.5 

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

func (*TraceLog) Validate added in v0.12.5 

func (m *TraceLog) Validate() error

func (*TraceLog) ValidateE added in v0.12.5 

func (m *TraceLog) ValidateE(prefix string) error

func (*TraceLog) XSize added in v0.12.5 

func (m *TraceLog) XSize() (n int)

func (*TraceLog) XXX_DiscardUnknown added in v0.12.5 

func (m *TraceLog) XXX_DiscardUnknown()

func (*TraceLog) XXX_Marshal added in v0.12.5 

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

func (*TraceLog) XXX_Merge added in v0.12.5 

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

func (*TraceLog) XXX_Size added in v0.12.5 

func (m *TraceLog) XXX_Size() int

func (*TraceLog) XXX_Unmarshal added in v0.12.5 

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

type UnimplementedFlowRpcServer 

type UnimplementedFlowRpcServer struct {
}

UnimplementedFlowRpcServer can be embedded to have forward compatible implementations.

func (*UnimplementedFlowRpcServer) AbortWorkflowInstance added in v0.10.0 

func (*UnimplementedFlowRpcServer) AbortWorkflowInstance(ctx context.Context, req *AbortWorkflowInstanceRequest) (*AbortWorkflowInstanceResponse, error)

func (*UnimplementedFlowRpcServer) Call 

func (*UnimplementedFlowRpcServer) Call(ctx context.Context, req *CallRequest) (*CallResponse, error)

func (*UnimplementedFlowRpcServer) CommitInteractive added in v0.10.0 

func (*UnimplementedFlowRpcServer) CommitInteractive(ctx context.Context, req *CommitInteractiveRequest) (*CommitInteractiveResponse, error)

func (*UnimplementedFlowRpcServer) ExecuteWorkflowInstance added in v0.13.2 

func (*UnimplementedFlowRpcServer) ExecuteWorkflowInstance(req *ExecuteWorkflowInstanceRequest, srv FlowRpc_ExecuteWorkflowInstanceServer) error

func (*UnimplementedFlowRpcServer) GetWorker added in v0.12.2 

func (*UnimplementedFlowRpcServer) GetWorker(ctx context.Context, req *GetWorkerRequest) (*GetWorkerResponse, error)

func (*UnimplementedFlowRpcServer) HandleServiceErr added in v0.14.0 

func (*UnimplementedFlowRpcServer) HandleServiceErr(ctx context.Context, req *HandleServiceErrRequest) (*HandleServiceErrResponse, error)

func (*UnimplementedFlowRpcServer) InspectWorkflowInstance added in v0.10.0 

func (*UnimplementedFlowRpcServer) InspectWorkflowInstance(ctx context.Context, req *InspectWorkflowInstanceRequest) (*InspectWorkflowInstanceResponse, error)

func (*UnimplementedFlowRpcServer) ListInteractive added in v0.10.0 

func (*UnimplementedFlowRpcServer) ListInteractive(ctx context.Context, req *ListInteractiveRequest) (*ListInteractiveResponse, error)

func (*UnimplementedFlowRpcServer) ListRegistry added in v0.2.0 

func (*UnimplementedFlowRpcServer) ListRegistry(ctx context.Context, req *ListRegistryRequest) (*ListRegistryResponse, error)

func (*UnimplementedFlowRpcServer) ListWorker added in v0.2.0 

func (*UnimplementedFlowRpcServer) ListWorker(ctx context.Context, req *ListWorkerRequest) (*ListWorkerResponse, error)

func (*UnimplementedFlowRpcServer) ListWorkflowInstance added in v0.10.0 

func (*UnimplementedFlowRpcServer) ListWorkflowInstance(ctx context.Context, req *ListWorkflowInstanceRequest) (*ListWorkflowInstanceResponse, error)

func (*UnimplementedFlowRpcServer) PauseWorkflowInstance added in v0.10.0 

func (*UnimplementedFlowRpcServer) PauseWorkflowInstance(ctx context.Context, req *PauseWorkflowInstanceRequest) (*PauseWorkflowInstanceResponse, error)

func (*UnimplementedFlowRpcServer) Pipe 

func (*UnimplementedFlowRpcServer) Pipe(srv FlowRpc_PipeServer) error

func (*UnimplementedFlowRpcServer) Register 

func (*UnimplementedFlowRpcServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterResponse, error)

func (*UnimplementedFlowRpcServer) ResumeWorkflowInstance added in v0.10.0 

func (*UnimplementedFlowRpcServer) ResumeWorkflowInstance(ctx context.Context, req *ResumeWorkflowInstanceRequest) (*ResumeWorkflowInstanceResponse, error)

func (*UnimplementedFlowRpcServer) Step 

func (*UnimplementedFlowRpcServer) Step(ctx context.Context, req *StepRequest) (*StepResponse, error)

func (*UnimplementedFlowRpcServer) StepGet 

func (*UnimplementedFlowRpcServer) StepGet(ctx context.Context, req *StepGetRequest) (*StepGetResponse, error)

func (*UnimplementedFlowRpcServer) StepPut 

func (*UnimplementedFlowRpcServer) StepPut(ctx context.Context, req *StepPutRequest) (*StepPutResponse, error)

func (*UnimplementedFlowRpcServer) StepTrace 

func (*UnimplementedFlowRpcServer) StepTrace(ctx context.Context, req *StepTraceRequest) (*StepTraceResponse, error)

func (*UnimplementedFlowRpcServer) WatchWorkflowInstance added in v0.10.0 

func (*UnimplementedFlowRpcServer) WatchWorkflowInstance(req *WatchWorkflowInstanceRequest, srv FlowRpc_WatchWorkflowInstanceServer) error

func (*UnimplementedFlowRpcServer) WorkHook added in v0.12.2 

func (*UnimplementedFlowRpcServer) WorkHook(req *WorkHookRequest, srv FlowRpc_WorkHookServer) error

type WatchWorkflowInstanceRequest added in v0.10.0 

type WatchWorkflowInstanceRequest struct {
	// +gen:required
	Wid string `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
	// +gen:required
	Cid string `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`
}

func (*WatchWorkflowInstanceRequest) Descriptor added in v0.10.0 

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

func (*WatchWorkflowInstanceRequest) Marshal added in v0.10.0 

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

func (*WatchWorkflowInstanceRequest) MarshalTo added in v0.10.0 

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

func (*WatchWorkflowInstanceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*WatchWorkflowInstanceRequest) ProtoMessage added in v0.10.0 

func (*WatchWorkflowInstanceRequest) ProtoMessage()

func (*WatchWorkflowInstanceRequest) Reset added in v0.10.0 

func (m *WatchWorkflowInstanceRequest) Reset()

func (*WatchWorkflowInstanceRequest) String added in v0.10.0 

func (m *WatchWorkflowInstanceRequest) String() string

func (*WatchWorkflowInstanceRequest) Unmarshal added in v0.10.0 

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

func (*WatchWorkflowInstanceRequest) Validate added in v0.10.0 

func (m *WatchWorkflowInstanceRequest) Validate() error

func (*WatchWorkflowInstanceRequest) ValidateE added in v0.10.0 

func (m *WatchWorkflowInstanceRequest) ValidateE(prefix string) error

func (*WatchWorkflowInstanceRequest) XSize added in v0.10.0 

func (m *WatchWorkflowInstanceRequest) XSize() (n int)

func (*WatchWorkflowInstanceRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *WatchWorkflowInstanceRequest) XXX_DiscardUnknown()

func (*WatchWorkflowInstanceRequest) XXX_Marshal added in v0.10.0 

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

func (*WatchWorkflowInstanceRequest) XXX_Merge added in v0.10.0 

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

func (*WatchWorkflowInstanceRequest) XXX_Size added in v0.10.0 

func (m *WatchWorkflowInstanceRequest) XXX_Size() int

func (*WatchWorkflowInstanceRequest) XXX_Unmarshal added in v0.10.0 

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

type WatchWorkflowInstanceResponse added in v0.10.0 

type WatchWorkflowInstanceResponse struct {
	Result *WorkflowWatchResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*WatchWorkflowInstanceResponse) Descriptor added in v0.10.0 

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

func (*WatchWorkflowInstanceResponse) Marshal added in v0.10.0 

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

func (*WatchWorkflowInstanceResponse) MarshalTo added in v0.10.0 

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

func (*WatchWorkflowInstanceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*WatchWorkflowInstanceResponse) ProtoMessage added in v0.10.0 

func (*WatchWorkflowInstanceResponse) ProtoMessage()

func (*WatchWorkflowInstanceResponse) Reset added in v0.10.0 

func (m *WatchWorkflowInstanceResponse) Reset()

func (*WatchWorkflowInstanceResponse) String added in v0.10.0 

func (m *WatchWorkflowInstanceResponse) String() string

func (*WatchWorkflowInstanceResponse) Unmarshal added in v0.10.0 

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

func (*WatchWorkflowInstanceResponse) Validate added in v0.10.0 

func (m *WatchWorkflowInstanceResponse) Validate() error

func (*WatchWorkflowInstanceResponse) ValidateE added in v0.10.0 

func (m *WatchWorkflowInstanceResponse) ValidateE(prefix string) error

func (*WatchWorkflowInstanceResponse) XSize added in v0.10.0 

func (m *WatchWorkflowInstanceResponse) XSize() (n int)

func (*WatchWorkflowInstanceResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *WatchWorkflowInstanceResponse) XXX_DiscardUnknown()

func (*WatchWorkflowInstanceResponse) XXX_Marshal added in v0.10.0 

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

func (*WatchWorkflowInstanceResponse) XXX_Merge added in v0.10.0 

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

func (*WatchWorkflowInstanceResponse) XXX_Size added in v0.10.0 

func (m *WatchWorkflowInstanceResponse) XXX_Size() int

func (*WatchWorkflowInstanceResponse) XXX_Unmarshal added in v0.10.0 

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

type WorkHookRequest added in v0.12.2 

type WorkHookRequest struct {
}

func (*WorkHookRequest) Descriptor added in v0.12.2 

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

func (*WorkHookRequest) Marshal added in v0.12.2 

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

func (*WorkHookRequest) MarshalTo added in v0.12.2 

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

func (*WorkHookRequest) MarshalToSizedBuffer added in v0.12.2 

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

func (*WorkHookRequest) ProtoMessage added in v0.12.2 

func (*WorkHookRequest) ProtoMessage()

func (*WorkHookRequest) Reset added in v0.12.2 

func (m *WorkHookRequest) Reset()

func (*WorkHookRequest) String added in v0.12.2 

func (m *WorkHookRequest) String() string

func (*WorkHookRequest) Unmarshal added in v0.12.2 

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

func (*WorkHookRequest) Validate added in v0.12.2 

func (m *WorkHookRequest) Validate() error

func (*WorkHookRequest) ValidateE added in v0.12.2 

func (m *WorkHookRequest) ValidateE(prefix string) error

func (*WorkHookRequest) XSize added in v0.12.2 

func (m *WorkHookRequest) XSize() (n int)

func (*WorkHookRequest) XXX_DiscardUnknown added in v0.12.2 

func (m *WorkHookRequest) XXX_DiscardUnknown()

func (*WorkHookRequest) XXX_Marshal added in v0.12.2 

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

func (*WorkHookRequest) XXX_Merge added in v0.12.2 

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

func (*WorkHookRequest) XXX_Size added in v0.12.2 

func (m *WorkHookRequest) XXX_Size() int

func (*WorkHookRequest) XXX_Unmarshal added in v0.12.2 

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

type WorkHookResponse added in v0.12.2 

type WorkHookResponse struct {
	Result *WorkHookResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*WorkHookResponse) Descriptor added in v0.12.2 

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

func (*WorkHookResponse) Marshal added in v0.12.2 

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

func (*WorkHookResponse) MarshalTo added in v0.12.2 

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

func (*WorkHookResponse) MarshalToSizedBuffer added in v0.12.2 

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

func (*WorkHookResponse) ProtoMessage added in v0.12.2 

func (*WorkHookResponse) ProtoMessage()

func (*WorkHookResponse) Reset added in v0.12.2 

func (m *WorkHookResponse) Reset()

func (*WorkHookResponse) String added in v0.12.2 

func (m *WorkHookResponse) String() string

func (*WorkHookResponse) Unmarshal added in v0.12.2 

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

func (*WorkHookResponse) Validate added in v0.12.2 

func (m *WorkHookResponse) Validate() error

func (*WorkHookResponse) ValidateE added in v0.12.2 

func (m *WorkHookResponse) ValidateE(prefix string) error

func (*WorkHookResponse) XSize added in v0.12.2 

func (m *WorkHookResponse) XSize() (n int)

func (*WorkHookResponse) XXX_DiscardUnknown added in v0.12.2 

func (m *WorkHookResponse) XXX_DiscardUnknown()

func (*WorkHookResponse) XXX_Marshal added in v0.12.2 

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

func (*WorkHookResponse) XXX_Merge added in v0.12.2 

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

func (*WorkHookResponse) XXX_Size added in v0.12.2 

func (m *WorkHookResponse) XXX_Size() int

func (*WorkHookResponse) XXX_Unmarshal added in v0.12.2 

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

type WorkHookResult added in v0.12.2 

type WorkHookResult struct {
	Action HookAction `protobuf:"varint,1,opt,name=action,proto3,enum=api.HookAction" json:"action,omitempty"`
	Worker *Worker    `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
}

func (*WorkHookResult) DeepCopyInto added in v0.12.2 

func (in *WorkHookResult) DeepCopyInto(out *WorkHookResult)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*WorkHookResult) Descriptor added in v0.12.2 

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

func (*WorkHookResult) Marshal added in v0.12.2 

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

func (*WorkHookResult) MarshalTo added in v0.12.2 

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

func (*WorkHookResult) MarshalToSizedBuffer added in v0.12.2 

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

func (*WorkHookResult) ProtoMessage added in v0.12.2 

func (*WorkHookResult) ProtoMessage()

func (*WorkHookResult) Reset added in v0.12.2 

func (m *WorkHookResult) Reset()

func (*WorkHookResult) String added in v0.12.2 

func (m *WorkHookResult) String() string

func (*WorkHookResult) Unmarshal added in v0.12.2 

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

func (*WorkHookResult) Validate added in v0.12.2 

func (m *WorkHookResult) Validate() error

func (*WorkHookResult) ValidateE added in v0.12.2 

func (m *WorkHookResult) ValidateE(prefix string) error

func (*WorkHookResult) XSize added in v0.12.2 

func (m *WorkHookResult) XSize() (n int)

func (*WorkHookResult) XXX_DiscardUnknown added in v0.12.2 

func (m *WorkHookResult) XXX_DiscardUnknown()

func (*WorkHookResult) XXX_Marshal added in v0.12.2 

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

func (*WorkHookResult) XXX_Merge added in v0.12.2 

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

func (*WorkHookResult) XXX_Size added in v0.12.2 

func (m *WorkHookResult) XXX_Size() int

func (*WorkHookResult) XXX_Unmarshal added in v0.12.2 

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

type Worker 

type Worker struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Endpoint string            `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Attrs    map[string]string `` /* 151-byte string literal not displayed */
	Up       bool              `protobuf:"varint,4,opt,name=up,proto3" json:"up,omitempty"`
}

+gen:deepcopy

func (*Worker) DeepCopy 

func (in *Worker) DeepCopy() *Worker

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new Worker.

func (*Worker) DeepCopyInto 

func (in *Worker) DeepCopyInto(out *Worker)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Worker) Descriptor 

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

func (*Worker) Marshal 

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

func (*Worker) MarshalTo 

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

func (*Worker) MarshalToSizedBuffer 

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

func (*Worker) ProtoMessage 

func (*Worker) ProtoMessage()

func (*Worker) Reset 

func (m *Worker) Reset()

func (*Worker) String 

func (m *Worker) String() string

func (*Worker) Unmarshal 

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

func (*Worker) Validate 

func (m *Worker) Validate() error

func (*Worker) ValidateE 

func (m *Worker) ValidateE(prefix string) error

func (*Worker) XSize 

func (m *Worker) XSize() (n int)

func (*Worker) XXX_DiscardUnknown 

func (m *Worker) XXX_DiscardUnknown()

func (*Worker) XXX_Marshal 

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

func (*Worker) XXX_Merge 

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

func (*Worker) XXX_Size 

func (m *Worker) XXX_Size() int

func (*Worker) XXX_Unmarshal 

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

type Workflow 

type Workflow struct {
	Option   *WorkflowOption   `protobuf:"bytes,1,opt,name=option,proto3" json:"option,omitempty"`
	Entities map[string]string `` /* 157-byte string literal not displayed */
	Items    map[string]string `` /* 151-byte string literal not displayed */
	Steps    []*WorkflowStep   `protobuf:"bytes,4,rep,name=steps,proto3" json:"steps,omitempty"`
	Status   *WorkflowStatus   `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
}

+gen:deepcopy

func (*Workflow) DeepCopy 

func (in *Workflow) DeepCopy() *Workflow

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new Workflow.

func (*Workflow) DeepCopyInto 

func (in *Workflow) DeepCopyInto(out *Workflow)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*Workflow) Descriptor 

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

func (*Workflow) Marshal 

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

func (*Workflow) MarshalTo 

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

func (*Workflow) MarshalToSizedBuffer 

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

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) Reset 

func (m *Workflow) Reset()

func (*Workflow) String 

func (m *Workflow) String() string

func (*Workflow) Unmarshal 

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

func (*Workflow) Validate 

func (m *Workflow) Validate() error

func (*Workflow) ValidateE 

func (m *Workflow) ValidateE(prefix string) error

func (*Workflow) XSize 

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

func (*Workflow) XXX_DiscardUnknown 

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal 

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

func (*Workflow) XXX_Merge 

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

func (*Workflow) XXX_Size 

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal 

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

type WorkflowOption 

type WorkflowOption struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Wid        string `protobuf:"bytes,2,opt,name=wid,proto3" json:"wid,omitempty"`
	InstanceId string `protobuf:"bytes,3,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	MaxRetries int32  `protobuf:"varint,4,opt,name=maxRetries,proto3" json:"maxRetries,omitempty"`
}

+gen:deepcopy

func (*WorkflowOption) DeepCopy 

func (in *WorkflowOption) DeepCopy() *WorkflowOption

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new WorkflowOption.

func (*WorkflowOption) DeepCopyInto 

func (in *WorkflowOption) DeepCopyInto(out *WorkflowOption)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*WorkflowOption) Descriptor 

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

func (*WorkflowOption) Marshal 

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

func (*WorkflowOption) MarshalTo 

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

func (*WorkflowOption) MarshalToSizedBuffer 

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

func (*WorkflowOption) ProtoMessage 

func (*WorkflowOption) ProtoMessage()

func (*WorkflowOption) Reset 

func (m *WorkflowOption) Reset()

func (*WorkflowOption) String 

func (m *WorkflowOption) String() string

func (*WorkflowOption) Unmarshal 

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

func (*WorkflowOption) Validate 

func (m *WorkflowOption) Validate() error

func (*WorkflowOption) ValidateE 

func (m *WorkflowOption) ValidateE(prefix string) error

func (*WorkflowOption) XSize 

func (m *WorkflowOption) XSize() (n int)

func (*WorkflowOption) XXX_DiscardUnknown 

func (m *WorkflowOption) XXX_DiscardUnknown()

func (*WorkflowOption) XXX_Marshal 

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

func (*WorkflowOption) XXX_Merge 

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

func (*WorkflowOption) XXX_Size 

func (m *WorkflowOption) XXX_Size() int

func (*WorkflowOption) XXX_Unmarshal 

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

type WorkflowSnapshot 

type WorkflowSnapshot struct {
	Name       string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Wid        string        `protobuf:"bytes,2,opt,name=wid,proto3" json:"wid,omitempty"`
	InstanceId string        `protobuf:"bytes,3,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Step       string        `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"`
	Action     StepAction    `protobuf:"varint,5,opt,name=action,proto3,enum=api.StepAction" json:"action,omitempty"`
	State      WorkflowState `protobuf:"varint,6,opt,name=state,proto3,enum=api.WorkflowState" json:"state,omitempty"`
}

+gen:deepcopy

func (*WorkflowSnapshot) DeepCopy 

func (in *WorkflowSnapshot) DeepCopy() *WorkflowSnapshot

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new WorkflowSnapshot.

func (*WorkflowSnapshot) DeepCopyInto 

func (in *WorkflowSnapshot) DeepCopyInto(out *WorkflowSnapshot)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*WorkflowSnapshot) Descriptor 

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

func (*WorkflowSnapshot) Marshal 

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

func (*WorkflowSnapshot) MarshalTo 

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

func (*WorkflowSnapshot) MarshalToSizedBuffer 

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

func (*WorkflowSnapshot) ProtoMessage 

func (*WorkflowSnapshot) ProtoMessage()

func (*WorkflowSnapshot) Reset 

func (m *WorkflowSnapshot) Reset()

func (*WorkflowSnapshot) String 

func (m *WorkflowSnapshot) String() string

func (*WorkflowSnapshot) Unmarshal 

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

func (*WorkflowSnapshot) Validate 

func (m *WorkflowSnapshot) Validate() error

func (*WorkflowSnapshot) ValidateE 

func (m *WorkflowSnapshot) ValidateE(prefix string) error

func (*WorkflowSnapshot) XSize 

func (m *WorkflowSnapshot) XSize() (n int)

func (*WorkflowSnapshot) XXX_DiscardUnknown 

func (m *WorkflowSnapshot) XXX_DiscardUnknown()

func (*WorkflowSnapshot) XXX_Marshal 

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

func (*WorkflowSnapshot) XXX_Merge 

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

func (*WorkflowSnapshot) XXX_Size 

func (m *WorkflowSnapshot) XXX_Size() int

func (*WorkflowSnapshot) XXX_Unmarshal 

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

type WorkflowState 

type WorkflowState int32
const (
	// 位置状态
	WorkflowState_SW_UNKNOWN WorkflowState = 0
	// 暂停状态, 工作流为人工干预模式下，发生错误或进入这个状态
	WorkflowState_SW_PAUSE WorkflowState = 1
	// 工作流正在执行，处理 prepare 和 commit 状态
	WorkflowState_SW_RUNNING WorkflowState = 2
	// 工作流逻辑已经执行完成，全部步骤执行成功
	WorkflowState_SW_SUCCESS WorkflowState = 3
	// 工作流执行结束，在 cancel 阶段出现错误
	WorkflowState_SW_WARN WorkflowState = 4
	// 工作流执行结束，在 prepare 和 commit 出现错误
	WorkflowState_SW_FAILED WorkflowState = 5
)

func (WorkflowState) EnumDescriptor 

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

func (*WorkflowState) MarshalJSON 

func (m *WorkflowState) MarshalJSON() ([]byte, error)

func (WorkflowState) Readably 

func (m WorkflowState) Readably() string

func (WorkflowState) String 

func (x WorkflowState) String() string

func (*WorkflowState) UnmarshalJSON 

func (m *WorkflowState) UnmarshalJSON(data []byte) error

type WorkflowStatus 

type WorkflowStatus struct {
	State    WorkflowState   `protobuf:"varint,1,opt,name=state,proto3,enum=api.WorkflowState" json:"state,omitempty"`
	Option   *WorkflowOption `protobuf:"bytes,2,opt,name=option,proto3" json:"option,omitempty"`
	Msg      string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	Action   StepAction      `protobuf:"varint,4,opt,name=action,proto3,enum=api.StepAction" json:"action,omitempty"`
	Progress string          `protobuf:"bytes,5,opt,name=progress,proto3" json:"progress,omitempty"`
	Step     string          `protobuf:"bytes,6,opt,name=step,proto3" json:"step,omitempty"`
}

+gen:deepcopy

func (*WorkflowStatus) DeepCopy 

func (in *WorkflowStatus) DeepCopy() *WorkflowStatus

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new WorkflowStatus.

func (*WorkflowStatus) DeepCopyInto 

func (in *WorkflowStatus) DeepCopyInto(out *WorkflowStatus)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*WorkflowStatus) Descriptor 

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

func (*WorkflowStatus) Marshal 

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

func (*WorkflowStatus) MarshalTo 

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

func (*WorkflowStatus) MarshalToSizedBuffer 

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

func (*WorkflowStatus) ProtoMessage 

func (*WorkflowStatus) ProtoMessage()

func (*WorkflowStatus) Reset 

func (m *WorkflowStatus) Reset()

func (*WorkflowStatus) String 

func (m *WorkflowStatus) String() string

func (*WorkflowStatus) Unmarshal 

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

func (*WorkflowStatus) Validate 

func (m *WorkflowStatus) Validate() error

func (*WorkflowStatus) ValidateE 

func (m *WorkflowStatus) ValidateE(prefix string) error

func (*WorkflowStatus) XSize 

func (m *WorkflowStatus) XSize() (n int)

func (*WorkflowStatus) XXX_DiscardUnknown 

func (m *WorkflowStatus) XXX_DiscardUnknown()

func (*WorkflowStatus) XXX_Marshal 

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

func (*WorkflowStatus) XXX_Merge 

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

func (*WorkflowStatus) XXX_Size 

func (m *WorkflowStatus) XXX_Size() int

func (*WorkflowStatus) XXX_Unmarshal 

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

type WorkflowStep 

type WorkflowStep struct {
	Name     string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Uid      string               `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Describe string               `protobuf:"bytes,3,opt,name=describe,proto3" json:"describe,omitempty"`
	Worker   string               `protobuf:"bytes,4,opt,name=worker,proto3" json:"worker,omitempty"`
	Entity   string               `protobuf:"bytes,5,opt,name=entity,proto3" json:"entity,omitempty"`
	EntityId string               `protobuf:"bytes,6,opt,name=entityId,proto3" json:"entityId,omitempty"`
	Injects  []string             `protobuf:"bytes,7,rep,name=injects,proto3" json:"injects,omitempty"`
	Logs     []string             `protobuf:"bytes,8,rep,name=logs,proto3" json:"logs,omitempty"`
	Retries  int32                `protobuf:"varint,9,opt,name=retries,proto3" json:"retries,omitempty"`
	Stages   []*WorkflowStepStage `protobuf:"bytes,10,rep,name=stages,proto3" json:"stages,omitempty"`
}

+gen:deepcopy

func (*WorkflowStep) DeepCopy 

func (in *WorkflowStep) DeepCopy() *WorkflowStep

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new WorkflowStep.

func (*WorkflowStep) DeepCopyInto 

func (in *WorkflowStep) DeepCopyInto(out *WorkflowStep)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*WorkflowStep) Descriptor 

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

func (*WorkflowStep) Marshal 

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

func (*WorkflowStep) MarshalTo 

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

func (*WorkflowStep) MarshalToSizedBuffer 

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

func (*WorkflowStep) ProtoMessage 

func (*WorkflowStep) ProtoMessage()

func (*WorkflowStep) Reset 

func (m *WorkflowStep) Reset()

func (*WorkflowStep) String 

func (m *WorkflowStep) String() string

func (*WorkflowStep) Unmarshal 

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

func (*WorkflowStep) Validate 

func (m *WorkflowStep) Validate() error

func (*WorkflowStep) ValidateE 

func (m *WorkflowStep) ValidateE(prefix string) error

func (*WorkflowStep) XSize 

func (m *WorkflowStep) XSize() (n int)

func (*WorkflowStep) XXX_DiscardUnknown 

func (m *WorkflowStep) XXX_DiscardUnknown()

func (*WorkflowStep) XXX_Marshal 

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

func (*WorkflowStep) XXX_Merge 

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

func (*WorkflowStep) XXX_Size 

func (m *WorkflowStep) XXX_Size() int

func (*WorkflowStep) XXX_Unmarshal 

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

type WorkflowStepStage added in v0.9.0 

type WorkflowStepStage struct {
	Action         StepAction    `protobuf:"varint,1,opt,name=action,proto3,enum=api.StepAction" json:"action,omitempty"`
	State          WorkflowState `protobuf:"varint,2,opt,name=state,proto3,enum=api.WorkflowState" json:"state,omitempty"`
	ErrorMsg       string        `protobuf:"bytes,3,opt,name=errorMsg,proto3" json:"errorMsg,omitempty"`
	StartTimestamp int64         `protobuf:"varint,4,opt,name=startTimestamp,proto3" json:"startTimestamp,omitempty"`
	EndTimestamp   int64         `protobuf:"varint,5,opt,name=endTimestamp,proto3" json:"endTimestamp,omitempty"`
}

func (*WorkflowStepStage) DeepCopyInto added in v0.9.0 

func (in *WorkflowStepStage) DeepCopyInto(out *WorkflowStepStage)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*WorkflowStepStage) Descriptor added in v0.9.0 

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

func (*WorkflowStepStage) Marshal added in v0.9.0 

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

func (*WorkflowStepStage) MarshalTo added in v0.9.0 

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

func (*WorkflowStepStage) MarshalToSizedBuffer added in v0.9.0 

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

func (*WorkflowStepStage) ProtoMessage added in v0.9.0 

func (*WorkflowStepStage) ProtoMessage()

func (*WorkflowStepStage) Reset added in v0.9.0 

func (m *WorkflowStepStage) Reset()

func (*WorkflowStepStage) String added in v0.9.0 

func (m *WorkflowStepStage) String() string

func (*WorkflowStepStage) Unmarshal added in v0.9.0 

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

func (*WorkflowStepStage) Validate added in v0.9.0 

func (m *WorkflowStepStage) Validate() error

func (*WorkflowStepStage) ValidateE added in v0.9.0 

func (m *WorkflowStepStage) ValidateE(prefix string) error

func (*WorkflowStepStage) XSize added in v0.9.0 

func (m *WorkflowStepStage) XSize() (n int)

func (*WorkflowStepStage) XXX_DiscardUnknown added in v0.9.0 

func (m *WorkflowStepStage) XXX_DiscardUnknown()

func (*WorkflowStepStage) XXX_Marshal added in v0.9.0 

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

func (*WorkflowStepStage) XXX_Merge added in v0.9.0 

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

func (*WorkflowStepStage) XXX_Size added in v0.9.0 

func (m *WorkflowStepStage) XXX_Size() int

func (*WorkflowStepStage) XXX_Unmarshal added in v0.9.0 

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

type WorkflowWatchResult 

type WorkflowWatchResult struct {
	Name       string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Wid        string    `protobuf:"bytes,2,opt,name=wid,proto3" json:"wid,omitempty"`
	InstanceId string    `protobuf:"bytes,3,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Type       EventType `protobuf:"varint,4,opt,name=type,proto3,enum=api.EventType" json:"type,omitempty"`
	Key        string    `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	Value      []byte    `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
}

+gen:deepcopy

func (*WorkflowWatchResult) DeepCopy 

func (in *WorkflowWatchResult) DeepCopy() *WorkflowWatchResult

DeepCopy is an auto-generated deepcopy function, copying the receiver, creating a new WorkflowWatchResult.

func (*WorkflowWatchResult) DeepCopyInto 

func (in *WorkflowWatchResult) DeepCopyInto(out *WorkflowWatchResult)

DeepCopyInto is an auto-generated deepcopy function, coping the receiver, writing into out. in must be no-nil.

func (*WorkflowWatchResult) Descriptor 

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

func (*WorkflowWatchResult) Marshal 

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

func (*WorkflowWatchResult) MarshalTo 

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

func (*WorkflowWatchResult) MarshalToSizedBuffer 

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

func (*WorkflowWatchResult) ProtoMessage 

func (*WorkflowWatchResult) ProtoMessage()

func (*WorkflowWatchResult) Reset 

func (m *WorkflowWatchResult) Reset()

func (*WorkflowWatchResult) String 

func (m *WorkflowWatchResult) String() string

func (*WorkflowWatchResult) Unmarshal 

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

func (*WorkflowWatchResult) Validate 

func (m *WorkflowWatchResult) Validate() error

func (*WorkflowWatchResult) ValidateE 

func (m *WorkflowWatchResult) ValidateE(prefix string) error

func (*WorkflowWatchResult) XSize 

func (m *WorkflowWatchResult) XSize() (n int)

func (*WorkflowWatchResult) XXX_DiscardUnknown 

func (m *WorkflowWatchResult) XXX_DiscardUnknown()

func (*WorkflowWatchResult) XXX_Marshal 

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

func (*WorkflowWatchResult) XXX_Merge 

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

func (*WorkflowWatchResult) XXX_Size 

func (m *WorkflowWatchResult) XXX_Size() int

func (*WorkflowWatchResult) XXX_Unmarshal 

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