Versions in this module Expand all Collapse all v1 v1.0.0 Jan 10, 2021 Changes in this version + var ErrIntOverflowProtos = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling") + func HelloFactory(factory func() Hello) + func RegisterHelloServer(s *grpc.Server, srv HelloServer) + type AddRequest struct + A float64 + B float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*AddRequest) Descriptor() ([]byte, []int) + func (*AddRequest) ProtoMessage() + func (dst *AddRequest) XXX_Merge(src proto.Message) + func (m *AddRequest) GetA() float64 + func (m *AddRequest) GetB() float64 + func (m *AddRequest) Marshal() (dAtA []byte, err error) + func (m *AddRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AddRequest) Reset() + func (m *AddRequest) Size() (n int) + func (m *AddRequest) Unmarshal(dAtA []byte) error + func (m *AddRequest) XXX_DiscardUnknown() + func (m *AddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AddRequest) XXX_Size() int + func (m *AddRequest) XXX_Unmarshal(b []byte) error + func (this *AddRequest) Equal(that interface{}) bool + func (this *AddRequest) GoString() string + func (this *AddRequest) String() string + type AddResponse struct + Result float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*AddResponse) Descriptor() ([]byte, []int) + func (*AddResponse) ProtoMessage() + func (dst *AddResponse) XXX_Merge(src proto.Message) + func (m *AddResponse) GetResult() float64 + func (m *AddResponse) Marshal() (dAtA []byte, err error) + func (m *AddResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AddResponse) Reset() + func (m *AddResponse) Size() (n int) + func (m *AddResponse) Unmarshal(dAtA []byte) error + func (m *AddResponse) XXX_DiscardUnknown() + func (m *AddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AddResponse) XXX_Size() int + func (m *AddResponse) XXX_Unmarshal(b []byte) error + func (this *AddResponse) Equal(that interface{}) bool + func (this *AddResponse) GoString() string + func (this *AddResponse) String() string + type Hello interface + Add func(*AddRequest, cluster.GrainContext) (*AddResponse, error) + Init func(id string) + SayHello func(*HelloRequest, cluster.GrainContext) (*HelloResponse, error) + VoidFunc func(*AddRequest, cluster.GrainContext) (*Unit, error) + type HelloActor struct + func (a *HelloActor) Receive(ctx actor.Context) + type HelloClient interface + Add func(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error) + SayHello func(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error) + VoidFunc func(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*Unit, error) + func NewHelloClient(cc *grpc.ClientConn) HelloClient + type HelloGrain struct + ID string + func GetHelloGrain(id string) *HelloGrain + func (g *HelloGrain) Add(r *AddRequest) (*AddResponse, error) + func (g *HelloGrain) AddChan(r *AddRequest) (<-chan *AddResponse, <-chan error) + func (g *HelloGrain) AddChanWithOpts(r *AddRequest, opts *cluster.GrainCallOptions) (<-chan *AddResponse, <-chan error) + func (g *HelloGrain) AddWithOpts(r *AddRequest, opts *cluster.GrainCallOptions) (*AddResponse, error) + func (g *HelloGrain) SayHello(r *HelloRequest) (*HelloResponse, error) + func (g *HelloGrain) SayHelloChan(r *HelloRequest) (<-chan *HelloResponse, <-chan error) + func (g *HelloGrain) SayHelloChanWithOpts(r *HelloRequest, opts *cluster.GrainCallOptions) (<-chan *HelloResponse, <-chan error) + func (g *HelloGrain) SayHelloWithOpts(r *HelloRequest, opts *cluster.GrainCallOptions) (*HelloResponse, error) + func (g *HelloGrain) VoidFunc(r *AddRequest) (*Unit, error) + func (g *HelloGrain) VoidFuncChan(r *AddRequest) (<-chan *Unit, <-chan error) + func (g *HelloGrain) VoidFuncChanWithOpts(r *AddRequest, opts *cluster.GrainCallOptions) (<-chan *Unit, <-chan error) + func (g *HelloGrain) VoidFuncWithOpts(r *AddRequest, opts *cluster.GrainCallOptions) (*Unit, error) + type HelloRequest struct + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*HelloRequest) Descriptor() ([]byte, []int) + func (*HelloRequest) ProtoMessage() + func (dst *HelloRequest) XXX_Merge(src proto.Message) + func (m *HelloRequest) GetName() string + func (m *HelloRequest) Marshal() (dAtA []byte, err error) + func (m *HelloRequest) MarshalTo(dAtA []byte) (int, error) + func (m *HelloRequest) Reset() + func (m *HelloRequest) Size() (n int) + func (m *HelloRequest) Unmarshal(dAtA []byte) error + func (m *HelloRequest) XXX_DiscardUnknown() + func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HelloRequest) XXX_Size() int + func (m *HelloRequest) XXX_Unmarshal(b []byte) error + func (this *HelloRequest) Equal(that interface{}) bool + func (this *HelloRequest) GoString() string + func (this *HelloRequest) String() string + type HelloResponse struct + Message string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*HelloResponse) Descriptor() ([]byte, []int) + func (*HelloResponse) ProtoMessage() + func (dst *HelloResponse) XXX_Merge(src proto.Message) + func (m *HelloResponse) GetMessage() string + func (m *HelloResponse) Marshal() (dAtA []byte, err error) + func (m *HelloResponse) MarshalTo(dAtA []byte) (int, error) + func (m *HelloResponse) Reset() + func (m *HelloResponse) Size() (n int) + func (m *HelloResponse) Unmarshal(dAtA []byte) error + func (m *HelloResponse) XXX_DiscardUnknown() + func (m *HelloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HelloResponse) XXX_Size() int + func (m *HelloResponse) XXX_Unmarshal(b []byte) error + func (this *HelloResponse) Equal(that interface{}) bool + func (this *HelloResponse) GoString() string + func (this *HelloResponse) String() string + type HelloServer interface + Add func(context.Context, *AddRequest) (*AddResponse, error) + SayHello func(context.Context, *HelloRequest) (*HelloResponse, error) + VoidFunc func(context.Context, *AddRequest) (*Unit, error) + type Unit struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*Unit) Descriptor() ([]byte, []int) + func (*Unit) ProtoMessage() + func (dst *Unit) XXX_Merge(src proto.Message) + func (m *Unit) Marshal() (dAtA []byte, err error) + func (m *Unit) MarshalTo(dAtA []byte) (int, error) + func (m *Unit) Reset() + func (m *Unit) Size() (n int) + func (m *Unit) Unmarshal(dAtA []byte) error + func (m *Unit) XXX_DiscardUnknown() + func (m *Unit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Unit) XXX_Size() int + func (m *Unit) XXX_Unmarshal(b []byte) error + func (this *Unit) Equal(that interface{}) bool + func (this *Unit) GoString() string + func (this *Unit) String() string
Go to main page