shared

package
v0.0.0-...-e005607 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProtos   = fmt.Errorf("proto: integer overflow")
)

Functions

func HelloFactory 

func HelloFactory(factory func() Hello)

func RegisterHelloServer 

func RegisterHelloServer(s *grpc.Server, srv HelloServer)

Types

type AddRequest 

type AddRequest struct {
	A                    float64  `protobuf:"fixed64,1,opt,name=a,proto3" json:"a,omitempty"`
	B                    float64  `protobuf:"fixed64,2,opt,name=b,proto3" json:"b,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddRequest) Descriptor 

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

func (*AddRequest) Equal 

func (this *AddRequest) Equal(that interface{}) bool

func (*AddRequest) GetA 

func (m *AddRequest) GetA() float64

func (*AddRequest) GetB 

func (m *AddRequest) GetB() float64

func (*AddRequest) GoString 

func (this *AddRequest) GoString() string

func (*AddRequest) Marshal 

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

func (*AddRequest) MarshalTo 

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

func (*AddRequest) ProtoMessage 

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset 

func (m *AddRequest) Reset()

func (*AddRequest) Size 

func (m *AddRequest) Size() (n int)

func (*AddRequest) String 

func (this *AddRequest) String() string

func (*AddRequest) Unmarshal 

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

func (*AddRequest) XXX_DiscardUnknown 

func (m *AddRequest) XXX_DiscardUnknown()

func (*AddRequest) XXX_Marshal 

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

func (*AddRequest) XXX_Merge 

func (dst *AddRequest) XXX_Merge(src proto.Message)

func (*AddRequest) XXX_Size 

func (m *AddRequest) XXX_Size() int

func (*AddRequest) XXX_Unmarshal 

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

type AddResponse 

type AddResponse struct {
	Result               float64  `protobuf:"fixed64,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddResponse) Descriptor 

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

func (*AddResponse) Equal 

func (this *AddResponse) Equal(that interface{}) bool

func (*AddResponse) GetResult 

func (m *AddResponse) GetResult() float64

func (*AddResponse) GoString 

func (this *AddResponse) GoString() string

func (*AddResponse) Marshal 

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

func (*AddResponse) MarshalTo 

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

func (*AddResponse) ProtoMessage 

func (*AddResponse) ProtoMessage()

func (*AddResponse) Reset 

func (m *AddResponse) Reset()

func (*AddResponse) Size 

func (m *AddResponse) Size() (n int)

func (*AddResponse) String 

func (this *AddResponse) String() string

func (*AddResponse) Unmarshal 

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

func (*AddResponse) XXX_DiscardUnknown 

func (m *AddResponse) XXX_DiscardUnknown()

func (*AddResponse) XXX_Marshal 

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

func (*AddResponse) XXX_Merge 

func (dst *AddResponse) XXX_Merge(src proto.Message)

func (*AddResponse) XXX_Size 

func (m *AddResponse) XXX_Size() int

func (*AddResponse) XXX_Unmarshal 

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

type Hello 

type Hello interface {
	Init(id string)

	SayHello(*HelloRequest, cluster.GrainContext) (*HelloResponse, error)

	Add(*AddRequest, cluster.GrainContext) (*AddResponse, error)

	VoidFunc(*AddRequest, cluster.GrainContext) (*Unit, error)
}

type HelloActor 

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

func (*HelloActor) Receive 

func (a *HelloActor) Receive(ctx actor.Context)

type HelloClient 

type HelloClient interface {
	SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
	Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)
	VoidFunc(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*Unit, error)
}

func NewHelloClient 

func NewHelloClient(cc *grpc.ClientConn) HelloClient

type HelloGrain 

type HelloGrain struct {
	ID string
}

func GetHelloGrain 

func GetHelloGrain(id string) *HelloGrain

func (*HelloGrain) Add 

func (g *HelloGrain) Add(r *AddRequest) (*AddResponse, error)

func (*HelloGrain) AddChan 

func (g *HelloGrain) AddChan(r *AddRequest) (<-chan *AddResponse, <-chan error)

func (*HelloGrain) AddChanWithOpts 

func (g *HelloGrain) AddChanWithOpts(r *AddRequest, opts *cluster.GrainCallOptions) (<-chan *AddResponse, <-chan error)

func (*HelloGrain) AddWithOpts 

func (g *HelloGrain) AddWithOpts(r *AddRequest, opts *cluster.GrainCallOptions) (*AddResponse, error)

func (*HelloGrain) SayHello 

func (g *HelloGrain) SayHello(r *HelloRequest) (*HelloResponse, error)

func (*HelloGrain) SayHelloChan 

func (g *HelloGrain) SayHelloChan(r *HelloRequest) (<-chan *HelloResponse, <-chan error)

func (*HelloGrain) SayHelloChanWithOpts 

