shared

package
v0.0.0-...-562037d Latest Latest
Warning

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

Go to latest
Published: Feb 19, 2019 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL