service

Documentation

Index

• Constants
• func ActorEndpoint(actorName, id string) string
• type GoletService
  • func New() *GoletService
  • func (s *GoletService) Invoke(ctx context.Context, in *pb.RemoteMessage) (out *pb.RemoteMessage, err error)
  • func (s *GoletService) List(ctx context.Context, in *pb.ListRequest) (out *pb.ListResponse, err error)
  • func (s *GoletService) Load(ctx context.Context, in *pb.LoadRequest) (out *pb.LoadResponse, err error)
  • func (s *GoletService) Shutdown()
  • func (s *GoletService) Unload(ctx context.Context, in *pb.UnloadRequest) (out *pb.UnloadResponse, err error)

Constants

const (
	SCHEME_ACTOR = "actor"
)

Functions

func ActorEndpoint

func ActorEndpoint(actorName, id string) string

Types

type GoletService

type GoletService struct {
	pb.UnimplementedGoletServer

	// actor id -> plugins
	cache.Indexer
	// contains filtered or unexported fields
}

func New

func New() *GoletService

func (*GoletService) Invoke

func (s *GoletService) Invoke(ctx context.Context, in *pb.RemoteMessage) (out *pb.RemoteMessage, err error)

func (*GoletService) List

func (s *GoletService) List(ctx context.Context, in *pb.ListRequest) (out *pb.ListResponse, err error)

func (*GoletService) Load

func (s *GoletService) Load(ctx context.Context, in *pb.LoadRequest) (out *pb.LoadResponse, err error)

func (*GoletService) Shutdown

func (s *GoletService) Shutdown()

func (*GoletService) Unload

func (s *GoletService) Unload(ctx context.Context, in *pb.UnloadRequest) (out *pb.UnloadResponse, err error)