func (g *HelloGrain) SayHelloChanWithOpts(r *HelloRequest, opts *cluster.GrainCallOptions) (<-chan *HelloResponse, <-chan error)

func (*HelloGrain) SayHelloWithOpts 

func (g *HelloGrain) SayHelloWithOpts(r *HelloRequest, opts *cluster.GrainCallOptions) (*HelloResponse, error)

func (*HelloGrain) VoidFunc 

func (g *HelloGrain) VoidFunc(r *AddRequest) (*Unit, error)

func (*HelloGrain) VoidFuncChan 

func (g *HelloGrain) VoidFuncChan(r *AddRequest) (<-chan *Unit, <-chan error)

func (*HelloGrain) VoidFuncChanWithOpts 

func (g *HelloGrain) VoidFuncChanWithOpts(r *AddRequest, opts *cluster.GrainCallOptions) (<-chan *Unit, <-chan error)

func (*HelloGrain) VoidFuncWithOpts 

func (g *HelloGrain) VoidFuncWithOpts(r *AddRequest, opts *cluster.GrainCallOptions) (*Unit, error)

type HelloRequest 

type HelloRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HelloRequest) Descriptor 

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

func (*HelloRequest) Equal 

func (this *HelloRequest) Equal(that interface{}) bool

func (*HelloRequest) GetName 

func (m *HelloRequest) GetName() string

func (*HelloRequest) GoString 

func (this *HelloRequest) GoString() string

func (*HelloRequest) Marshal 

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

func (*HelloRequest) MarshalTo 

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

func (*HelloRequest) ProtoMessage 

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset 

func (m *HelloRequest) Reset()

func (*HelloRequest) Size 

func (m *HelloRequest) Size() (n int)

func (*HelloRequest) String 

func (this *HelloRequest) String() string

func (*HelloRequest) Unmarshal 

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

func (*HelloRequest) XXX_DiscardUnknown 

func (m *HelloRequest) XXX_DiscardUnknown()

func (*HelloRequest) XXX_Marshal 

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

func (*HelloRequest) XXX_Merge 

func (dst *HelloRequest) XXX_Merge(src proto.Message)

func (*HelloRequest) XXX_Size 

func (m *HelloRequest) XXX_Size() int

func (*HelloRequest) XXX_Unmarshal 

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

type HelloResponse 

type HelloResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HelloResponse) Descriptor 

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

func (*HelloResponse) Equal 

func (this *HelloResponse) Equal(that interface{}) bool

func (*HelloResponse) GetMessage 

func (m *HelloResponse) GetMessage() string

func (*HelloResponse) GoString 

func (this *HelloResponse) GoString() string

func (*HelloResponse) Marshal 

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

func (*HelloResponse) MarshalTo 

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

func (*HelloResponse) ProtoMessage 

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) Reset 

func (m *HelloResponse) Reset()

func (*HelloResponse) Size 

func (m *HelloResponse) Size() (n int)

func (*HelloResponse) String 

func (this *HelloResponse) String() string

func (*HelloResponse) Unmarshal 

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

func (*HelloResponse) XXX_DiscardUnknown 

func (m *HelloResponse) XXX_DiscardUnknown()

func (*HelloResponse) XXX_Marshal 

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

func (*HelloResponse) XXX_Merge 

func (dst *HelloResponse) XXX_Merge(src proto.Message)

func (*HelloResponse) XXX_Size 

func (m *HelloResponse) XXX_Size() int

func (*HelloResponse) XXX_Unmarshal 

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

type HelloServer 

type HelloServer interface {
	SayHello(context.Context, *HelloRequest) (*HelloResponse, error)
	Add(context.Context, *AddRequest) (*AddResponse, error)
	VoidFunc(context.Context, *AddRequest) (*Unit, error)
}

type Unit 

type Unit struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Unit) Descriptor 

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

func (*Unit) Equal 

func (this *Unit) Equal(that interface{}) bool

func (*Unit) GoString 

func (this *Unit) GoString() string

func (*Unit) Marshal 

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

func (*Unit) MarshalTo 

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

func (*Unit) ProtoMessage 

func (*Unit) ProtoMessage()

func (*Unit) Reset 

func (m *Unit) Reset()

func (*Unit) Size 

func (m *Unit) Size() (n int)

func (*Unit) String 

func (this *Unit) String() string

func (*Unit) Unmarshal 

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

func (*Unit) XXX_DiscardUnknown 

func (m *Unit) XXX_DiscardUnknown()

func (*Unit) XXX_Marshal 

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

func (*Unit) XXX_Merge 

func (dst *Unit) XXX_Merge(src proto.Message)

func (*Unit) XXX_Size 

func (m *Unit) XXX_Size() int

func (*Unit) XXX_Unmarshal 

func (m *Unit) 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.