api

package
v0.9.2 Latest Latest
Warning

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

 Go to latest Published: May 6, 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 EventAction_name = map[int32]string{
	0: "EA_UNKNOWN",
	1: "EA_CREATE",
	2: "EA_UPDATE",
	3: "EA_DELETE",
}
View Source 
var EventAction_value = map[string]int32{
	"EA_UNKNOWN": 0,
	"EA_CREATE":  1,
	"EA_UPDATE":  2,
	"EA_DELETE":  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_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_RESULT":   6,
}
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 WorkflowMode_name = map[int32]string{
	0: "WM_UNKNOWN",
	1: "WM_AUTO",
	2: "WM_ABORT",
	3: "WM_MANUAL",
	4: "WM_HYBRID",
}
View Source 
var WorkflowMode_value = map[string]int32{
	"WM_UNKNOWN": 0,
	"WM_AUTO":    1,
	"WM_ABORT":   2,
	"WM_MANUAL":  3,
	"WM_HYBRID":  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 AbortWorkflowRequest 

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

func (*AbortWorkflowRequest) Descriptor 

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

func (*AbortWorkflowRequest) Marshal 

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

func (*AbortWorkflowRequest) MarshalTo 

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

func (*AbortWorkflowRequest) MarshalToSizedBuffer 

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

func (*AbortWorkflowRequest) ProtoMessage 

func (*AbortWorkflowRequest) ProtoMessage()

func (*AbortWorkflowRequest) Reset 

func (m *AbortWorkflowRequest) Reset()

func (*AbortWorkflowRequest) String 

func (m *AbortWorkflowRequest) String() string

func (*AbortWorkflowRequest) Unmarshal 

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

func (*AbortWorkflowRequest) Validate 

func (m *AbortWorkflowRequest) Validate() error

func (*AbortWorkflowRequest) ValidateE 

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

func (*AbortWorkflowRequest) XSize 

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

func (*AbortWorkflowRequest) XXX_DiscardUnknown 

func (m *AbortWorkflowRequest) XXX_DiscardUnknown()

func (*AbortWorkflowRequest) XXX_Marshal 

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

func (*AbortWorkflowRequest) XXX_Merge 

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

func (*AbortWorkflowRequest) XXX_Size 

func (m *AbortWorkflowRequest) XXX_Size() int

func (*AbortWorkflowRequest) XXX_Unmarshal 

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

type AbortWorkflowResponse 

type AbortWorkflowResponse struct {
}

func (*AbortWorkflowResponse) Descriptor 

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

func (*AbortWorkflowResponse) Marshal 

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

func (*AbortWorkflowResponse) MarshalTo 

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

func (*AbortWorkflowResponse) MarshalToSizedBuffer 

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

func (*AbortWorkflowResponse) ProtoMessage 

func (*AbortWorkflowResponse) ProtoMessage()

func (*AbortWorkflowResponse) Reset 

func (m *AbortWorkflowResponse) Reset()

func (*AbortWorkflowResponse) String 

func (m *AbortWorkflowResponse) String() string

func (*AbortWorkflowResponse) Unmarshal 

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

func (*AbortWorkflowResponse) Validate 

func (m *AbortWorkflowResponse) Validate() error

func (*AbortWorkflowResponse) ValidateE 

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

func (*AbortWorkflowResponse) XSize 

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

func (*AbortWorkflowResponse) XXX_DiscardUnknown 

func (m *AbortWorkflowResponse) XXX_DiscardUnknown()

func (*AbortWorkflowResponse) XXX_Marshal 

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

func (*AbortWorkflowResponse) XXX_Merge 

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

func (*AbortWorkflowResponse) XXX_Size 

func (m *AbortWorkflowResponse) XXX_Size() int

func (*AbortWorkflowResponse) XXX_Unmarshal 

func (m *AbortWorkflowResponse) 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 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) Desc added in v0.2.1 

func (m *Echo) Desc() string

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) OwnerReferences added in v0.9.2 

func (m *Echo) OwnerReferences() []*OwnerReference

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             []byte             `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 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"`
}

+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) 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 EventAction 

type EventAction int32
const (
	EventAction_EA_UNKNOWN EventAction = 0
	EventAction_EA_CREATE  EventAction = 1
	EventAction_EA_UPDATE  EventAction = 2
	EventAction_EA_DELETE  EventAction = 3
)

