hello

Documentation

Index

• Variables
• func GetHelloKind(opts ...actor.PropsOption) *cluster.Kind
• func HelloFactory(factory func() Hello)
• func NewHelloKind(factory func() Hello, timeout time.Duration, opts ...actor.PropsOption) *cluster.Kind
• type Hello
• type HelloActor
  • func (a *HelloActor) Receive(ctx actor.Context)
• type HelloGrainClient
  • func GetHelloGrainClient(c *cluster.Cluster, id string) *HelloGrainClient
  • func (g *HelloGrainClient) SayHello(r *emptypb.Empty, opts ...cluster.GrainCallOption) (*SayHelloResponse, error)
• type SayHelloResponse
  • func (*SayHelloResponse) Descriptor() ([]byte, []int)
  • func (x *SayHelloResponse) GetMessage() string
  • func (*SayHelloResponse) ProtoMessage()
  • func (x *SayHelloResponse) ProtoReflect() protoreflect.Message
  • func (x *SayHelloResponse) Reset()
  • func (x *SayHelloResponse) String() string

Variables

var File_test_hello_hello_proto protoreflect.FileDescriptor

Functions

func GetHelloKind

func GetHelloKind(opts ...actor.PropsOption) *cluster.Kind

GetHelloKind instantiates a new cluster.Kind for Hello

func HelloFactory

func HelloFactory(factory func() Hello)

HelloFactory produces a Hello

func NewHelloKind

func NewHelloKind(factory func() Hello, timeout time.Duration, opts ...actor.PropsOption) *cluster.Kind

GetHelloKind instantiates a new cluster.Kind for Hello

Types

type Hello

type Hello interface {
	Init(ctx cluster.GrainContext)
	Terminate(ctx cluster.GrainContext)
	ReceiveDefault(ctx cluster.GrainContext)
	SayHello(req *emptypb.Empty, ctx cluster.GrainContext) (*SayHelloResponse, error)
}

Hello interfaces the services available to the Hello

type HelloActor

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

HelloActor represents the actor structure

func (*HelloActor) Receive

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

Receive ensures the lifecycle of the actor for the received message

type HelloGrainClient

type HelloGrainClient struct {
	Identity string
	// contains filtered or unexported fields
}

HelloGrainClient holds the base data for the HelloGrain

func GetHelloGrainClient

func GetHelloGrainClient(c *cluster.Cluster, id string) *HelloGrainClient

GetHelloGrainClient instantiates a new HelloGrainClient with given Identity

func (*HelloGrainClient) SayHello

func (g *HelloGrainClient) SayHello(r *emptypb.Empty, opts ...cluster.GrainCallOption) (*SayHelloResponse, error)

SayHello requests the execution on to the cluster with CallOptions

type SayHelloResponse

type SayHelloResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*SayHelloResponse) Descriptor

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

Deprecated: Use SayHelloResponse.ProtoReflect.Descriptor instead.

func (*SayHelloResponse) GetMessage

func (x *SayHelloResponse) GetMessage() string

func (*SayHelloResponse) ProtoMessage

func (*SayHelloResponse) ProtoMessage()

func (*SayHelloResponse) ProtoReflect

func (x *SayHelloResponse) ProtoReflect() protoreflect.Message

func (*SayHelloResponse) Reset

func (x *SayHelloResponse) Reset()

func (*SayHelloResponse) String

func (x *SayHelloResponse) String() string