cereal

package
v0.0.0-...-be2ef80 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_interservice_cereal_cereal_proto protoreflect.FileDescriptor

Functions

func RegisterCerealServiceServer 

func RegisterCerealServiceServer(s *grpc.Server, srv CerealServiceServer)

Types

type CancelWorkflowRequest 

type CancelWorkflowRequest struct {
	Domain       string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	InstanceName string `` /* 167-byte string literal not displayed */
	WorkflowName string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CancelWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use CancelWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CancelWorkflowRequest) GetDomain 

func (x *CancelWorkflowRequest) GetDomain() string

func (*CancelWorkflowRequest) GetInstanceName 

func (x *CancelWorkflowRequest) GetInstanceName() string

func (*CancelWorkflowRequest) GetWorkflowName 

func (x *CancelWorkflowRequest) GetWorkflowName() string

func (*CancelWorkflowRequest) ProtoMessage 

func (*CancelWorkflowRequest) ProtoMessage()

func (*CancelWorkflowRequest) ProtoReflect 

func (x *CancelWorkflowRequest) ProtoReflect() protoreflect.Message

func (*CancelWorkflowRequest) Reset 

func (x *CancelWorkflowRequest) Reset()

func (*CancelWorkflowRequest) String 

func (x *CancelWorkflowRequest) String() string

type CancelWorkflowResponse 

type CancelWorkflowResponse struct {
	// contains filtered or unexported fields
}