func (EventAction) EnumDescriptor 

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

func (EventAction) String 

func (x EventAction) String() string

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_RESULT   EventType = 6
)

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type FlowRpcClient 

type FlowRpcClient interface {
	ListWorker(ctx context.Context, in *ListWorkerRequest, opts ...grpc.CallOption) (*ListWorkerResponse, error)
	ListRegistry(ctx context.Context, in *ListRegistryRequest, opts ...grpc.CallOption) (*ListRegistryResponse, error)
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, 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)
	ListWorkflow(ctx context.Context, in *ListWorkflowRequest, opts ...grpc.CallOption) (*ListWorkflowResponse, error)
	RunWorkflow(ctx context.Context, in *RunWorkflowRequest, opts ...grpc.CallOption) (FlowRpc_RunWorkflowClient, error)
	InspectWorkflow(ctx context.Context, in *InspectWorkflowRequest, opts ...grpc.CallOption) (*InspectWorkflowResponse, error)
	AbortWorkflow(ctx context.Context, in *AbortWorkflowRequest, opts ...grpc.CallOption) (*AbortWorkflowResponse, error)
	PauseWorkflow(ctx context.Context, in *PauseWorkflowRequest, opts ...grpc.CallOption) (*PauseWorkflowResponse, error)
	ResumeWorkflow(ctx context.Context, in *ResumeWorkflowRequest, opts ...grpc.CallOption) (*ResumeWorkflowResponse, error)
	WatchWorkflow(ctx context.Context, in *WatchWorkflowRequest, opts ...grpc.CallOption) (FlowRpc_WatchWorkflowClient, 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
	ListRegistry(context.Context, *ListRegistryRequest, *ListRegistryResponse) error
	Register(context.Context, *RegisterRequest, *RegisterResponse) error
	Call(context.Context, *CallRequest, *CallResponse) error
	Step(context.Context, *StepRequest, *StepResponse) error
	Pipe(context.Context, FlowRpc_PipeStream) error
	ListWorkflow(context.Context, *ListWorkflowRequest, *ListWorkflowResponse) error
	RunWorkflow(context.Context, *RunWorkflowRequest, FlowRpc_RunWorkflowStream) error
	InspectWorkflow(context.Context, *InspectWorkflowRequest, *InspectWorkflowResponse) error
	AbortWorkflow(context.Context, *AbortWorkflowRequest, *AbortWorkflowResponse) error
	PauseWorkflow(context.Context, *PauseWorkflowRequest, *PauseWorkflowResponse) error
	ResumeWorkflow(context.Context, *ResumeWorkflowRequest, *ResumeWorkflowResponse) error
	WatchWorkflow(context.Context, *WatchWorkflowRequest, FlowRpc_WatchWorkflowStream) 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)
	ListRegistry(context.Context, *ListRegistryRequest) (*ListRegistryResponse, error)
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	Call(context.Context, *CallRequest) (*CallResponse, error)
	Step(context.Context, *StepRequest) (*StepResponse, error)
	Pipe(FlowRpc_PipeServer) error
	ListWorkflow(context.Context, *ListWorkflowRequest) (*ListWorkflowResponse, error)
	RunWorkflow(*RunWorkflowRequest, FlowRpc_RunWorkflowServer) error
	InspectWorkflow(context.Context, *InspectWorkflowRequest) (*InspectWorkflowResponse, error)
	AbortWorkflow(context.Context, *AbortWorkflowRequest) (*AbortWorkflowResponse, error)
	PauseWorkflow(context.Context, *PauseWorkflowRequest) (*PauseWorkflowResponse, error)
	ResumeWorkflow(context.Context, *ResumeWorkflowRequest) (*ResumeWorkflowResponse, error)
	WatchWorkflow(*WatchWorkflowRequest, FlowRpc_WatchWorkflowServer) 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)
	ListRegistry(ctx context.Context, in *ListRegistryRequest, opts ...client.CallOption) (*ListRegistryResponse, error)
	Register(ctx context.Context, in *RegisterRequest, opts ...client.CallOption) (*RegisterResponse, 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)
	ListWorkflow(ctx context.Context, in *ListWorkflowRequest, opts ...client.CallOption) (*ListWorkflowResponse, error)
	RunWorkflow(ctx context.Context, in *RunWorkflowRequest, opts ...client.CallOption) (FlowRpc_RunWorkflowService, error)
	InspectWorkflow(ctx context.Context, in *InspectWorkflowRequest, opts ...client.CallOption) (*InspectWorkflowResponse, error)
	AbortWorkflow(ctx context.Context, in *AbortWorkflowRequest, opts ...client.CallOption) (*AbortWorkflowResponse, error)
	PauseWorkflow(ctx context.Context, in *PauseWorkflowRequest, opts ...client.CallOption) (*PauseWorkflowResponse, error)
	ResumeWorkflow(ctx context.Context, in *ResumeWorkflowRequest, opts ...client.CallOption) (*ResumeWorkflowResponse, error)
	WatchWorkflow(ctx context.Context, in *WatchWorkflowRequest, opts ...client.CallOption) (FlowRpc_WatchWorkflowService, 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_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_RunWorkflowClient 

type FlowRpc_RunWorkflowClient interface {
	Recv() (*RunWorkflowResponse, error)
	grpc.ClientStream
}

type FlowRpc_RunWorkflowServer 

type FlowRpc_RunWorkflowServer interface {
	Send(*RunWorkflowResponse) error
	grpc.ServerStream
}

type FlowRpc_RunWorkflowService 

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

type FlowRpc_RunWorkflowStream 

type FlowRpc_RunWorkflowStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*RunWorkflowResponse) error
}

