protoactor-go: github.com/AsynkronIT/protoactor-go/examples/cluster-metrics/shared Index | Files

package shared

import "github.com/AsynkronIT/protoactor-go/examples/cluster-metrics/shared"

Package shared is a generated protocol buffer package.

It is generated from these files:

protos.proto

It has these top-level messages:

Unit
HelloRequest
HelloResponse
AddRequest
AddResponse

Index

Package Files

actors.go protos.pb.go protos_protoactor.go

Variables

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

func HelloFactory Uses

func HelloFactory(factory func() Hello)

type AddRequest Uses

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"`
}

func (*AddRequest) Descriptor Uses

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

func (*AddRequest) Equal Uses

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

func (*AddRequest) GetA Uses

func (m *AddRequest) GetA() float64

func (*AddRequest) GetB Uses

func (m *AddRequest) GetB() float64

func (*AddRequest) GoString Uses

func (this *AddRequest) GoString() string

func (*AddRequest) Marshal Uses

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

func (*AddRequest) MarshalTo Uses

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

func (*AddRequest) ProtoMessage Uses

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset Uses

func (m *AddRequest) Reset()

func (*AddRequest) Size Uses

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

func (*AddRequest) String Uses

func (this *AddRequest) String() string

func (*AddRequest) Unmarshal Uses

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

type AddResponse Uses

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

func (*AddResponse) Descriptor Uses

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

func (*AddResponse) Equal Uses

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

func (*AddResponse) GetResult Uses

func (m *AddResponse) GetResult() float64

func (*AddResponse) GoString Uses

func (this *AddResponse) GoString() string

func (*AddResponse) Marshal Uses

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

func (*AddResponse) MarshalTo Uses

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

func (*AddResponse) ProtoMessage Uses

func (*AddResponse) ProtoMessage()

func (*AddResponse) Reset Uses

func (m *AddResponse) Reset()

func (*AddResponse) Size Uses

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

func (*AddResponse) String Uses

func (this *AddResponse) String() string

func (*AddResponse) Unmarshal Uses

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

type Hello Uses

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 Uses

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

func (*HelloActor) Receive Uses

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

type HelloGrain Uses

type HelloGrain struct {
    ID string
}

func GetHelloGrain Uses

func GetHelloGrain(id string) *HelloGrain

func (*HelloGrain) Add Uses

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

func (*HelloGrain) AddChan Uses

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

func (*HelloGrain) AddChanWithOpts Uses

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

func (*HelloGrain) AddWithOpts Uses

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

func (*HelloGrain) SayHello Uses

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

func (*HelloGrain) SayHelloChan Uses

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

func (*HelloGrain) SayHelloChanWithOpts Uses

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

func (*HelloGrain) SayHelloWithOpts Uses

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

func (*HelloGrain) VoidFunc Uses

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

func (*HelloGrain) VoidFuncChan Uses

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

func (*HelloGrain) VoidFuncChanWithOpts Uses

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

func (*HelloGrain) VoidFuncWithOpts Uses

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

type HelloRequest Uses

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

func (*HelloRequest) Descriptor Uses

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

func (*HelloRequest) Equal Uses

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

func (*HelloRequest) GetName Uses

func (m *HelloRequest) GetName() string

func (*HelloRequest) GoString Uses

func (this *HelloRequest) GoString() string

func (*HelloRequest) Marshal Uses

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

func (*HelloRequest) MarshalTo Uses

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

func (*HelloRequest) ProtoMessage Uses

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset Uses

func (m *HelloRequest) Reset()

func (*HelloRequest) Size Uses

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

func (*HelloRequest) String Uses

func (this *HelloRequest) String() string

func (*HelloRequest) Unmarshal Uses

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

type HelloResponse Uses

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

func (*HelloResponse) Descriptor Uses

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

func (*HelloResponse) Equal Uses

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

func (*HelloResponse) GetMessage Uses

func (m *HelloResponse) GetMessage() string

func (*HelloResponse) GoString Uses

func (this *HelloResponse) GoString() string

func (*HelloResponse) Marshal Uses

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

func (*HelloResponse) MarshalTo Uses

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

func (*HelloResponse) ProtoMessage Uses

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) Reset Uses

func (m *HelloResponse) Reset()

func (*HelloResponse) Size Uses

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

func (*HelloResponse) String Uses

func (this *HelloResponse) String() string

func (*HelloResponse) Unmarshal Uses

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

type Unit Uses

type Unit struct {
}

func (*Unit) Descriptor Uses

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

func (*Unit) Equal Uses

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

func (*Unit) GoString Uses

func (this *Unit) GoString() string

func (*Unit) Marshal Uses

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

func (*Unit) MarshalTo Uses

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

func (*Unit) ProtoMessage Uses

func (*Unit) ProtoMessage()

func (*Unit) Reset Uses

func (m *Unit) Reset()

func (*Unit) Size Uses

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

func (*Unit) String Uses

func (this *Unit) String() string

func (*Unit) Unmarshal Uses

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

Package shared imports 11 packages (graph). Updated 2017-12-27. Refresh now. Tools for package owners.