Versions in this module Expand all Collapse all v0 v0.3.0 Jan 13, 2021 Changes in this version + var File_tck_action_proto protoreflect.FileDescriptor + func NewTestModel() action.EntityHandler + func NewTestModelTwo() action.EntityHandler + func RegisterActionTckModelServer(s grpc.ServiceRegistrar, srv ActionTckModelServer) + func RegisterActionTwoServer(s grpc.ServiceRegistrar, srv ActionTwoServer) + type ActionTckModelClient interface + ProcessStreamed func(ctx context.Context, opts ...grpc.CallOption) (ActionTckModel_ProcessStreamedClient, error) + ProcessStreamedIn func(ctx context.Context, opts ...grpc.CallOption) (ActionTckModel_ProcessStreamedInClient, error) + ProcessStreamedOut func(ctx context.Context, in *Request, opts ...grpc.CallOption) (ActionTckModel_ProcessStreamedOutClient, error) + ProcessUnary func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) + func NewActionTckModelClient(cc grpc.ClientConnInterface) ActionTckModelClient + type ActionTckModelServer interface + ProcessStreamed func(ActionTckModel_ProcessStreamedServer) error + ProcessStreamedIn func(ActionTckModel_ProcessStreamedInServer) error + ProcessStreamedOut func(*Request, ActionTckModel_ProcessStreamedOutServer) error + ProcessUnary func(context.Context, *Request) (*Response, error) + type ActionTckModel_ProcessStreamedClient interface + Recv func() (*Response, error) + Send func(*Request) error + type ActionTckModel_ProcessStreamedInClient interface + CloseAndRecv func() (*Response, error) + Send func(*Request) error + type ActionTckModel_ProcessStreamedInServer interface + Recv func() (*Request, error) + SendAndClose func(*Response) error + type ActionTckModel_ProcessStreamedOutClient interface + Recv func() (*Response, error) + type ActionTckModel_ProcessStreamedOutServer interface + Send func(*Response) error + type ActionTckModel_ProcessStreamedServer interface + Recv func() (*Request, error) + Send func(*Response) error + type ActionTwoClient interface + Call func(ctx context.Context, in *OtherRequest, opts ...grpc.CallOption) (*Response, error) + func NewActionTwoClient(cc grpc.ClientConnInterface) ActionTwoClient + type ActionTwoServer interface + Call func(context.Context, *OtherRequest) (*Response, error) + type Fail struct + Message string + func (*Fail) Descriptor() ([]byte, []int) + func (*Fail) ProtoMessage() + func (x *Fail) GetMessage() string + func (x *Fail) ProtoReflect() protoreflect.Message + func (x *Fail) Reset() + func (x *Fail) String() string + type Forward struct + Id string + func (*Forward) Descriptor() ([]byte, []int) + func (*Forward) ProtoMessage() + func (x *Forward) GetId() string + func (x *Forward) ProtoReflect() protoreflect.Message + func (x *Forward) Reset() + func (x *Forward) String() string + type OtherRequest struct + Id string + func (*OtherRequest) Descriptor() ([]byte, []int) + func (*OtherRequest) ProtoMessage() + func (x *OtherRequest) GetId() string + func (x *OtherRequest) ProtoReflect() protoreflect.Message + func (x *OtherRequest) Reset() + func (x *OtherRequest) String() string + type ProcessGroup struct + Steps []*ProcessStep + func (*ProcessGroup) Descriptor() ([]byte, []int) + func (*ProcessGroup) ProtoMessage() + func (x *ProcessGroup) GetSteps() []*ProcessStep + func (x *ProcessGroup) ProtoReflect() protoreflect.Message + func (x *ProcessGroup) Reset() + func (x *ProcessGroup) String() string + type ProcessStep struct + Step isProcessStep_Step + func (*ProcessStep) Descriptor() ([]byte, []int) + func (*ProcessStep) ProtoMessage() + func (m *ProcessStep) GetStep() isProcessStep_Step + func (x *ProcessStep) GetEffect() *SideEffect + func (x *ProcessStep) GetFail() *Fail + func (x *ProcessStep) GetForward() *Forward + func (x *ProcessStep) GetReply() *Reply + func (x *ProcessStep) ProtoReflect() protoreflect.Message + func (x *ProcessStep) Reset() + func (x *ProcessStep) String() string + type ProcessStep_Effect struct + Effect *SideEffect + type ProcessStep_Fail struct + Fail *Fail + type ProcessStep_Forward struct + Forward *Forward + type ProcessStep_Reply struct + Reply *Reply + type Reply struct + Message string + func (*Reply) Descriptor() ([]byte, []int) + func (*Reply) ProtoMessage() + func (x *Reply) GetMessage() string + func (x *Reply) ProtoReflect() protoreflect.Message + func (x *Reply) Reset() + func (x *Reply) String() string + type Request struct + Groups []*ProcessGroup + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (x *Request) GetGroups() []*ProcessGroup + func (x *Request) ProtoReflect() protoreflect.Message + func (x *Request) Reset() + func (x *Request) String() string + type Response struct + Message string + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (x *Response) GetMessage() string + func (x *Response) ProtoReflect() protoreflect.Message + func (x *Response) Reset() + func (x *Response) String() string + type SideEffect struct + Id string + Synchronous bool + func (*SideEffect) Descriptor() ([]byte, []int) + func (*SideEffect) ProtoMessage() + func (x *SideEffect) GetId() string + func (x *SideEffect) GetSynchronous() bool + func (x *SideEffect) ProtoReflect() protoreflect.Message + func (x *SideEffect) Reset() + func (x *SideEffect) String() string + type TestModel struct + func (m *TestModel) HandleCommand(ctx *action.Context, name string, msg proto.Message) error + type TestModelTwo struct + func (m *TestModelTwo) HandleCommand(ctx *action.Context, name string, msg proto.Message) error + type UnimplementedActionTckModelServer struct + func (UnimplementedActionTckModelServer) ProcessStreamed(ActionTckModel_ProcessStreamedServer) error + func (UnimplementedActionTckModelServer) ProcessStreamedIn(ActionTckModel_ProcessStreamedInServer) error + func (UnimplementedActionTckModelServer) ProcessStreamedOut(*Request, ActionTckModel_ProcessStreamedOutServer) error + func (UnimplementedActionTckModelServer) ProcessUnary(context.Context, *Request) (*Response, error) + type UnimplementedActionTwoServer struct + func (UnimplementedActionTwoServer) Call(context.Context, *OtherRequest) (*Response, error) + type UnsafeActionTckModelServer interface + type UnsafeActionTwoServer interface