func (*CancelWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use CancelWorkflowResponse.ProtoReflect.Descriptor instead.

func (*CancelWorkflowResponse) ProtoMessage 

func (*CancelWorkflowResponse) ProtoMessage()

func (*CancelWorkflowResponse) ProtoReflect 

func (x *CancelWorkflowResponse) ProtoReflect() protoreflect.Message

func (*CancelWorkflowResponse) Reset 

func (x *CancelWorkflowResponse) Reset()

func (*CancelWorkflowResponse) String 

func (x *CancelWorkflowResponse) String() string

type CerealServiceClient 

type CerealServiceClient interface {
	EnqueueWorkflow(ctx context.Context, in *EnqueueWorkflowRequest, opts ...grpc.CallOption) (*EnqueueWorkflowResponse, error)
	DequeueWorkflow(ctx context.Context, opts ...grpc.CallOption) (CerealService_DequeueWorkflowClient, error)
	DequeueWorkflowChunk(ctx context.Context, opts ...grpc.CallOption) (CerealService_DequeueWorkflowChunkClient, error)
	CancelWorkflow(ctx context.Context, in *CancelWorkflowRequest, opts ...grpc.CallOption) (*CancelWorkflowResponse, error)
	KillWorkflow(ctx context.Context, in *KillWorkflowRequest, opts ...grpc.CallOption) (*KillWorkflowResponse, error)
	DequeueTask(ctx context.Context, opts ...grpc.CallOption) (CerealService_DequeueTaskClient, error)
	CreateWorkflowSchedule(ctx context.Context, in *CreateWorkflowScheduleRequest, opts ...grpc.CallOption) (*CreateWorkflowScheduleResponse, error)
	ListWorkflowSchedules(ctx context.Context, in *ListWorkflowSchedulesRequest, opts ...grpc.CallOption) (CerealService_ListWorkflowSchedulesClient, error)
	GetWorkflowScheduleByName(ctx context.Context, in *GetWorkflowScheduleByNameRequest, opts ...grpc.CallOption) (*GetWorkflowScheduleByNameResponse, error)
	UpdateWorkflowScheduleByName(ctx context.Context, in *UpdateWorkflowScheduleByNameRequest, opts ...grpc.CallOption) (*UpdateWorkflowScheduleByNameResponse, error)
	GetWorkflowInstanceByName(ctx context.Context, in *GetWorkflowInstanceByNameRequest, opts ...grpc.CallOption) (*GetWorkflowInstanceByNameResponse, error)
	ListWorkflowInstances(ctx context.Context, in *ListWorkflowInstancesRequest, opts ...grpc.CallOption) (CerealService_ListWorkflowInstancesClient, error)
}

CerealServiceClient is the client API for CerealService service.

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

func NewCerealServiceClient 

func NewCerealServiceClient(cc grpc.ClientConnInterface) CerealServiceClient

type CerealServiceServer 

type CerealServiceServer interface {
	EnqueueWorkflow(context.Context, *EnqueueWorkflowRequest) (*EnqueueWorkflowResponse, error)
	DequeueWorkflow(CerealService_DequeueWorkflowServer) error
	DequeueWorkflowChunk(CerealService_DequeueWorkflowChunkServer) error
	CancelWorkflow(context.Context, *CancelWorkflowRequest) (*CancelWorkflowResponse, error)
	KillWorkflow(context.Context, *KillWorkflowRequest) (*KillWorkflowResponse, error)
	DequeueTask(CerealService_DequeueTaskServer) error
	CreateWorkflowSchedule(context.Context, *CreateWorkflowScheduleRequest) (*CreateWorkflowScheduleResponse, error)
	ListWorkflowSchedules(*ListWorkflowSchedulesRequest, CerealService_ListWorkflowSchedulesServer) error
	GetWorkflowScheduleByName(context.Context, *GetWorkflowScheduleByNameRequest) (*GetWorkflowScheduleByNameResponse, error)
	UpdateWorkflowScheduleByName(context.Context, *UpdateWorkflowScheduleByNameRequest) (*UpdateWorkflowScheduleByNameResponse, error)
	GetWorkflowInstanceByName(context.Context, *GetWorkflowInstanceByNameRequest) (*GetWorkflowInstanceByNameResponse, error)
	ListWorkflowInstances(*ListWorkflowInstancesRequest, CerealService_ListWorkflowInstancesServer) error
}

CerealServiceServer is the server API for CerealService service.

type CerealService_DequeueTaskClient 

type CerealService_DequeueTaskClient interface {
	Send(*DequeueTaskRequest) error
	Recv() (*DequeueTaskResponse, error)
	grpc.ClientStream
}

type CerealService_DequeueTaskServer 

type CerealService_DequeueTaskServer interface {
	Send(*DequeueTaskResponse) error
	Recv() (*DequeueTaskRequest, error)
	grpc.ServerStream
}

type CerealService_DequeueWorkflowChunkClient 

type CerealService_DequeueWorkflowChunkClient interface {
	Send(*DequeueWorkflowChunkRequest) error
	Recv() (*DequeueWorkflowChunkResponse, error)
	grpc.ClientStream
}

type CerealService_DequeueWorkflowChunkServer 

type CerealService_DequeueWorkflowChunkServer interface {
	Send(*DequeueWorkflowChunkResponse) error
	Recv() (*DequeueWorkflowChunkRequest, error)
	grpc.ServerStream
}

type CerealService_DequeueWorkflowClient 

type CerealService_DequeueWorkflowClient interface {
	Send(*DequeueWorkflowRequest) error
	Recv() (*DequeueWorkflowResponse, error)
	grpc.ClientStream
}

type CerealService_DequeueWorkflowServer 

type CerealService_DequeueWorkflowServer interface {
	Send(*DequeueWorkflowResponse) error
	Recv() (*DequeueWorkflowRequest, error)
	grpc.ServerStream
}

type CerealService_ListWorkflowInstancesClient 

type CerealService_ListWorkflowInstancesClient interface {
	Recv() (*ListWorkflowInstancesResponse, error)
	grpc.ClientStream
}

type CerealService_ListWorkflowInstancesServer 

type CerealService_ListWorkflowInstancesServer interface {
	Send(*ListWorkflowInstancesResponse) error
	grpc.ServerStream
}

type CerealService_ListWorkflowSchedulesClient 

type CerealService_ListWorkflowSchedulesClient interface {
	Recv() (*ListWorkflowSchedulesResponse, error)
	grpc.ClientStream
}

type CerealService_ListWorkflowSchedulesServer 

type CerealService_ListWorkflowSchedulesServer interface {
	Send(*ListWorkflowSchedulesResponse) error
	grpc.ServerStream
}

type CreateWorkflowScheduleRequest 

type CreateWorkflowScheduleRequest struct {
	Domain       string                 `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	InstanceName string                 `` /* 167-byte string literal not displayed */
	WorkflowName string                 `` /* 167-byte string literal not displayed */
	Parameters   []byte                 `` /* 137-byte string literal not displayed */
	Enabled      bool                   `` /* 126-byte string literal not displayed */
	Recurrence   string                 `` /* 137-byte string literal not displayed */
	Payload      []byte                 `protobuf:"bytes,7,opt,name=payload,proto3" json:"payload,omitempty" toml:"payload,omitempty" mapstructure:"payload,omitempty"`
	NextRunAt    *timestamppb.Timestamp `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateWorkflowScheduleRequest) Descriptor deprecated 

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

Deprecated: Use CreateWorkflowScheduleRequest.ProtoReflect.Descriptor instead.

func (*CreateWorkflowScheduleRequest) GetDomain 

func (x *CreateWorkflowScheduleRequest) GetDomain() string

func (*CreateWorkflowScheduleRequest) GetEnabled 

func (x *CreateWorkflowScheduleRequest) GetEnabled() bool

func (*CreateWorkflowScheduleRequest) GetInstanceName 

func (x *CreateWorkflowScheduleRequest) GetInstanceName() string

func (*CreateWorkflowScheduleRequest) GetNextRunAt 

func (x *CreateWorkflowScheduleRequest) GetNextRunAt() *timestamppb.Timestamp

func (*CreateWorkflowScheduleRequest) GetParameters 

func (x *CreateWorkflowScheduleRequest) GetParameters() []byte

func (*CreateWorkflowScheduleRequest) GetPayload 

func (x *CreateWorkflowScheduleRequest) GetPayload() []byte

func (*CreateWorkflowScheduleRequest) GetRecurrence 

func (x *CreateWorkflowScheduleRequest) GetRecurrence() string

func (*CreateWorkflowScheduleRequest) GetWorkflowName 

func (x *CreateWorkflowScheduleRequest) GetWorkflowName() string

func (*CreateWorkflowScheduleRequest) ProtoMessage 

func (*CreateWorkflowScheduleRequest) ProtoMessage()

func (*CreateWorkflowScheduleRequest) ProtoReflect 

func (x *CreateWorkflowScheduleRequest) ProtoReflect() protoreflect.Message

func (*CreateWorkflowScheduleRequest) Reset 

func (x *CreateWorkflowScheduleRequest) Reset()

func (*CreateWorkflowScheduleRequest) String 

func (x *CreateWorkflowScheduleRequest) String() string

type CreateWorkflowScheduleResponse 

type CreateWorkflowScheduleResponse struct {
	// contains filtered or unexported fields
}

func (*CreateWorkflowScheduleResponse) Descriptor deprecated 

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

Deprecated: Use CreateWorkflowScheduleResponse.ProtoReflect.Descriptor instead.

func (*CreateWorkflowScheduleResponse) ProtoMessage 

func (*CreateWorkflowScheduleResponse) ProtoMessage()

func (*CreateWorkflowScheduleResponse) ProtoReflect 

func (x *CreateWorkflowScheduleResponse) ProtoReflect() protoreflect.Message

func (*CreateWorkflowScheduleResponse) Reset 

func (x *CreateWorkflowScheduleResponse) Reset()

func (*CreateWorkflowScheduleResponse) String 

func (x *CreateWorkflowScheduleResponse) String() string

type DequeueTaskRequest 

type DequeueTaskRequest struct {

	// Types that are assignable to Cmd:
	//
	//	*DequeueTaskRequest_Dequeue_
	//	*DequeueTaskRequest_Succeed_
	//	*DequeueTaskRequest_Fail_
	Cmd isDequeueTaskRequest_Cmd `protobuf_oneof:"cmd"`
	// contains filtered or unexported fields
}

func (*DequeueTaskRequest) Descriptor deprecated 

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

Deprecated: Use DequeueTaskRequest.ProtoReflect.Descriptor instead.

func (*DequeueTaskRequest) GetCmd 

func (m *DequeueTaskRequest) GetCmd() isDequeueTaskRequest_Cmd

func (*DequeueTaskRequest) GetDequeue 

func (x *DequeueTaskRequest) GetDequeue() *DequeueTaskRequest_Dequeue

func (*DequeueTaskRequest) GetFail 

func (x *DequeueTaskRequest) GetFail() *DequeueTaskRequest_Fail

func (*DequeueTaskRequest) GetSucceed 

func (x *DequeueTaskRequest) GetSucceed() *DequeueTaskRequest_Succeed

func (*DequeueTaskRequest) ProtoMessage 

func (*DequeueTaskRequest) ProtoMessage()

func (*DequeueTaskRequest) ProtoReflect 

func (x *DequeueTaskRequest) ProtoReflect() protoreflect.Message

func (*DequeueTaskRequest) Reset 

func (x *DequeueTaskRequest) Reset()

func (*DequeueTaskRequest) String 

func (x *DequeueTaskRequest) String() string

type DequeueTaskRequest_Dequeue 

type DequeueTaskRequest_Dequeue struct {
	Domain   string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	TaskName string `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DequeueTaskRequest_Dequeue) Descriptor deprecated 

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

Deprecated: Use DequeueTaskRequest_Dequeue.ProtoReflect.Descriptor instead.

func (*DequeueTaskRequest_Dequeue) GetDomain 

func (x *DequeueTaskRequest_Dequeue) GetDomain() string

func (*DequeueTaskRequest_Dequeue) GetTaskName 

func (x *DequeueTaskRequest_Dequeue) GetTaskName() string

func (*DequeueTaskRequest_Dequeue) ProtoMessage 

func (*DequeueTaskRequest_Dequeue) ProtoMessage()

func (*DequeueTaskRequest_Dequeue) ProtoReflect 

func (x *DequeueTaskRequest_Dequeue) ProtoReflect() protoreflect.Message

func (*DequeueTaskRequest_Dequeue) Reset 

func (x *DequeueTaskRequest_Dequeue) Reset()

func (*DequeueTaskRequest_Dequeue) String 

func (x *DequeueTaskRequest_Dequeue) String() string

type DequeueTaskRequest_Dequeue_ 

type DequeueTaskRequest_Dequeue_ struct {
	Dequeue *DequeueTaskRequest_Dequeue `protobuf:"bytes,1,opt,name=dequeue,proto3,oneof"`
}

type DequeueTaskRequest_Fail 

type DequeueTaskRequest_Fail struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" toml:"error,omitempty" mapstructure:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueTaskRequest_Fail) Descriptor deprecated 

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

Deprecated: Use DequeueTaskRequest_Fail.ProtoReflect.Descriptor instead.

func (*DequeueTaskRequest_Fail) GetError 

func (x *DequeueTaskRequest_Fail) GetError() string

func (*DequeueTaskRequest_Fail) ProtoMessage 

func (*DequeueTaskRequest_Fail) ProtoMessage()

func (*DequeueTaskRequest_Fail) ProtoReflect 

func (x *DequeueTaskRequest_Fail) ProtoReflect() protoreflect.Message

func (*DequeueTaskRequest_Fail) Reset 

func (x *DequeueTaskRequest_Fail) Reset()

func (*DequeueTaskRequest_Fail) String 

func (x *DequeueTaskRequest_Fail) String() string

type DequeueTaskRequest_Fail_ 

type DequeueTaskRequest_Fail_ struct {
	Fail *DequeueTaskRequest_Fail `protobuf:"bytes,3,opt,name=fail,proto3,oneof"`
}

type DequeueTaskRequest_Succeed 

type DequeueTaskRequest_Succeed struct {
	Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty" toml:"result,omitempty" mapstructure:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueTaskRequest_Succeed) Descriptor deprecated 

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

Deprecated: Use DequeueTaskRequest_Succeed.ProtoReflect.Descriptor instead.

func (*DequeueTaskRequest_Succeed) GetResult 

func (x *DequeueTaskRequest_Succeed) GetResult() []byte

func (*DequeueTaskRequest_Succeed) ProtoMessage 

func (*DequeueTaskRequest_Succeed) ProtoMessage()

func (*DequeueTaskRequest_Succeed) ProtoReflect 

func (x *DequeueTaskRequest_Succeed) ProtoReflect() protoreflect.Message

func (*DequeueTaskRequest_Succeed) Reset 

func (x *DequeueTaskRequest_Succeed) Reset()

func (*DequeueTaskRequest_Succeed) String 

func (x *DequeueTaskRequest_Succeed) String() string

type DequeueTaskRequest_Succeed_ 

type DequeueTaskRequest_Succeed_ struct {
	Succeed *DequeueTaskRequest_Succeed `protobuf:"bytes,2,opt,name=succeed,proto3,oneof"`
}

type DequeueTaskResponse 

type DequeueTaskResponse struct {

	// Types that are assignable to Cmd:
	//
	//	*DequeueTaskResponse_Dequeue_
	//	*DequeueTaskResponse_Cancel_
	//	*DequeueTaskResponse_Committed_
	Cmd isDequeueTaskResponse_Cmd `protobuf_oneof:"cmd"`
	// contains filtered or unexported fields
}

func (*DequeueTaskResponse) Descriptor deprecated 

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

Deprecated: Use DequeueTaskResponse.ProtoReflect.Descriptor instead.

func (*DequeueTaskResponse) GetCancel 

func (x *DequeueTaskResponse) GetCancel() *DequeueTaskResponse_Cancel

func (*DequeueTaskResponse) GetCmd 

func (m *DequeueTaskResponse) GetCmd() isDequeueTaskResponse_Cmd

func (*DequeueTaskResponse) GetCommitted 

func (x *DequeueTaskResponse) GetCommitted() *DequeueTaskResponse_Committed

func (*DequeueTaskResponse) GetDequeue 

func (x *DequeueTaskResponse) GetDequeue() *DequeueTaskResponse_Dequeue

func (*DequeueTaskResponse) ProtoMessage 

func (*DequeueTaskResponse) ProtoMessage()

func (*DequeueTaskResponse) ProtoReflect 

func (x *DequeueTaskResponse) ProtoReflect() protoreflect.Message

func (*DequeueTaskResponse) Reset 

func (x *DequeueTaskResponse) Reset()

func (*DequeueTaskResponse) String 

func (x *DequeueTaskResponse) String() string

type DequeueTaskResponse_Cancel 

type DequeueTaskResponse_Cancel struct {
	Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty" toml:"err,omitempty" mapstructure:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueTaskResponse_Cancel) Descriptor deprecated 

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

Deprecated: Use DequeueTaskResponse_Cancel.ProtoReflect.Descriptor instead.

func (*DequeueTaskResponse_Cancel) GetErr 

func (x *DequeueTaskResponse_Cancel) GetErr() string

func (*DequeueTaskResponse_Cancel) ProtoMessage 

func (*DequeueTaskResponse_Cancel) ProtoMessage()

func (*DequeueTaskResponse_Cancel) ProtoReflect 

func (x *DequeueTaskResponse_Cancel) ProtoReflect() protoreflect.Message

func (*DequeueTaskResponse_Cancel) Reset 

func (x *DequeueTaskResponse_Cancel) Reset()

func (*DequeueTaskResponse_Cancel) String 

func (x *DequeueTaskResponse_Cancel) String() string

type DequeueTaskResponse_Cancel_ 

type DequeueTaskResponse_Cancel_ struct {
	Cancel *DequeueTaskResponse_Cancel `protobuf:"bytes,2,opt,name=cancel,proto3,oneof"`
}

type DequeueTaskResponse_Committed 

type DequeueTaskResponse_Committed struct {
	// contains filtered or unexported fields
}

func (*DequeueTaskResponse_Committed) Descriptor deprecated 

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

Deprecated: Use DequeueTaskResponse_Committed.ProtoReflect.Descriptor instead.

func (*DequeueTaskResponse_Committed) ProtoMessage 

func (*DequeueTaskResponse_Committed) ProtoMessage()

func (*DequeueTaskResponse_Committed) ProtoReflect 

func (x *DequeueTaskResponse_Committed) ProtoReflect() protoreflect.Message

func (*DequeueTaskResponse_Committed) Reset 

func (x *DequeueTaskResponse_Committed) Reset()

func (*DequeueTaskResponse_Committed) String 

func (x *DequeueTaskResponse_Committed) String() string

type DequeueTaskResponse_Committed_ 

type DequeueTaskResponse_Committed_ struct {
	Committed *DequeueTaskResponse_Committed `protobuf:"bytes,3,opt,name=committed,proto3,oneof"`
}

type DequeueTaskResponse_Dequeue 

type DequeueTaskResponse_Dequeue struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty" toml:"task,omitempty" mapstructure:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueTaskResponse_Dequeue) Descriptor deprecated 

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

Deprecated: Use DequeueTaskResponse_Dequeue.ProtoReflect.Descriptor instead.

func (*DequeueTaskResponse_Dequeue) GetTask 

func (x *DequeueTaskResponse_Dequeue) GetTask() *Task

func (*DequeueTaskResponse_Dequeue) ProtoMessage 

func (*DequeueTaskResponse_Dequeue) ProtoMessage()

func (*DequeueTaskResponse_Dequeue) ProtoReflect 

func (x *DequeueTaskResponse_Dequeue) ProtoReflect() protoreflect.Message

func (*DequeueTaskResponse_Dequeue) Reset 

func (x *DequeueTaskResponse_Dequeue) Reset()

func (*DequeueTaskResponse_Dequeue) String 

func (x *DequeueTaskResponse_Dequeue) String() string

type DequeueTaskResponse_Dequeue_ 

type DequeueTaskResponse_Dequeue_ struct {
	Dequeue *DequeueTaskResponse_Dequeue `protobuf:"bytes,1,opt,name=dequeue,proto3,oneof"`
}

type DequeueWorkflowChunkRequest 

type DequeueWorkflowChunkRequest struct {

	// Types that are assignable to Cmd:
	//
	//	*DequeueWorkflowChunkRequest_Dequeue_
	//	*DequeueWorkflowChunkRequest_Continue_
	//	*DequeueWorkflowChunkRequest_Done_
	//	*DequeueWorkflowChunkRequest_Fail_
	Cmd isDequeueWorkflowChunkRequest_Cmd `protobuf_oneof:"cmd"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowChunkRequest) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowChunkRequest.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowChunkRequest) GetCmd 

