cluster

Documentation

Index

• type Cluster
  • func NewCluster(node core.Node, client *clientv3.Client, opt ...Option) (*Cluster, error)
  • func (c *Cluster) Endpoints() []*remote.Endpoint
  • func (c *Cluster) SendMessage(ctx context.Context, to core.PID, message core.Message) error
  • func (c *Cluster) Spawn(behavior core.ProcessBehavior, opts *core.SpawnOptions) (core.Process, error)
  • func (c *Cluster) StaticRoute(nodeName string, nodeAddr string, attrs *attributes.Attributes) error
  • func (c *Cluster) Stop()
  • func (c *Cluster) UpdateState(state resolver.State) error
• type Option
  • func Address(addr string) Option
  • func Discovery(discovery registry.Discovery) Option
  • func Registrar(registrar registry.Registrar) Option
• type Options

Types

type Cluster

type Cluster struct {
	// contains filtered or unexported fields
}

func NewCluster

func NewCluster(node core.Node, client *clientv3.Client, opt ...Option) (*Cluster, error)

func (*Cluster) Endpoints

func (c *Cluster) Endpoints() []*remote.Endpoint

func (*Cluster) SendMessage

func (c *Cluster) SendMessage(ctx context.Context, to core.PID, message core.Message) error

func (*Cluster) Spawn

func (c *Cluster) Spawn(behavior core.ProcessBehavior, opts *core.SpawnOptions) (core.Process, error)

func (*Cluster) StaticRoute

func (c *Cluster) StaticRoute(nodeName string, nodeAddr string, attrs *attributes.Attributes) error

func (*Cluster) Stop

func (c *Cluster) Stop()

func (*Cluster) UpdateState

func (c *Cluster) UpdateState(state resolver.State) error

type Option

type Option func(opts *Options)

func Address

func Address(addr string) Option

func Discovery

func Discovery(discovery registry.Discovery) Option

func Registrar

func Registrar(registrar registry.Registrar) Option

type Options

type Options struct {
	// contains filtered or unexported fields
}