type FlowRpc_WatchWorkflowClient 

type FlowRpc_WatchWorkflowClient interface {
	Recv() (*WatchWorkflowResponse, error)
	grpc.ClientStream
}

type FlowRpc_WatchWorkflowServer 

type FlowRpc_WatchWorkflowServer interface {
	Send(*WatchWorkflowResponse) error
	grpc.ServerStream
}

type FlowRpc_WatchWorkflowService 

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

type FlowRpc_WatchWorkflowStream 

type FlowRpc_WatchWorkflowStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*WatchWorkflowResponse) error
}

type InspectWorkflowRequest 

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

func (*InspectWorkflowRequest) Descriptor 

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

func (*InspectWorkflowRequest) Marshal 

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

func (*InspectWorkflowRequest) MarshalTo 

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

func (*InspectWorkflowRequest) MarshalToSizedBuffer 

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

func (*InspectWorkflowRequest) ProtoMessage 

func (*InspectWorkflowRequest) ProtoMessage()

func (*InspectWorkflowRequest) Reset 

func (m *InspectWorkflowRequest) Reset()

func (*InspectWorkflowRequest) String 

func (m *InspectWorkflowRequest) String() string

func (*InspectWorkflowRequest) Unmarshal 

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

func (*InspectWorkflowRequest) Validate 

func (m *InspectWorkflowRequest) Validate() error

func (*InspectWorkflowRequest) ValidateE 

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

func (*InspectWorkflowRequest) XSize 

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

func (*InspectWorkflowRequest) XXX_DiscardUnknown 

func (m *InspectWorkflowRequest) XXX_DiscardUnknown()

func (*InspectWorkflowRequest) XXX_Marshal 

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

func (*InspectWorkflowRequest) XXX_Merge 

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

func (*InspectWorkflowRequest) XXX_Size 

func (m *InspectWorkflowRequest) XXX_Size() int

func (*InspectWorkflowRequest) XXX_Unmarshal 

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

type InspectWorkflowResponse 

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

func (*InspectWorkflowResponse) Descriptor 

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

func (*InspectWorkflowResponse) Marshal 

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

func (*InspectWorkflowResponse) MarshalTo 

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

func (*InspectWorkflowResponse) MarshalToSizedBuffer 

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

func (*InspectWorkflowResponse) ProtoMessage 

func (*InspectWorkflowResponse) ProtoMessage()

func (*InspectWorkflowResponse) Reset 

func (m *InspectWorkflowResponse) Reset()

func (*InspectWorkflowResponse) String 

func (m *InspectWorkflowResponse) String() string

func (*InspectWorkflowResponse) Unmarshal 

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

func (*InspectWorkflowResponse) Validate 

func (m *InspectWorkflowResponse) Validate() error

func (*InspectWorkflowResponse) ValidateE 

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

func (*InspectWorkflowResponse) XSize 

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

