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 DoworkRequest
  • func (*DoworkRequest) Descriptor() ([]byte, []int)
  • func (x *DoworkRequest) GetName() string
  • func (*DoworkRequest) ProtoMessage()
  • func (x *DoworkRequest) ProtoReflect() protoreflect.Message
  • func (x *DoworkRequest) Reset()
  • func (x *DoworkRequest) String() string
• type DoworkResponse
  • func (*DoworkResponse) Descriptor() ([]byte, []int)
  • func (x *DoworkResponse) GetMessage() string
  • func (*DoworkResponse) ProtoMessage()
  • func (x *DoworkResponse) ProtoReflect() protoreflect.Message
  • func (x *DoworkResponse) Reset()
  • func (x *DoworkResponse) String() string
• type Hello
• type HelloActor
  • func (a *HelloActor) Receive(ctx actor.Context)
• type HelloGrainClient
  • func GetHelloGrainClient(c *cluster.Cluster, id string) *HelloGrainClient
  • func (g *HelloGrainClient) Dowork(r *DoworkRequest, opts ...cluster.GrainCallOption) (*DoworkResponse, error)
  • func (g *HelloGrainClient) DoworkFuture(r *DoworkRequest, opts ...cluster.GrainCallOption) (*actor.Future, error)
  • func (g *HelloGrainClient) SayHello(r *SayHelloRequest, opts ...cluster.GrainCallOption) (*SayHelloResponse, error)
• type SayHelloRequest
  • func (*SayHelloRequest) Descriptor() ([]byte, []int)
  • func (x *SayHelloRequest) GetName() string
  • func (*SayHelloRequest) ProtoMessage()
  • func (x *SayHelloRequest) ProtoReflect() protoreflect.Message
  • func (x *SayHelloRequest) Reset()
  • func (x *SayHelloRequest) String() string
• 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_reenter_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 DoworkRequest

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

func (*DoworkRequest) Descriptor

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

Deprecated: Use DoworkRequest.ProtoReflect.Descriptor instead.

func (*DoworkRequest) GetName

func (x *DoworkRequest) GetName() string

func (*DoworkRequest) ProtoMessage

func (*DoworkRequest) ProtoMessage()

func (*DoworkRequest) ProtoReflect

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

func (*DoworkRequest) Reset

func (x *DoworkRequest) Reset()

func (*DoworkRequest) String

func (x *DoworkRequest) String() string

type DoworkResponse

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

func (*DoworkResponse) Descriptor

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

Deprecated: Use DoworkResponse.ProtoReflect.Descriptor instead.

func (*DoworkResponse) GetMessage

func (x *DoworkResponse) GetMessage() string

func (*DoworkResponse) ProtoMessage

func (*DoworkResponse) ProtoMessage()

func (*DoworkResponse) ProtoReflect

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

func (*DoworkResponse) Reset

func (x *DoworkResponse) Reset()

func (*DoworkResponse) String

func (x *DoworkResponse) String() string

type Hello

type Hello interface {
	Init(ctx cluster.GrainContext)
	Terminate(ctx cluster.GrainContext)
	ReceiveDefault(ctx cluster.GrainContext)
	SayHello(req *SayHelloRequest, respond func(*SayHelloResponse), onError func(error), ctx cluster.GrainContext) error
	Dowork(req *DoworkRequest, ctx cluster.GrainContext) (*DoworkResponse, 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) Dowork

func (g *HelloGrainClient) Dowork(r *DoworkRequest, opts ...cluster.GrainCallOption) (*DoworkResponse, error)

Dowork requests the execution on to the cluster with CallOptions

func (*HelloGrainClient) DoworkFuture

func (g *HelloGrainClient) DoworkFuture(r *DoworkRequest, opts ...cluster.GrainCallOption) (*actor.Future, error)

DoworkFuture return a future for the execution of Dowork on the cluster

func (*HelloGrainClient) SayHello

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

SayHello requests the execution on to the cluster with CallOptions

type SayHelloRequest

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

func (*SayHelloRequest) Descriptor

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

Deprecated: Use SayHelloRequest.ProtoReflect.Descriptor instead.

func (*SayHelloRequest) GetName

func (x *SayHelloRequest) GetName() string

func (*SayHelloRequest) ProtoMessage

func (*SayHelloRequest) ProtoMessage()

func (*SayHelloRequest) ProtoReflect

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

func (*SayHelloRequest) Reset

func (x *SayHelloRequest) Reset()

func (*SayHelloRequest) String

func (x *SayHelloRequest) String() string

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