actor

Documentation

Index

• type Service
  • func NewService() *Service
  • func (service *Service) Join() error
  • func (service *Service) Leave() error
  • func (service *Service) ServiceName() string
  • func (service *Service) ServiceType() plugins.ServiceType
  • func (service *Service) SetConfig(c config.Config)
  • func (service *Service) SetCoordinator(coord coordinator_plugin.Service)
  • func (service *Service) SetStatus(status cluster.NodeStatus) error
  • func (service *Service) Start() error
  • func (service *Service) Status() cluster.NodeStatus
  • func (service *Service) Stop() error

Types

type Service

type Service struct {
	plugins.Config
	// contains filtered or unexported fields
}

Service represents a actor service.

func NewService

func NewService() *Service

NewService returns a new actor service.

func (*Service) Join

func (service *Service) Join() error

Join joins the actor service to the cluster.

func (*Service) Leave

func (service *Service) Leave() error

Leave leaves the actor service from the cluster.

func (*Service) ServiceName

func (service *Service) ServiceName() string

ServiceName returns the plug-in service name.

func (*Service) ServiceType

func (service *Service) ServiceType() plugins.ServiceType

ServiceType returns the plug-in service type.

func (*Service) SetConfig

func (service *Service) SetConfig(c config.Config)

SetConfig sets a manager configuration.

func (*Service) SetCoordinator

func (service *Service) SetCoordinator(coord coordinator_plugin.Service)

SetCoordinator sets a coordinator service.

func (*Service) SetStatus

func (service *Service) SetStatus(status cluster.NodeStatus) error

SetStatus sets a actor status.

func (*Service) Start

func (service *Service) Start() error

Start starts the actor service.

func (*Service) Status

func (service *Service) Status() cluster.NodeStatus

Status returns a actor status.

func (*Service) Stop

func (service *Service) Stop() error

Stop stops the actor server.