func (m *DequeueWorkflowChunkRequest) GetCmd() isDequeueWorkflowChunkRequest_Cmd

func (*DequeueWorkflowChunkRequest) GetContinue 

func (x *DequeueWorkflowChunkRequest) GetContinue() *DequeueWorkflowChunkRequest_Continue

func (*DequeueWorkflowChunkRequest) GetDequeue 

func (x *DequeueWorkflowChunkRequest) GetDequeue() *DequeueWorkflowChunkRequest_Dequeue

func (*DequeueWorkflowChunkRequest) GetDone 

func (x *DequeueWorkflowChunkRequest) GetDone() *DequeueWorkflowChunkRequest_Done

func (*DequeueWorkflowChunkRequest) GetFail 

func (x *DequeueWorkflowChunkRequest) GetFail() *DequeueWorkflowChunkRequest_Fail

func (*DequeueWorkflowChunkRequest) ProtoMessage 

func (*DequeueWorkflowChunkRequest) ProtoMessage()

func (*DequeueWorkflowChunkRequest) ProtoReflect 

func (x *DequeueWorkflowChunkRequest) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowChunkRequest) Reset 

func (x *DequeueWorkflowChunkRequest) Reset()

func (*DequeueWorkflowChunkRequest) String 

func (x *DequeueWorkflowChunkRequest) String() string

type DequeueWorkflowChunkRequest_Continue 

type DequeueWorkflowChunkRequest_Continue struct {
	Payload []byte  `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty" toml:"payload,omitempty" mapstructure:"payload,omitempty"`
	Tasks   []*Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty" toml:"tasks,omitempty" mapstructure:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowChunkRequest_Continue) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowChunkRequest_Continue.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowChunkRequest_Continue) GetPayload 

func (x *DequeueWorkflowChunkRequest_Continue) GetPayload() []byte

func (*DequeueWorkflowChunkRequest_Continue) GetTasks 

func (x *DequeueWorkflowChunkRequest_Continue) GetTasks() []*Task

func (*DequeueWorkflowChunkRequest_Continue) ProtoMessage 

func (*DequeueWorkflowChunkRequest_Continue) ProtoMessage()

func (*DequeueWorkflowChunkRequest_Continue) ProtoReflect 

func (x *DequeueWorkflowChunkRequest_Continue) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowChunkRequest_Continue) Reset 

func (x *DequeueWorkflowChunkRequest_Continue) Reset()

func (*DequeueWorkflowChunkRequest_Continue) String 

func (x *DequeueWorkflowChunkRequest_Continue) String() string

type DequeueWorkflowChunkRequest_Continue_ 

type DequeueWorkflowChunkRequest_Continue_ struct {
	Continue *DequeueWorkflowChunkRequest_Continue `protobuf:"bytes,2,opt,name=continue,proto3,oneof"`
}

type DequeueWorkflowChunkRequest_Dequeue 