func (*InspectWorkflowResponse) XXX_DiscardUnknown 

func (m *InspectWorkflowResponse) XXX_DiscardUnknown()

func (*InspectWorkflowResponse) XXX_Marshal 

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

func (*InspectWorkflowResponse) XXX_Merge 

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

func (*InspectWorkflowResponse) XXX_Size 

func (m *InspectWorkflowResponse) XXX_Size() int

func (*InspectWorkflowResponse) XXX_Unmarshal 

func (m *InspectWorkflowResponse) 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 ListWorkflowRequest 

type ListWorkflowRequest struct {
}

func (*ListWorkflowRequest) Descriptor 

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

func (*ListWorkflowRequest) Marshal 

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

func (*ListWorkflowRequest) MarshalTo 

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

func (*ListWorkflowRequest) MarshalToSizedBuffer 

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

func (*ListWorkflowRequest) ProtoMessage 

func (*ListWorkflowRequest) ProtoMessage()

func (*ListWorkflowRequest) Reset 

func (m *ListWorkflowRequest) Reset()

func (*ListWorkflowRequest) String 

func (m *ListWorkflowRequest) String() string

func (*ListWorkflowRequest) Unmarshal 

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

func (*ListWorkflowRequest) Validate 

func (m *ListWorkflowRequest) Validate() error

func (*ListWorkflowRequest) ValidateE 

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

func (*ListWorkflowRequest) XSize 

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

func (*ListWorkflowRequest) XXX_DiscardUnknown 

func (m *ListWorkflowRequest) XXX_DiscardUnknown()

func (*ListWorkflowRequest) XXX_Marshal 

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

func (*ListWorkflowRequest) XXX_Merge 

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

func (*ListWorkflowRequest) XXX_Size 

func (m *ListWorkflowRequest) XXX_Size() int

func (*ListWorkflowRequest) XXX_Unmarshal 

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

type ListWorkflowResponse 

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

func (*ListWorkflowResponse) Descriptor 

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

func (*ListWorkflowResponse) Marshal 

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

func (*ListWorkflowResponse) MarshalTo 

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

func (*ListWorkflowResponse) MarshalToSizedBuffer 

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

func (*ListWorkflowResponse) ProtoMessage 

func (*ListWorkflowResponse) ProtoMessage()

func (*ListWorkflowResponse) Reset 

func (m *ListWorkflowResponse) Reset()

func (*ListWorkflowResponse) String 

func (m *ListWorkflowResponse) String() string

func (*ListWorkflowResponse) Unmarshal 

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

func (*ListWorkflowResponse) Validate 

func (m *ListWorkflowResponse) Validate() error

func (*ListWorkflowResponse) ValidateE 

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

func (*ListWorkflowResponse) XSize 

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

func (*ListWorkflowResponse) XXX_DiscardUnknown 

func (m *ListWorkflowResponse) XXX_DiscardUnknown()

func (*ListWorkflowResponse) XXX_Marshal 

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

func (*ListWorkflowResponse) XXX_Merge 

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

func (*ListWorkflowResponse) XXX_Size 

func (m *ListWorkflowResponse) XXX_Size() int

func (*ListWorkflowResponse) XXX_Unmarshal 

func (m *ListWorkflowResponse) 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 PauseWorkflowRequest 

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

func (*PauseWorkflowRequest) Descriptor 

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

func (*PauseWorkflowRequest) Marshal 

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

func (*PauseWorkflowRequest) MarshalTo 

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

func (*PauseWorkflowRequest) MarshalToSizedBuffer 

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

func (*PauseWorkflowRequest) ProtoMessage 

func (*PauseWorkflowRequest) ProtoMessage()

func (*PauseWorkflowRequest) Reset 

func (m *PauseWorkflowRequest) Reset()

func (*PauseWorkflowRequest) String 

func (m *PauseWorkflowRequest) String() string

func (*PauseWorkflowRequest) Unmarshal 

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

func (*PauseWorkflowRequest) Validate 

func (m *PauseWorkflowRequest) Validate() error

func (*PauseWorkflowRequest) ValidateE 

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

func (*PauseWorkflowRequest) XSize 

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

func (*PauseWorkflowRequest) XXX_DiscardUnknown 

func (m *PauseWorkflowRequest) XXX_DiscardUnknown()

