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

package shared

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

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)

HelloFactory produces a 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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*AddRequest) XXX_DiscardUnknown Uses

func (m *AddRequest) XXX_DiscardUnknown()

func (*AddRequest) XXX_Marshal Uses

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

func (*AddRequest) XXX_Merge Uses

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

func (*AddRequest) XXX_Size Uses

func (m *AddRequest) XXX_Size() int

func (*AddRequest) XXX_Unmarshal Uses

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

type AddResponse Uses

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 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

func (*AddResponse) XXX_DiscardUnknown Uses

func (m *AddResponse) XXX_DiscardUnknown()

func (*AddResponse) XXX_Marshal Uses

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

func (*AddResponse) XXX_Merge Uses

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

func (*AddResponse) XXX_Size Uses

func (m *AddResponse) XXX_Size() int

func (*AddResponse) XXX_Unmarshal Uses

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

type Hello Uses

type Hello interface {
    Init(id string)
    Terminate()

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

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

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

Hello interfaces the services available to the Hello

type HelloActor Uses

type HelloActor struct {
    Timeout *time.Duration
    // contains filtered or unexported fields
}

HelloActor represents the actor structure

func (*HelloActor) Receive Uses

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

Receive ensures the lifecycle of the actor for the received message

type HelloGrain Uses

type HelloGrain struct {
    ID string
}

HelloGrain holds the base data for the HelloGrain

func GetHelloGrain Uses

func GetHelloGrain(id string) *HelloGrain

GetHelloGrain instantiates a new HelloGrain with given ID

func (*HelloGrain) Add Uses

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

Add requests the execution on to the cluster using default options

func (*HelloGrain) AddChan Uses

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

AddChan allows to use a channel to execute the method using default options

func (*HelloGrain) AddChanWithOpts Uses

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

AddChanWithOpts allows to use a channel to execute the method

func (*HelloGrain) AddWithOpts Uses

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

AddWithOpts requests the execution on to the cluster

func (*HelloGrain) SayHello Uses

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

SayHello requests the execution on to the cluster using default options

func (*HelloGrain) SayHelloChan Uses

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

SayHelloChan allows to use a channel to execute the method using default options

func (*HelloGrain) SayHelloChanWithOpts Uses

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

SayHelloChanWithOpts allows to use a channel to execute the method

func (*HelloGrain) SayHelloWithOpts Uses

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

SayHelloWithOpts requests the execution on to the cluster

func (*HelloGrain) VoidFunc Uses

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

VoidFunc requests the execution on to the cluster using default options

func (*HelloGrain) VoidFuncChan Uses

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

VoidFuncChan allows to use a channel to execute the method using default options

func (*HelloGrain) VoidFuncChanWithOpts Uses

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

VoidFuncChanWithOpts allows to use a channel to execute the method

func (*HelloGrain) VoidFuncWithOpts Uses

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

VoidFuncWithOpts requests the execution on to the cluster

type HelloRequest Uses

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 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

func (*HelloRequest) XXX_DiscardUnknown Uses

func (m *HelloRequest) XXX_DiscardUnknown()

func (*HelloRequest) XXX_Marshal Uses

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

func (*HelloRequest) XXX_Merge Uses

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

func (*HelloRequest) XXX_Size Uses

func (m *HelloRequest) XXX_Size() int

func (*HelloRequest) XXX_Unmarshal Uses

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

type HelloResponse Uses

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 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

func (*HelloResponse) XXX_DiscardUnknown Uses

func (m *HelloResponse) XXX_DiscardUnknown()

func (*HelloResponse) XXX_Marshal Uses

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

func (*HelloResponse) XXX_Merge Uses

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

func (*HelloResponse) XXX_Size Uses

func (m *HelloResponse) XXX_Size() int

func (*HelloResponse) XXX_Unmarshal Uses

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

type Unit Uses

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

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

func (*Unit) XXX_DiscardUnknown Uses

func (m *Unit) XXX_DiscardUnknown()

func (*Unit) XXX_Marshal Uses

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

func (*Unit) XXX_Merge Uses

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

func (*Unit) XXX_Size Uses

func (m *Unit) XXX_Size() int

func (*Unit) XXX_Unmarshal Uses

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

Package shared imports 13 packages (graph) and is imported by 4 packages. Updated 2019-08-19. Refresh now. Tools for package owners.