type DequeueWorkflowChunkRequest_Dequeue struct {
	Domain        string   `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	WorkflowNames []string `` /* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DequeueWorkflowChunkRequest_Dequeue) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowChunkRequest_Dequeue.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowChunkRequest_Dequeue) GetDomain 

func (x *DequeueWorkflowChunkRequest_Dequeue) GetDomain() string

func (*DequeueWorkflowChunkRequest_Dequeue) GetWorkflowNames 

func (x *DequeueWorkflowChunkRequest_Dequeue) GetWorkflowNames() []string

func (*DequeueWorkflowChunkRequest_Dequeue) ProtoMessage 

func (*DequeueWorkflowChunkRequest_Dequeue) ProtoMessage()

func (*DequeueWorkflowChunkRequest_Dequeue) ProtoReflect 

func (x *DequeueWorkflowChunkRequest_Dequeue) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowChunkRequest_Dequeue) Reset 

func (x *DequeueWorkflowChunkRequest_Dequeue) Reset()

func (*DequeueWorkflowChunkRequest_Dequeue) String 

func (x *DequeueWorkflowChunkRequest_Dequeue) String() string

type DequeueWorkflowChunkRequest_Dequeue_ 

type DequeueWorkflowChunkRequest_Dequeue_ struct {
	Dequeue *DequeueWorkflowChunkRequest_Dequeue `protobuf:"bytes,1,opt,name=dequeue,proto3,oneof"`
}

type DequeueWorkflowChunkRequest_Done 

type DequeueWorkflowChunkRequest_Done struct {
	Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty" toml:"result,omitempty" mapstructure:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowChunkRequest_Done) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowChunkRequest_Done.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowChunkRequest_Done) GetResult 

func (x *DequeueWorkflowChunkRequest_Done) GetResult() []byte

func (*DequeueWorkflowChunkRequest_Done) ProtoMessage 

func (*DequeueWorkflowChunkRequest_Done) ProtoMessage()

func (*DequeueWorkflowChunkRequest_Done) ProtoReflect 

func (x *DequeueWorkflowChunkRequest_Done) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowChunkRequest_Done) Reset 

func (x *DequeueWorkflowChunkRequest_Done) Reset()

func (*DequeueWorkflowChunkRequest_Done) String 

func (x *DequeueWorkflowChunkRequest_Done) String() string

type DequeueWorkflowChunkRequest_Done_ 

type DequeueWorkflowChunkRequest_Done_ struct {
	Done *DequeueWorkflowChunkRequest_Done `protobuf:"bytes,3,opt,name=done,proto3,oneof"`
}

type DequeueWorkflowChunkRequest_Fail 

type DequeueWorkflowChunkRequest_Fail struct {
	Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty" toml:"err,omitempty" mapstructure:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowChunkRequest_Fail) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowChunkRequest_Fail.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowChunkRequest_Fail) GetErr 

func (x *DequeueWorkflowChunkRequest_Fail) GetErr() string

func (*DequeueWorkflowChunkRequest_Fail) ProtoMessage 

func (*DequeueWorkflowChunkRequest_Fail) ProtoMessage()

func (*DequeueWorkflowChunkRequest_Fail) ProtoReflect 

func (x *DequeueWorkflowChunkRequest_Fail) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowChunkRequest_Fail) Reset 

func (x *DequeueWorkflowChunkRequest_Fail) Reset()

func (*DequeueWorkflowChunkRequest_Fail) String 

func (x *DequeueWorkflowChunkRequest_Fail) String() string

type DequeueWorkflowChunkRequest_Fail_ 

type DequeueWorkflowChunkRequest_Fail_ struct {
	Fail *DequeueWorkflowChunkRequest_Fail `protobuf:"bytes,4,opt,name=fail,proto3,oneof"`
}

type DequeueWorkflowChunkResponse 

type DequeueWorkflowChunkResponse struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty" toml:"chunk,omitempty" mapstructure:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowChunkResponse) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowChunkResponse.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowChunkResponse) GetChunk 

func (x *DequeueWorkflowChunkResponse) GetChunk() []byte

func (*DequeueWorkflowChunkResponse) ProtoMessage 

func (*DequeueWorkflowChunkResponse) ProtoMessage()

func (*DequeueWorkflowChunkResponse) ProtoReflect 

func (x *DequeueWorkflowChunkResponse) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowChunkResponse) Reset 

func (x *DequeueWorkflowChunkResponse) Reset()

func (*DequeueWorkflowChunkResponse) String 

func (x *DequeueWorkflowChunkResponse) String() string

type DequeueWorkflowRequest 

type DequeueWorkflowRequest struct {

	// Types that are assignable to Cmd:
	//
	//	*DequeueWorkflowRequest_Dequeue_
	//	*DequeueWorkflowRequest_Continue_
	//	*DequeueWorkflowRequest_Done_
	//	*DequeueWorkflowRequest_Fail_
	Cmd isDequeueWorkflowRequest_Cmd `protobuf_oneof:"cmd"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowRequest) GetCmd 

func (m *DequeueWorkflowRequest) GetCmd() isDequeueWorkflowRequest_Cmd

func (*DequeueWorkflowRequest) GetContinue 

func (x *DequeueWorkflowRequest) GetContinue() *DequeueWorkflowRequest_Continue

func (*DequeueWorkflowRequest) GetDequeue 

func (x *DequeueWorkflowRequest) GetDequeue() *DequeueWorkflowRequest_Dequeue

func (*DequeueWorkflowRequest) GetDone 

func (x *DequeueWorkflowRequest) GetDone() *DequeueWorkflowRequest_Done

func (*DequeueWorkflowRequest) GetFail 

func (x *DequeueWorkflowRequest) GetFail() *DequeueWorkflowRequest_Fail

func (*DequeueWorkflowRequest) ProtoMessage 

func (*DequeueWorkflowRequest) ProtoMessage()

func (*DequeueWorkflowRequest) ProtoReflect 

func (x *DequeueWorkflowRequest) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowRequest) Reset 

func (x *DequeueWorkflowRequest) Reset()

func (*DequeueWorkflowRequest) String 

func (x *DequeueWorkflowRequest) String() string

type DequeueWorkflowRequest_Continue 

type DequeueWorkflowRequest_Continue struct {
	Payload []byte  `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty" toml:"payload,omitempty" mapstructure:"payload,omitempty"`
	Tasks   []*Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty" toml:"tasks,omitempty" mapstructure:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowRequest_Continue) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowRequest_Continue.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowRequest_Continue) GetPayload 

func (x *DequeueWorkflowRequest_Continue) GetPayload() []byte

func (*DequeueWorkflowRequest_Continue) GetTasks 

func (x *DequeueWorkflowRequest_Continue) GetTasks() []*Task

func (*DequeueWorkflowRequest_Continue) ProtoMessage 

func (*DequeueWorkflowRequest_Continue) ProtoMessage()

func (*DequeueWorkflowRequest_Continue) ProtoReflect 

func (x *DequeueWorkflowRequest_Continue) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowRequest_Continue) Reset 

func (x *DequeueWorkflowRequest_Continue) Reset()

func (*DequeueWorkflowRequest_Continue) String 

func (x *DequeueWorkflowRequest_Continue) String() string

type DequeueWorkflowRequest_Continue_ 

type DequeueWorkflowRequest_Continue_ struct {
	Continue *DequeueWorkflowRequest_Continue `protobuf:"bytes,2,opt,name=continue,proto3,oneof"`
}

type DequeueWorkflowRequest_Dequeue 