func (*PauseWorkflowRequest) XXX_Marshal 

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

func (*PauseWorkflowRequest) XXX_Merge 

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

func (*PauseWorkflowRequest) XXX_Size 

func (m *PauseWorkflowRequest) XXX_Size() int

func (*PauseWorkflowRequest) XXX_Unmarshal 

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

type PauseWorkflowResponse 

type PauseWorkflowResponse struct {
}

func (*PauseWorkflowResponse) Descriptor 

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

func (*PauseWorkflowResponse) Marshal 

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

func (*PauseWorkflowResponse) MarshalTo 

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

func (*PauseWorkflowResponse) MarshalToSizedBuffer 

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

func (*PauseWorkflowResponse) ProtoMessage 

func (*PauseWorkflowResponse) ProtoMessage()

func (*PauseWorkflowResponse) Reset 

func (m *PauseWorkflowResponse) Reset()

func (*PauseWorkflowResponse) String 

func (m *PauseWorkflowResponse) String() string

func (*PauseWorkflowResponse) Unmarshal 

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

func (*PauseWorkflowResponse) Validate 

func (m *PauseWorkflowResponse) Validate() error

func (*PauseWorkflowResponse) ValidateE 

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

func (*PauseWorkflowResponse) XSize 

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

func (*PauseWorkflowResponse) XXX_DiscardUnknown 

func (m *PauseWorkflowResponse) XXX_DiscardUnknown()

func (*PauseWorkflowResponse) XXX_Marshal 

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

func (*PauseWorkflowResponse) XXX_Merge 

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

func (*PauseWorkflowResponse) XXX_Size 

func (m *PauseWorkflowResponse) XXX_Size() int

func (*PauseWorkflowResponse) XXX_Unmarshal 

