node

Documentation

Index

• Variables
• func BuildProcessWithOption(opts ...core.NodeOption) core.INode
• func Get() core.INode
• type Acceptor
  • func NewAcceptor(sys core.ISystem, port int) (*Acceptor, error)
  • func (acceptor *Acceptor) Exit()
  • func (acceptor *Acceptor) Update()
• type NormalSystem
  • func (sys *NormalSystem) Actors() []core.IActor
  • func (sys *NormalSystem) AddressBook() core.IAddressBook
  • func (sys *NormalSystem) Call(tar router.Target, mw *msg.Wrapper) error
  • func (sys *NormalSystem) Exit(wait *sync.WaitGroup)
  • func (sys *NormalSystem) FindActor(ctx context.Context, id string) (core.IActor, error)
  • func (sys *NormalSystem) Loader(ty string) core.IActorBuilder
  • func (sys *NormalSystem) Pub(topic string, msg *router.Message) error
  • func (sys *NormalSystem) Register(builder core.IActorBuilder) (core.IActor, error)
  • func (sys *NormalSystem) Send(tar router.Target, mw *msg.Wrapper) error
  • func (sys *NormalSystem) Sub(topic string, channel string, opts ...pubsub.TopicOption) (*pubsub.Channel, error)
  • func (sys *NormalSystem) Unregister(id, ty string) error
  • func (sys *NormalSystem) Update()

Variables

var ErrSelfCall = errors.New("cannot call self node through RPC")

Functions

func BuildProcessWithOption

func BuildProcessWithOption(opts ...core.NodeOption) core.INode

func Get

func Get() core.INode

Types

type Acceptor

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

func NewAcceptor

func NewAcceptor(sys core.ISystem, port int) (*Acceptor, error)

func (*Acceptor) Exit

func (acceptor *Acceptor) Exit()

func (*Acceptor) Update

func (acceptor *Acceptor) Update()

type NormalSystem

type NormalSystem struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*NormalSystem) Actors

func (sys *NormalSystem) Actors() []core.IActor

func (*NormalSystem) AddressBook

func (sys *NormalSystem) AddressBook() core.IAddressBook

func (*NormalSystem) Call

func (sys *NormalSystem) Call(tar router.Target, mw *msg.Wrapper) error

func (*NormalSystem) Exit

func (sys *NormalSystem) Exit(wait *sync.WaitGroup)

func (*NormalSystem) FindActor

func (sys *NormalSystem) FindActor(ctx context.Context, id string) (core.IActor, error)

func (*NormalSystem) Loader

func (sys *NormalSystem) Loader(ty string) core.IActorBuilder

func (*NormalSystem) Pub

func (sys *NormalSystem) Pub(topic string, msg *router.Message) error

func (*NormalSystem) Register

func (sys *NormalSystem) Register(builder core.IActorBuilder) (core.IActor, error)

func (*NormalSystem) Send

func (sys *NormalSystem) Send(tar router.Target, mw *msg.Wrapper) error

func (*NormalSystem) Sub

func (sys *NormalSystem) Sub(topic string, channel string, opts ...pubsub.TopicOption) (*pubsub.Channel, error)

func (*NormalSystem) Unregister

func (sys *NormalSystem) Unregister(id, ty string) error

func (*NormalSystem) Update

func (sys *NormalSystem) Update()