type DequeueWorkflowRequest_Dequeue struct {
	Domain        string   `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	WorkflowNames []string `` /* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DequeueWorkflowRequest_Dequeue) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowRequest_Dequeue.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowRequest_Dequeue) GetDomain 

func (x *DequeueWorkflowRequest_Dequeue) GetDomain() string

func (*DequeueWorkflowRequest_Dequeue) GetWorkflowNames 

func (x *DequeueWorkflowRequest_Dequeue) GetWorkflowNames() []string

func (*DequeueWorkflowRequest_Dequeue) ProtoMessage 

func (*DequeueWorkflowRequest_Dequeue) ProtoMessage()

func (*DequeueWorkflowRequest_Dequeue) ProtoReflect 

func (x *DequeueWorkflowRequest_Dequeue) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowRequest_Dequeue) Reset 

func (x *DequeueWorkflowRequest_Dequeue) Reset()

func (*DequeueWorkflowRequest_Dequeue) String 

func (x *DequeueWorkflowRequest_Dequeue) String() string

type DequeueWorkflowRequest_Dequeue_ 

type DequeueWorkflowRequest_Dequeue_ struct {
	Dequeue *DequeueWorkflowRequest_Dequeue `protobuf:"bytes,1,opt,name=dequeue,proto3,oneof"`
}

type DequeueWorkflowRequest_Done 

type DequeueWorkflowRequest_Done struct {
	Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty" toml:"result,omitempty" mapstructure:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowRequest_Done) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowRequest_Done.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowRequest_Done) GetResult 

func (x *DequeueWorkflowRequest_Done) GetResult() []byte

func (*DequeueWorkflowRequest_Done) ProtoMessage 

func (*DequeueWorkflowRequest_Done) ProtoMessage()

func (*DequeueWorkflowRequest_Done) ProtoReflect 

func (x *DequeueWorkflowRequest_Done) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowRequest_Done) Reset 

func (x *DequeueWorkflowRequest_Done) Reset()

func (*DequeueWorkflowRequest_Done) String 

func (x *DequeueWorkflowRequest_Done) String() string

type DequeueWorkflowRequest_Done_ 

type DequeueWorkflowRequest_Done_ struct {
	Done *DequeueWorkflowRequest_Done `protobuf:"bytes,3,opt,name=done,proto3,oneof"`
}

type DequeueWorkflowRequest_Fail 

type DequeueWorkflowRequest_Fail struct {
	Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty" toml:"err,omitempty" mapstructure:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowRequest_Fail) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowRequest_Fail.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowRequest_Fail) GetErr 

func (x *DequeueWorkflowRequest_Fail) GetErr() string

func (*DequeueWorkflowRequest_Fail) ProtoMessage 

func (*DequeueWorkflowRequest_Fail) ProtoMessage()

func (*DequeueWorkflowRequest_Fail) ProtoReflect 

func (x *DequeueWorkflowRequest_Fail) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowRequest_Fail) Reset 

func (x *DequeueWorkflowRequest_Fail) Reset()

func (*DequeueWorkflowRequest_Fail) String 

func (x *DequeueWorkflowRequest_Fail) String() string

type DequeueWorkflowRequest_Fail_ 

type DequeueWorkflowRequest_Fail_ struct {
	Fail *DequeueWorkflowRequest_Fail `protobuf:"bytes,4,opt,name=fail,proto3,oneof"`
}

type DequeueWorkflowResponse 

type DequeueWorkflowResponse struct {

	// Types that are assignable to Cmd:
	//
	//	*DequeueWorkflowResponse_Dequeue_
	//	*DequeueWorkflowResponse_Status_
	//	*DequeueWorkflowResponse_Committed_
	Cmd isDequeueWorkflowResponse_Cmd `protobuf_oneof:"cmd"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowResponse.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowResponse) GetCmd 

func (m *DequeueWorkflowResponse) GetCmd() isDequeueWorkflowResponse_Cmd

func (*DequeueWorkflowResponse) GetCommitted 

func (x *DequeueWorkflowResponse) GetCommitted() *DequeueWorkflowResponse_Committed

func (*DequeueWorkflowResponse) GetDequeue 

func (x *DequeueWorkflowResponse) GetDequeue() *DequeueWorkflowResponse_Dequeue

func (*DequeueWorkflowResponse) GetStatus 

func (x *DequeueWorkflowResponse) GetStatus() *DequeueWorkflowResponse_Status

func (*DequeueWorkflowResponse) ProtoMessage 

func (*DequeueWorkflowResponse) ProtoMessage()

func (*DequeueWorkflowResponse) ProtoReflect 

func (x *DequeueWorkflowResponse) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowResponse) Reset 

func (x *DequeueWorkflowResponse) Reset()

func (*DequeueWorkflowResponse) String 

func (x *DequeueWorkflowResponse) String() string

type DequeueWorkflowResponse_Committed 

type DequeueWorkflowResponse_Committed struct {
	// contains filtered or unexported fields
}

func (*DequeueWorkflowResponse_Committed) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowResponse_Committed.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowResponse_Committed) ProtoMessage 

func (*DequeueWorkflowResponse_Committed) ProtoMessage()

func (*DequeueWorkflowResponse_Committed) ProtoReflect 

func (x *DequeueWorkflowResponse_Committed) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowResponse_Committed) Reset 

func (x *DequeueWorkflowResponse_Committed) Reset()

func (*DequeueWorkflowResponse_Committed) String 

func (x *DequeueWorkflowResponse_Committed) String() string

type DequeueWorkflowResponse_Committed_ 

type DequeueWorkflowResponse_Committed_ struct {
	Committed *DequeueWorkflowResponse_Committed `protobuf:"bytes,3,opt,name=committed,proto3,oneof"`
}

type DequeueWorkflowResponse_Dequeue 