func (m *PauseWorkflowResponse) 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"`
	Name   string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Sid    string            `protobuf:"bytes,3,opt,name=sid,proto3" json:"sid,omitempty"`
	Action StepAction        `protobuf:"varint,4,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,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"`
	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 (*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 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 ResumeWorkflowRequest 

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

func (*ResumeWorkflowRequest) Descriptor 

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

func (*ResumeWorkflowRequest) Marshal 

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

func (*ResumeWorkflowRequest) MarshalTo 

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

func (*ResumeWorkflowRequest) MarshalToSizedBuffer 

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

func (*ResumeWorkflowRequest) ProtoMessage 

func (*ResumeWorkflowRequest) ProtoMessage()

func (*ResumeWorkflowRequest) Reset 

func (m *ResumeWorkflowRequest) Reset()

func (*ResumeWorkflowRequest) String 

func (m *ResumeWorkflowRequest) String() string

func (*ResumeWorkflowRequest) Unmarshal 

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

func (*ResumeWorkflowRequest) Validate 

func (m *ResumeWorkflowRequest) Validate() error

func (*ResumeWorkflowRequest) ValidateE 

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

func (*ResumeWorkflowRequest) XSize 

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

func (*ResumeWorkflowRequest) XXX_DiscardUnknown 

func (m *ResumeWorkflowRequest) XXX_DiscardUnknown()

func (*ResumeWorkflowRequest) XXX_Marshal 

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

func (*ResumeWorkflowRequest) XXX_Merge 

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

func (*ResumeWorkflowRequest) XXX_Size 

func (m *ResumeWorkflowRequest) XXX_Size() int

func (*ResumeWorkflowRequest) XXX_Unmarshal 

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

type ResumeWorkflowResponse 

type ResumeWorkflowResponse struct {
}

func (*ResumeWorkflowResponse) Descriptor 

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

func (*ResumeWorkflowResponse) Marshal 

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

func (*ResumeWorkflowResponse) MarshalTo 

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

func (*ResumeWorkflowResponse) MarshalToSizedBuffer 

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

func (*ResumeWorkflowResponse) ProtoMessage 

func (*ResumeWorkflowResponse) ProtoMessage()

func (*ResumeWorkflowResponse) Reset 

func (m *ResumeWorkflowResponse) Reset()

func (*ResumeWorkflowResponse) String 

func (m *ResumeWorkflowResponse) String() string

func (*ResumeWorkflowResponse) Unmarshal 

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

func (*ResumeWorkflowResponse) Validate 

func (m *ResumeWorkflowResponse) Validate() error

func (*ResumeWorkflowResponse) ValidateE 

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

func (*ResumeWorkflowResponse) XSize 

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

func (*ResumeWorkflowResponse) XXX_DiscardUnknown 

func (m *ResumeWorkflowResponse) XXX_DiscardUnknown()

func (*ResumeWorkflowResponse) XXX_Marshal 

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

func (*ResumeWorkflowResponse) XXX_Merge 

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

func (*ResumeWorkflowResponse) XXX_Size 

func (m *ResumeWorkflowResponse) XXX_Size() int

func (*ResumeWorkflowResponse) XXX_Unmarshal 

func (m *ResumeWorkflowResponse) 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 RunWorkflowRequest 

type RunWorkflowRequest struct {
	// +gen:required
	Workflow *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	Watch    bool      `protobuf:"varint,2,opt,name=watch,proto3" json:"watch,omitempty"`
}

func (*RunWorkflowRequest) Descriptor 

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

func (*RunWorkflowRequest) Marshal 

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

func (*RunWorkflowRequest) MarshalTo 

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

func (*RunWorkflowRequest) MarshalToSizedBuffer 

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

func (*RunWorkflowRequest) ProtoMessage 

func (*RunWorkflowRequest) ProtoMessage()

func (*RunWorkflowRequest) Reset 

func (m *RunWorkflowRequest) Reset()

func (*RunWorkflowRequest) String 

func (m *RunWorkflowRequest) String() string

func (*RunWorkflowRequest) Unmarshal 

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

func (*RunWorkflowRequest) Validate 

func (m *RunWorkflowRequest) Validate() error

func (*RunWorkflowRequest) ValidateE 

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

func (*RunWorkflowRequest) XSize 

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

func (*RunWorkflowRequest) XXX_DiscardUnknown 

func (m *RunWorkflowRequest) XXX_DiscardUnknown()

func (*RunWorkflowRequest) XXX_Marshal 

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

func (*RunWorkflowRequest) XXX_Merge 

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

func (*RunWorkflowRequest) XXX_Size 

func (m *RunWorkflowRequest) XXX_Size() int

func (*RunWorkflowRequest) XXX_Unmarshal 

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

type RunWorkflowResponse 

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

func (*RunWorkflowResponse) Descriptor 

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

func (*RunWorkflowResponse) Marshal 

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

func (*RunWorkflowResponse) MarshalTo 

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

func (*RunWorkflowResponse) MarshalToSizedBuffer 

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

func (*RunWorkflowResponse) ProtoMessage 

func (*RunWorkflowResponse) ProtoMessage()

func (*RunWorkflowResponse) Reset 

func (m *RunWorkflowResponse) Reset()

func (*RunWorkflowResponse) String 

func (m *RunWorkflowResponse) String() string

func (*RunWorkflowResponse) Unmarshal 

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

func (*RunWorkflowResponse) Validate 

func (m *RunWorkflowResponse) Validate() error

func (*RunWorkflowResponse) ValidateE 

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

func (*RunWorkflowResponse) XSize 

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

func (*RunWorkflowResponse) XXX_DiscardUnknown 

func (m *RunWorkflowResponse) XXX_DiscardUnknown()

func (*RunWorkflowResponse) XXX_Marshal 

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

func (*RunWorkflowResponse) XXX_Merge 

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

func (*RunWorkflowResponse) XXX_Size 

func (m *RunWorkflowResponse) XXX_Size() int

func (*RunWorkflowResponse) XXX_Unmarshal 

func (m *RunWorkflowResponse) 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"`
	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
	Step string `protobuf:"bytes,2,opt,name=step,proto3" json:"step,omitempty"`
	// +gen:required
	Key string `protobuf:"bytes,3,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
	Step string `protobuf:"bytes,2,opt,name=step,proto3" json:"step,omitempty"`
	// +gen:required
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// +gen:required
	Value string `protobuf:"bytes,4,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  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	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
	Wid string `protobuf:"bytes,1,opt,name=wid,proto3" json:"wid,omitempty"`
	// +gen:required
	Step string `protobuf:"bytes,2,opt,name=step,proto3" json:"step,omitempty"`
	// +gen:required
	Text []byte `protobuf:"bytes,3,opt,name=text,proto3" json:"text,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 UnimplementedFlowRpcServer 

type UnimplementedFlowRpcServer struct {
}

UnimplementedFlowRpcServer can be embedded to have forward compatible implementations.

func (*UnimplementedFlowRpcServer) AbortWorkflow 

func (*UnimplementedFlowRpcServer) AbortWorkflow(ctx context.Context, req *AbortWorkflowRequest) (*AbortWorkflowResponse, error)

func (*UnimplementedFlowRpcServer) Call 

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

func (*UnimplementedFlowRpcServer) InspectWorkflow 

func (*UnimplementedFlowRpcServer) InspectWorkflow(ctx context.Context, req *InspectWorkflowRequest) (*InspectWorkflowResponse, 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) ListWorkflow 

func (*UnimplementedFlowRpcServer) ListWorkflow(ctx context.Context, req *ListWorkflowRequest) (*ListWorkflowResponse, error)

func (*UnimplementedFlowRpcServer) PauseWorkflow 

func (*UnimplementedFlowRpcServer) PauseWorkflow(ctx context.Context, req *PauseWorkflowRequest) (*PauseWorkflowResponse, 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) ResumeWorkflow 

func (*UnimplementedFlowRpcServer) ResumeWorkflow(ctx context.Context, req *ResumeWorkflowRequest) (*ResumeWorkflowResponse, error)

func (*UnimplementedFlowRpcServer) RunWorkflow 

func (*UnimplementedFlowRpcServer) RunWorkflow(req *RunWorkflowRequest, srv FlowRpc_RunWorkflowServer) 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) WatchWorkflow 

func (*UnimplementedFlowRpcServer) WatchWorkflow(req *WatchWorkflowRequest, srv FlowRpc_WatchWorkflowServer) error

type WatchWorkflowRequest 

type WatchWorkflowRequest 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 (*WatchWorkflowRequest) Descriptor 

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

func (*WatchWorkflowRequest) Marshal 

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

func (*WatchWorkflowRequest) MarshalTo 

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

func (*WatchWorkflowRequest) MarshalToSizedBuffer 

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

func (*WatchWorkflowRequest) ProtoMessage 

func (*WatchWorkflowRequest) ProtoMessage()

func (*WatchWorkflowRequest) Reset 

func (m *WatchWorkflowRequest) Reset()

func (*WatchWorkflowRequest) String 

func (m *WatchWorkflowRequest) String() string

func (*WatchWorkflowRequest) Unmarshal 

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

func (*WatchWorkflowRequest) Validate 

func (m *WatchWorkflowRequest) Validate() error

func (*WatchWorkflowRequest) ValidateE 

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

func (*WatchWorkflowRequest) XSize 

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

func (*WatchWorkflowRequest) XXX_DiscardUnknown 

func (m *WatchWorkflowRequest) XXX_DiscardUnknown()

func (*WatchWorkflowRequest) XXX_Marshal 

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

func (*WatchWorkflowRequest) XXX_Merge 

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

func (*WatchWorkflowRequest) XXX_Size 

func (m *WatchWorkflowRequest) XXX_Size() int

func (*WatchWorkflowRequest) XXX_Unmarshal 

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

type WatchWorkflowResponse 

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

func (*WatchWorkflowResponse) Descriptor 

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

func (*WatchWorkflowResponse) Marshal 

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

func (*WatchWorkflowResponse) MarshalTo 

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

func (*WatchWorkflowResponse) MarshalToSizedBuffer 

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

func (*WatchWorkflowResponse) ProtoMessage 

func (*WatchWorkflowResponse) ProtoMessage()

func (*WatchWorkflowResponse) Reset 

func (m *WatchWorkflowResponse) Reset()

func (*WatchWorkflowResponse) String 

func (m *WatchWorkflowResponse) String() string

func (*WatchWorkflowResponse) Unmarshal 

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

func (*WatchWorkflowResponse) Validate 

func (m *WatchWorkflowResponse) Validate() error

func (*WatchWorkflowResponse) ValidateE 

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

func (*WatchWorkflowResponse) XSize 

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

func (*WatchWorkflowResponse) XXX_DiscardUnknown 

func (m *WatchWorkflowResponse) XXX_DiscardUnknown()

func (*WatchWorkflowResponse) XXX_Marshal 

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

func (*WatchWorkflowResponse) XXX_Merge 

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

func (*WatchWorkflowResponse) XXX_Size 

func (m *WatchWorkflowResponse) XXX_Size() int

func (*WatchWorkflowResponse) XXX_Unmarshal 

func (m *WatchWorkflowResponse) 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 []*Entity                `protobuf:"bytes,2,rep,name=entities,proto3" json:"entities,omitempty"`
	Items    map[string]string        `` /* 151-byte string literal not displayed */
	Steps    []*WorkflowStep          `protobuf:"bytes,4,rep,name=steps,proto3" json:"steps,omitempty"`
	StepArgs map[string]*WorkflowArgs `` /* 157-byte string literal not displayed */
	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 WorkflowArgs added in v0.7.0 

type WorkflowArgs struct {
	Args map[string]string `` /* 149-byte string literal not displayed */
}

func (*WorkflowArgs) DeepCopyInto added in v0.7.0 

func (in *WorkflowArgs) DeepCopyInto(out *WorkflowArgs)

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

func (*WorkflowArgs) Descriptor added in v0.7.0 

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

func (*WorkflowArgs) Marshal added in v0.7.0 

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

func (*WorkflowArgs) MarshalTo added in v0.7.0 

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

func (*WorkflowArgs) MarshalToSizedBuffer added in v0.7.0 

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

func (*WorkflowArgs) ProtoMessage added in v0.7.0 

func (*WorkflowArgs) ProtoMessage()

func (*WorkflowArgs) Reset added in v0.7.0 

func (m *WorkflowArgs) Reset()

func (*WorkflowArgs) String added in v0.7.0 

func (m *WorkflowArgs) String() string

func (*WorkflowArgs) Unmarshal added in v0.7.0 

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

func (*WorkflowArgs) Validate added in v0.7.0 

func (m *WorkflowArgs) Validate() error

func (*WorkflowArgs) ValidateE added in v0.7.0 

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

func (*WorkflowArgs) XSize added in v0.7.0 

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

func (*WorkflowArgs) XXX_DiscardUnknown added in v0.7.0 

func (m *WorkflowArgs) XXX_DiscardUnknown()

func (*WorkflowArgs) XXX_Marshal added in v0.7.0 

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

func (*WorkflowArgs) XXX_Merge added in v0.7.0 

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

func (*WorkflowArgs) XXX_Size added in v0.7.0 

func (m *WorkflowArgs) XXX_Size() int

func (*WorkflowArgs) XXX_Unmarshal added in v0.7.0 

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

type WorkflowMode 

type WorkflowMode int32
const (
	WorkflowMode_WM_UNKNOWN WorkflowMode = 0
	WorkflowMode_WM_AUTO    WorkflowMode = 1
	WorkflowMode_WM_ABORT   WorkflowMode = 2
	WorkflowMode_WM_MANUAL  WorkflowMode = 3
	WorkflowMode_WM_HYBRID  WorkflowMode = 4
)

func (WorkflowMode) EnumDescriptor 

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

func (*WorkflowMode) MarshalJSON 

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

func (WorkflowMode) Readably 

func (m WorkflowMode) Readably() string

func (WorkflowMode) String 

func (x WorkflowMode) String() string

func (*WorkflowMode) UnmarshalJSON 

func (m *WorkflowMode) UnmarshalJSON(data []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"`
	Mode       WorkflowMode `protobuf:"varint,3,opt,name=mode,proto3,enum=api.WorkflowMode" json:"mode,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"`
	Step   string        `protobuf:"bytes,3,opt,name=step,proto3" json:"step,omitempty"`
	Action StepAction    `protobuf:"varint,4,opt,name=action,proto3,enum=api.StepAction" json:"action,omitempty"`
	State  WorkflowState `protobuf:"varint,5,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"`
	Msg      string        `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Action   StepAction    `protobuf:"varint,3,opt,name=action,proto3,enum=api.StepAction" json:"action,omitempty"`
	Progress string        `protobuf:"bytes,4,opt,name=progress,proto3" json:"progress,omitempty"`
	Step     string        `protobuf:"bytes,5,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"`
	Args     *WorkflowArgs        `protobuf:"bytes,6,opt,name=args,proto3" json:"args,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"`
	Action EventAction `protobuf:"varint,3,opt,name=action,proto3,enum=api.EventAction" json:"action,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.