type DequeueWorkflowResponse_Dequeue struct {
	Instance *WorkflowInstance `` /* 129-byte string literal not displayed */
	Event    *WorkflowEvent    `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty" toml:"event,omitempty" mapstructure:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowResponse_Dequeue) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowResponse_Dequeue.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowResponse_Dequeue) GetEvent 

func (x *DequeueWorkflowResponse_Dequeue) GetEvent() *WorkflowEvent

func (*DequeueWorkflowResponse_Dequeue) GetInstance 

func (x *DequeueWorkflowResponse_Dequeue) GetInstance() *WorkflowInstance

func (*DequeueWorkflowResponse_Dequeue) ProtoMessage 

func (*DequeueWorkflowResponse_Dequeue) ProtoMessage()

func (*DequeueWorkflowResponse_Dequeue) ProtoReflect 

func (x *DequeueWorkflowResponse_Dequeue) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowResponse_Dequeue) Reset 

func (x *DequeueWorkflowResponse_Dequeue) Reset()

func (*DequeueWorkflowResponse_Dequeue) String 

func (x *DequeueWorkflowResponse_Dequeue) String() string

type DequeueWorkflowResponse_Dequeue_ 

type DequeueWorkflowResponse_Dequeue_ struct {
	Dequeue *DequeueWorkflowResponse_Dequeue `protobuf:"bytes,1,opt,name=dequeue,proto3,oneof"`
}

type DequeueWorkflowResponse_Status 

type DequeueWorkflowResponse_Status struct {
	Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty" toml:"err,omitempty" mapstructure:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueWorkflowResponse_Status) Descriptor deprecated 

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

Deprecated: Use DequeueWorkflowResponse_Status.ProtoReflect.Descriptor instead.

func (*DequeueWorkflowResponse_Status) GetErr 

func (x *DequeueWorkflowResponse_Status) GetErr() string

func (*DequeueWorkflowResponse_Status) ProtoMessage 

func (*DequeueWorkflowResponse_Status) ProtoMessage()

func (*DequeueWorkflowResponse_Status) ProtoReflect 

func (x *DequeueWorkflowResponse_Status) ProtoReflect() protoreflect.Message

func (*DequeueWorkflowResponse_Status) Reset 

func (x *DequeueWorkflowResponse_Status) Reset()

func (*DequeueWorkflowResponse_Status) String 

func (x *DequeueWorkflowResponse_Status) String() string

type DequeueWorkflowResponse_Status_ 

type DequeueWorkflowResponse_Status_ struct {
	Status *DequeueWorkflowResponse_Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

type EnqueueWorkflowRequest 

type EnqueueWorkflowRequest struct {
	Domain       string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	InstanceName string `` /* 167-byte string literal not displayed */
	WorkflowName string `` /* 167-byte string literal not displayed */
	Parameters   []byte `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EnqueueWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use EnqueueWorkflowRequest.ProtoReflect.Descriptor instead.

func (*EnqueueWorkflowRequest) GetDomain 

func (x *EnqueueWorkflowRequest) GetDomain() string

func (*EnqueueWorkflowRequest) GetInstanceName 

func (x *EnqueueWorkflowRequest) GetInstanceName() string

func (*EnqueueWorkflowRequest) GetParameters 

func (x *EnqueueWorkflowRequest) GetParameters() []byte

func (*EnqueueWorkflowRequest) GetWorkflowName 

func (x *EnqueueWorkflowRequest) GetWorkflowName() string

func (*EnqueueWorkflowRequest) ProtoMessage 

func (*EnqueueWorkflowRequest) ProtoMessage()

func (*EnqueueWorkflowRequest) ProtoReflect 

func (x *EnqueueWorkflowRequest) ProtoReflect() protoreflect.Message

func (*EnqueueWorkflowRequest) Reset 

func (x *EnqueueWorkflowRequest) Reset()

func (*EnqueueWorkflowRequest) String 

func (x *EnqueueWorkflowRequest) String() string

type EnqueueWorkflowResponse 

type EnqueueWorkflowResponse struct {
	// contains filtered or unexported fields
}

func (*EnqueueWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use EnqueueWorkflowResponse.ProtoReflect.Descriptor instead.

func (*EnqueueWorkflowResponse) ProtoMessage 

func (*EnqueueWorkflowResponse) ProtoMessage()

func (*EnqueueWorkflowResponse) ProtoReflect 

func (x *EnqueueWorkflowResponse) ProtoReflect() protoreflect.Message

func (*EnqueueWorkflowResponse) Reset 

func (x *EnqueueWorkflowResponse) Reset()

func (*EnqueueWorkflowResponse) String 

func (x *EnqueueWorkflowResponse) String() string

type GetWorkflowInstanceByNameRequest 

type GetWorkflowInstanceByNameRequest struct {
	Domain       string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	InstanceName string `` /* 167-byte string literal not displayed */
	WorkflowName string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkflowInstanceByNameRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstanceByNameRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstanceByNameRequest) GetDomain 

func (x *GetWorkflowInstanceByNameRequest) GetDomain() string

func (*GetWorkflowInstanceByNameRequest) GetInstanceName 

func (x *GetWorkflowInstanceByNameRequest) GetInstanceName() string

func (*GetWorkflowInstanceByNameRequest) GetWorkflowName 

func (x *GetWorkflowInstanceByNameRequest) GetWorkflowName() string

func (*GetWorkflowInstanceByNameRequest) ProtoMessage 

func (*GetWorkflowInstanceByNameRequest) ProtoMessage()

func (*GetWorkflowInstanceByNameRequest) ProtoReflect 

func (x *GetWorkflowInstanceByNameRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstanceByNameRequest) Reset 

func (x *GetWorkflowInstanceByNameRequest) Reset()

func (*GetWorkflowInstanceByNameRequest) String 

func (x *GetWorkflowInstanceByNameRequest) String() string

type GetWorkflowInstanceByNameResponse 

type GetWorkflowInstanceByNameResponse struct {
	WorkflowInstance *WorkflowInstance `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkflowInstanceByNameResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowInstanceByNameResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowInstanceByNameResponse) GetWorkflowInstance 

func (x *GetWorkflowInstanceByNameResponse) GetWorkflowInstance() *WorkflowInstance

func (*GetWorkflowInstanceByNameResponse) ProtoMessage 

func (*GetWorkflowInstanceByNameResponse) ProtoMessage()

func (*GetWorkflowInstanceByNameResponse) ProtoReflect 

func (x *GetWorkflowInstanceByNameResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowInstanceByNameResponse) Reset 

func (x *GetWorkflowInstanceByNameResponse) Reset()

func (*GetWorkflowInstanceByNameResponse) String 

func (x *GetWorkflowInstanceByNameResponse) String() string

type GetWorkflowScheduleByNameRequest 

type GetWorkflowScheduleByNameRequest struct {
	Domain       string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	InstanceName string `` /* 167-byte string literal not displayed */
	WorkflowName string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkflowScheduleByNameRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowScheduleByNameRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowScheduleByNameRequest) GetDomain 

func (x *GetWorkflowScheduleByNameRequest) GetDomain() string

func (*GetWorkflowScheduleByNameRequest) GetInstanceName 

func (x *GetWorkflowScheduleByNameRequest) GetInstanceName() string

func (*GetWorkflowScheduleByNameRequest) GetWorkflowName 

func (x *GetWorkflowScheduleByNameRequest) GetWorkflowName() string

func (*GetWorkflowScheduleByNameRequest) ProtoMessage 

func (*GetWorkflowScheduleByNameRequest) ProtoMessage()

func (*GetWorkflowScheduleByNameRequest) ProtoReflect 

func (x *GetWorkflowScheduleByNameRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowScheduleByNameRequest) Reset 

func (x *GetWorkflowScheduleByNameRequest) Reset()

func (*GetWorkflowScheduleByNameRequest) String 

func (x *GetWorkflowScheduleByNameRequest) String() string

type GetWorkflowScheduleByNameResponse 

type GetWorkflowScheduleByNameResponse struct {
	Schedule *Schedule `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkflowScheduleByNameResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowScheduleByNameResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowScheduleByNameResponse) GetSchedule 

func (x *GetWorkflowScheduleByNameResponse) GetSchedule() *Schedule

func (*GetWorkflowScheduleByNameResponse) ProtoMessage 

func (*GetWorkflowScheduleByNameResponse) ProtoMessage()

func (*GetWorkflowScheduleByNameResponse) ProtoReflect 

func (x *GetWorkflowScheduleByNameResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowScheduleByNameResponse) Reset 

func (x *GetWorkflowScheduleByNameResponse) Reset()

func (*GetWorkflowScheduleByNameResponse) String 

func (x *GetWorkflowScheduleByNameResponse) String() string

type KillWorkflowRequest 

type KillWorkflowRequest struct {
	Domain       string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	InstanceName string `` /* 167-byte string literal not displayed */
	WorkflowName string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KillWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use KillWorkflowRequest.ProtoReflect.Descriptor instead.

func (*KillWorkflowRequest) GetDomain 

func (x *KillWorkflowRequest) GetDomain() string

func (*KillWorkflowRequest) GetInstanceName 

func (x *KillWorkflowRequest) GetInstanceName() string

func (*KillWorkflowRequest) GetWorkflowName 

func (x *KillWorkflowRequest) GetWorkflowName() string

func (*KillWorkflowRequest) ProtoMessage 

func (*KillWorkflowRequest) ProtoMessage()

func (*KillWorkflowRequest) ProtoReflect 

func (x *KillWorkflowRequest) ProtoReflect() protoreflect.Message

func (*KillWorkflowRequest) Reset 

func (x *KillWorkflowRequest) Reset()

func (*KillWorkflowRequest) String 

func (x *KillWorkflowRequest) String() string

type KillWorkflowResponse 

type KillWorkflowResponse struct {
	// contains filtered or unexported fields
}

func (*KillWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use KillWorkflowResponse.ProtoReflect.Descriptor instead.

func (*KillWorkflowResponse) ProtoMessage 

func (*KillWorkflowResponse) ProtoMessage()

func (*KillWorkflowResponse) ProtoReflect 

func (x *KillWorkflowResponse) ProtoReflect() protoreflect.Message

func (*KillWorkflowResponse) Reset 

func (x *KillWorkflowResponse) Reset()

func (*KillWorkflowResponse) String 

func (x *KillWorkflowResponse) String() string

type ListWorkflowInstancesRequest 

type ListWorkflowInstancesRequest struct {
	Domain       string                  `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	WorkflowName *wrapperspb.StringValue `` /* 167-byte string literal not displayed */
	InstanceName *wrapperspb.StringValue `` /* 167-byte string literal not displayed */
	IsRunning    *wrapperspb.BoolValue   `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListWorkflowInstancesRequest) Descriptor deprecated 

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

Deprecated: Use ListWorkflowInstancesRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowInstancesRequest) GetDomain 

func (x *ListWorkflowInstancesRequest) GetDomain() string

func (*ListWorkflowInstancesRequest) GetInstanceName 

func (x *ListWorkflowInstancesRequest) GetInstanceName() *wrapperspb.StringValue

func (*ListWorkflowInstancesRequest) GetIsRunning 

func (x *ListWorkflowInstancesRequest) GetIsRunning() *wrapperspb.BoolValue

func (*ListWorkflowInstancesRequest) GetWorkflowName 

func (x *ListWorkflowInstancesRequest) GetWorkflowName() *wrapperspb.StringValue

func (*ListWorkflowInstancesRequest) ProtoMessage 

func (*ListWorkflowInstancesRequest) ProtoMessage()

func (*ListWorkflowInstancesRequest) ProtoReflect 

func (x *ListWorkflowInstancesRequest) ProtoReflect() protoreflect.Message

func (*ListWorkflowInstancesRequest) Reset 

func (x *ListWorkflowInstancesRequest) Reset()

func (*ListWorkflowInstancesRequest) String 

func (x *ListWorkflowInstancesRequest) String() string

type ListWorkflowInstancesResponse 

type ListWorkflowInstancesResponse struct {
	WorkflowInstance *WorkflowInstance `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListWorkflowInstancesResponse) Descriptor deprecated 

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

Deprecated: Use ListWorkflowInstancesResponse.ProtoReflect.Descriptor instead.

func (*ListWorkflowInstancesResponse) GetWorkflowInstance 

func (x *ListWorkflowInstancesResponse) GetWorkflowInstance() *WorkflowInstance

func (*ListWorkflowInstancesResponse) ProtoMessage 

func (*ListWorkflowInstancesResponse) ProtoMessage()

func (*ListWorkflowInstancesResponse) ProtoReflect 

func (x *ListWorkflowInstancesResponse) ProtoReflect() protoreflect.Message

func (*ListWorkflowInstancesResponse) Reset 

func (x *ListWorkflowInstancesResponse) Reset()

func (*ListWorkflowInstancesResponse) String 

func (x *ListWorkflowInstancesResponse) String() string

type ListWorkflowSchedulesRequest 

type ListWorkflowSchedulesRequest struct {
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkflowSchedulesRequest) Descriptor deprecated 

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

Deprecated: Use ListWorkflowSchedulesRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowSchedulesRequest) GetDomain 

func (x *ListWorkflowSchedulesRequest) GetDomain() string

func (*ListWorkflowSchedulesRequest) ProtoMessage 

func (*ListWorkflowSchedulesRequest) ProtoMessage()

func (*ListWorkflowSchedulesRequest) ProtoReflect 

func (x *ListWorkflowSchedulesRequest) ProtoReflect() protoreflect.Message

func (*ListWorkflowSchedulesRequest) Reset 

func (x *ListWorkflowSchedulesRequest) Reset()

func (*ListWorkflowSchedulesRequest) String 

func (x *ListWorkflowSchedulesRequest) String() string

type ListWorkflowSchedulesResponse 

type ListWorkflowSchedulesResponse struct {
	NumSchedules int32     `` /* 168-byte string literal not displayed */
	Schedule     *Schedule `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListWorkflowSchedulesResponse) Descriptor deprecated 

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

Deprecated: Use ListWorkflowSchedulesResponse.ProtoReflect.Descriptor instead.

func (*ListWorkflowSchedulesResponse) GetNumSchedules 

func (x *ListWorkflowSchedulesResponse) GetNumSchedules() int32

func (*ListWorkflowSchedulesResponse) GetSchedule 

func (x *ListWorkflowSchedulesResponse) GetSchedule() *Schedule

func (*ListWorkflowSchedulesResponse) ProtoMessage 

func (*ListWorkflowSchedulesResponse) ProtoMessage()

func (*ListWorkflowSchedulesResponse) ProtoReflect 

func (x *ListWorkflowSchedulesResponse) ProtoReflect() protoreflect.Message

func (*ListWorkflowSchedulesResponse) Reset 

func (x *ListWorkflowSchedulesResponse) Reset()

func (*ListWorkflowSchedulesResponse) String 

func (x *ListWorkflowSchedulesResponse) String() string

type Schedule 

type Schedule struct {
	Domain         string                 `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	InstanceName   string                 `` /* 167-byte string literal not displayed */
	WorkflowName   string                 `` /* 167-byte string literal not displayed */
	Parameters     []byte                 `` /* 137-byte string literal not displayed */
	Recurrence     string                 `` /* 137-byte string literal not displayed */
	NextDueAt      *timestamppb.Timestamp `` /* 156-byte string literal not displayed */
	LastEnqueuedAt *timestamppb.Timestamp `` /* 181-byte string literal not displayed */
	Enabled        bool                   `` /* 126-byte string literal not displayed */
	LastStart      *timestamppb.Timestamp `` /* 152-byte string literal not displayed */
	LastEnd        *timestamppb.Timestamp `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Schedule) Descriptor deprecated 

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

Deprecated: Use Schedule.ProtoReflect.Descriptor instead.

func (*Schedule) GetDomain 

func (x *Schedule) GetDomain() string

func (*Schedule) GetEnabled 

func (x *Schedule) GetEnabled() bool

func (*Schedule) GetInstanceName 

func (x *Schedule) GetInstanceName() string

func (*Schedule) GetLastEnd 

func (x *Schedule) GetLastEnd() *timestamppb.Timestamp

func (*Schedule) GetLastEnqueuedAt 

func (x *Schedule) GetLastEnqueuedAt() *timestamppb.Timestamp

func (*Schedule) GetLastStart 

func (x *Schedule) GetLastStart() *timestamppb.Timestamp

func (*Schedule) GetNextDueAt 

func (x *Schedule) GetNextDueAt() *timestamppb.Timestamp

func (*Schedule) GetParameters 

func (x *Schedule) GetParameters() []byte

func (*Schedule) GetRecurrence 

func (x *Schedule) GetRecurrence() string

func (*Schedule) GetWorkflowName 

func (x *Schedule) GetWorkflowName() string

func (*Schedule) ProtoMessage 

func (*Schedule) ProtoMessage()

func (*Schedule) ProtoReflect 

func (x *Schedule) ProtoReflect() protoreflect.Message

func (*Schedule) Reset 

func (x *Schedule) Reset()

func (*Schedule) String 

func (x *Schedule) String() string

type Task 

type Task struct {
	Name       string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	Parameters []byte                 `` /* 137-byte string literal not displayed */
	StartAfter *timestamppb.Timestamp `` /* 157-byte string literal not displayed */
	Metadata   *TaskMetadata          `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetMetadata 

func (x *Task) GetMetadata() *TaskMetadata

func (*Task) GetName 

func (x *Task) GetName() string

func (*Task) GetParameters 

func (x *Task) GetParameters() []byte

func (*Task) GetStartAfter 

func (x *Task) GetStartAfter() *timestamppb.Timestamp

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskMetadata 

type TaskMetadata struct {
	EnqueuedAt *timestamppb.Timestamp `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskMetadata) Descriptor deprecated 

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

Deprecated: Use TaskMetadata.ProtoReflect.Descriptor instead.

func (*TaskMetadata) GetEnqueuedAt 

func (x *TaskMetadata) GetEnqueuedAt() *timestamppb.Timestamp

func (*TaskMetadata) ProtoMessage 

func (*TaskMetadata) ProtoMessage()

func (*TaskMetadata) ProtoReflect 

func (x *TaskMetadata) ProtoReflect() protoreflect.Message

func (*TaskMetadata) Reset 

func (x *TaskMetadata) Reset()

func (*TaskMetadata) String 

func (x *TaskMetadata) String() string

type TaskResult 

type TaskResult struct {
	TaskName   string `` /* 147-byte string literal not displayed */
	Parameters []byte `` /* 137-byte string literal not displayed */
	Status     string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty" mapstructure:"status,omitempty"`
	ErrorText  string `` /* 152-byte string literal not displayed */
	Result     []byte `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty" toml:"result,omitempty" mapstructure:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResult) Descriptor deprecated 

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

Deprecated: Use TaskResult.ProtoReflect.Descriptor instead.

func (*TaskResult) GetErrorText 

func (x *TaskResult) GetErrorText() string

func (*TaskResult) GetParameters 

func (x *TaskResult) GetParameters() []byte

func (*TaskResult) GetResult 

func (x *TaskResult) GetResult() []byte

func (*TaskResult) GetStatus 

func (x *TaskResult) GetStatus() string

func (*TaskResult) GetTaskName 

func (x *TaskResult) GetTaskName() string

func (*TaskResult) ProtoMessage 

func (*TaskResult) ProtoMessage()

func (*TaskResult) ProtoReflect 

func (x *TaskResult) ProtoReflect() protoreflect.Message

func (*TaskResult) Reset 

func (x *TaskResult) Reset()

func (*TaskResult) String 

func (x *TaskResult) String() string

type UnimplementedCerealServiceServer 

type UnimplementedCerealServiceServer struct {
}

UnimplementedCerealServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCerealServiceServer) CancelWorkflow 

func (*UnimplementedCerealServiceServer) CancelWorkflow(context.Context, *CancelWorkflowRequest) (*CancelWorkflowResponse, error)

func (*UnimplementedCerealServiceServer) CreateWorkflowSchedule 

func (*UnimplementedCerealServiceServer) CreateWorkflowSchedule(context.Context, *CreateWorkflowScheduleRequest) (*CreateWorkflowScheduleResponse, error)

func (*UnimplementedCerealServiceServer) DequeueTask 

func (*UnimplementedCerealServiceServer) DequeueTask(CerealService_DequeueTaskServer) error

func (*UnimplementedCerealServiceServer) DequeueWorkflow 

func (*UnimplementedCerealServiceServer) DequeueWorkflow(CerealService_DequeueWorkflowServer) error

func (*UnimplementedCerealServiceServer) DequeueWorkflowChunk 

func (*UnimplementedCerealServiceServer) DequeueWorkflowChunk(CerealService_DequeueWorkflowChunkServer) error

func (*UnimplementedCerealServiceServer) EnqueueWorkflow 

func (*UnimplementedCerealServiceServer) EnqueueWorkflow(context.Context, *EnqueueWorkflowRequest) (*EnqueueWorkflowResponse, error)

func (*UnimplementedCerealServiceServer) GetWorkflowInstanceByName 

func (*UnimplementedCerealServiceServer) GetWorkflowInstanceByName(context.Context, *GetWorkflowInstanceByNameRequest) (*GetWorkflowInstanceByNameResponse, error)

func (*UnimplementedCerealServiceServer) GetWorkflowScheduleByName 

func (*UnimplementedCerealServiceServer) GetWorkflowScheduleByName(context.Context, *GetWorkflowScheduleByNameRequest) (*GetWorkflowScheduleByNameResponse, error)

func (*UnimplementedCerealServiceServer) KillWorkflow 

func (*UnimplementedCerealServiceServer) KillWorkflow(context.Context, *KillWorkflowRequest) (*KillWorkflowResponse, error)

func (*UnimplementedCerealServiceServer) ListWorkflowInstances 

func (*UnimplementedCerealServiceServer) ListWorkflowInstances(*ListWorkflowInstancesRequest, CerealService_ListWorkflowInstancesServer) error

func (*UnimplementedCerealServiceServer) ListWorkflowSchedules 

func (*UnimplementedCerealServiceServer) ListWorkflowSchedules(*ListWorkflowSchedulesRequest, CerealService_ListWorkflowSchedulesServer) error

func (*UnimplementedCerealServiceServer) UpdateWorkflowScheduleByName 

func (*UnimplementedCerealServiceServer) UpdateWorkflowScheduleByName(context.Context, *UpdateWorkflowScheduleByNameRequest) (*UpdateWorkflowScheduleByNameResponse, error)

type UpdateWorkflowScheduleByNameRequest 

type UpdateWorkflowScheduleByNameRequest struct {
	Domain       string                  `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	InstanceName string                  `` /* 167-byte string literal not displayed */
	WorkflowName string                  `` /* 167-byte string literal not displayed */
	Enabled      *wrapperspb.BoolValue   `protobuf:"bytes,4,opt,name=enabled,proto3" json:"enabled,omitempty" toml:"enabled,omitempty" mapstructure:"enabled,omitempty"`
	Parameters   *wrapperspb.BytesValue  `` /* 137-byte string literal not displayed */
	Recurrence   *wrapperspb.StringValue `` /* 137-byte string literal not displayed */
	NextRunAt    *timestamppb.Timestamp  `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateWorkflowScheduleByNameRequest) Descriptor deprecated 

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

Deprecated: Use UpdateWorkflowScheduleByNameRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowScheduleByNameRequest) GetDomain 

func (x *UpdateWorkflowScheduleByNameRequest) GetDomain() string

func (*UpdateWorkflowScheduleByNameRequest) GetEnabled 

func (x *UpdateWorkflowScheduleByNameRequest) GetEnabled() *wrapperspb.BoolValue

func (*UpdateWorkflowScheduleByNameRequest) GetInstanceName 

func (x *UpdateWorkflowScheduleByNameRequest) GetInstanceName() string

func (*UpdateWorkflowScheduleByNameRequest) GetNextRunAt 

func (x *UpdateWorkflowScheduleByNameRequest) GetNextRunAt() *timestamppb.Timestamp

func (*UpdateWorkflowScheduleByNameRequest) GetParameters 

func (x *UpdateWorkflowScheduleByNameRequest) GetParameters() *wrapperspb.BytesValue

func (*UpdateWorkflowScheduleByNameRequest) GetRecurrence 

func (x *UpdateWorkflowScheduleByNameRequest) GetRecurrence() *wrapperspb.StringValue

func (*UpdateWorkflowScheduleByNameRequest) GetWorkflowName 

func (x *UpdateWorkflowScheduleByNameRequest) GetWorkflowName() string

func (*UpdateWorkflowScheduleByNameRequest) ProtoMessage 

func (*UpdateWorkflowScheduleByNameRequest) ProtoMessage()

func (*UpdateWorkflowScheduleByNameRequest) ProtoReflect 

func (x *UpdateWorkflowScheduleByNameRequest) ProtoReflect() protoreflect.Message

func (*UpdateWorkflowScheduleByNameRequest) Reset 

func (x *UpdateWorkflowScheduleByNameRequest) Reset()

func (*UpdateWorkflowScheduleByNameRequest) String 

func (x *UpdateWorkflowScheduleByNameRequest) String() string

type UpdateWorkflowScheduleByNameResponse 

type UpdateWorkflowScheduleByNameResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateWorkflowScheduleByNameResponse) Descriptor deprecated 

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

Deprecated: Use UpdateWorkflowScheduleByNameResponse.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowScheduleByNameResponse) ProtoMessage 

func (*UpdateWorkflowScheduleByNameResponse) ProtoMessage()

func (*UpdateWorkflowScheduleByNameResponse) ProtoReflect 

func (x *UpdateWorkflowScheduleByNameResponse) ProtoReflect() protoreflect.Message

func (*UpdateWorkflowScheduleByNameResponse) Reset 

func (x *UpdateWorkflowScheduleByNameResponse) Reset()

func (*UpdateWorkflowScheduleByNameResponse) String 

func (x *UpdateWorkflowScheduleByNameResponse) String() string

type WorkflowEvent 

type WorkflowEvent struct {
	Type               string                 `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty" toml:"type,omitempty" mapstructure:"type,omitempty"`
	EnqueuedTaskCount  int64                  `` /* 197-byte string literal not displayed */
	CompletedTaskCount int64                  `` /* 202-byte string literal not displayed */
	TaskResult         *TaskResult            `` /* 157-byte string literal not displayed */
	EnqueuedAt         *timestamppb.Timestamp `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkflowEvent) Descriptor deprecated 

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

Deprecated: Use WorkflowEvent.ProtoReflect.Descriptor instead.

func (*WorkflowEvent) GetCompletedTaskCount 

func (x *WorkflowEvent) GetCompletedTaskCount() int64

func (*WorkflowEvent) GetEnqueuedAt 

func (x *WorkflowEvent) GetEnqueuedAt() *timestamppb.Timestamp

func (*WorkflowEvent) GetEnqueuedTaskCount 

func (x *WorkflowEvent) GetEnqueuedTaskCount() int64

func (*WorkflowEvent) GetTaskResult 

func (x *WorkflowEvent) GetTaskResult() *TaskResult

func (*WorkflowEvent) GetType 

func (x *WorkflowEvent) GetType() string

func (*WorkflowEvent) ProtoMessage 

func (*WorkflowEvent) ProtoMessage()

func (*WorkflowEvent) ProtoReflect 

func (x *WorkflowEvent) ProtoReflect() protoreflect.Message

func (*WorkflowEvent) Reset 

func (x *WorkflowEvent) Reset()

func (*WorkflowEvent) String 

func (x *WorkflowEvent) String() string

type WorkflowInstance 

type WorkflowInstance struct {
	Domain       string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty" toml:"domain,omitempty" mapstructure:"domain,omitempty"`
	InstanceName string `` /* 167-byte string literal not displayed */
	WorkflowName string `` /* 167-byte string literal not displayed */
	Status       string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty" mapstructure:"status,omitempty"`
	Parameters   []byte `` /* 137-byte string literal not displayed */
	Payload      []byte `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty" toml:"payload,omitempty" mapstructure:"payload,omitempty"`
	Result       []byte `protobuf:"bytes,7,opt,name=result,proto3" json:"result,omitempty" toml:"result,omitempty" mapstructure:"result,omitempty"`
	Err          string `protobuf:"bytes,8,opt,name=err,proto3" json:"err,omitempty" toml:"err,omitempty" mapstructure:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowInstance) Descriptor deprecated 

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

Deprecated: Use WorkflowInstance.ProtoReflect.Descriptor instead.

func (*WorkflowInstance) GetDomain 

func (x *WorkflowInstance) GetDomain() string

func (*WorkflowInstance) GetErr 

func (x *WorkflowInstance) GetErr() string

func (*WorkflowInstance) GetInstanceName 

func (x *WorkflowInstance) GetInstanceName() string

func (*WorkflowInstance) GetParameters 

func (x *WorkflowInstance) GetParameters() []byte

func (*WorkflowInstance) GetPayload 

func (x *WorkflowInstance) GetPayload() []byte

func (*WorkflowInstance) GetResult 

func (x *WorkflowInstance) GetResult() []byte

func (*WorkflowInstance) GetStatus 

func (x *WorkflowInstance) GetStatus() string

func (*WorkflowInstance) GetWorkflowName 

func (x *WorkflowInstance) GetWorkflowName() string

func (*WorkflowInstance) ProtoMessage 

func (*WorkflowInstance) ProtoMessage()

func (*WorkflowInstance) ProtoReflect 

func (x *WorkflowInstance) ProtoReflect() protoreflect.Message

func (*WorkflowInstance) Reset 

func (x *WorkflowInstance) Reset()

func (*WorkflowInstance) String 

func (x *WorkflowInstance) String() string

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.