process

Documentation

Index

• func NewGlobalUUID() string
• func NewNamespaceUUID(name string, space uuid.UUID) string
• type Channels
• type MeshID
• type Process
  • func New(addr string, encoder encoder.Encoder) (*Process, error)
  • func (proc *Process) Call(pkg *oceanus.Pkg) (interface{}, error)
  • func (proc *Process) Local() abstract.Mesh
  • func (proc *Process) Logger() logis.Logger
  • func (proc *Process) NewAcceptor(addr string) network.Acceptor
  • func (proc *Process) NewConnector(addr string) network.Connector
  • func (proc *Process) Router() abstract.Router
  • func (proc *Process) Run()
  • func (proc *Process) Send(pkg *oceanus.Pkg) error
  • func (proc *Process) Sends(pkg *oceanus.Pkg) error
  • func (proc *Process) Stop()
• type Remotes
• type Router
• type RpcID

Functions

func NewGlobalUUID

func NewGlobalUUID() string

func NewNamespaceUUID

func NewNamespaceUUID(name string, space uuid.UUID) string

Types

type Channels

type Channels = map[RpcID]chan interface{}

type MeshID

type MeshID = proto.MeshID

type Process

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

func New

func New(addr string, encoder encoder.Encoder) (*Process, error)

创建进程

func (*Process) Call

func (proc *Process) Call(pkg *oceanus.Pkg) (interface{}, error)

RPC调用

func (*Process) Local

func (proc *Process) Local() abstract.Mesh

func (*Process) Logger

func (proc *Process) Logger() logis.Logger

func (*Process) NewAcceptor

func (proc *Process) NewAcceptor(addr string) network.Acceptor

func (*Process) NewConnector

func (proc *Process) NewConnector(addr string) network.Connector

func (*Process) Router

func (proc *Process) Router() abstract.Router

func (*Process) Run

func (proc *Process) Run()

func (*Process) Send

func (proc *Process) Send(pkg *oceanus.Pkg) error

发送邮件

func (*Process) Sends

func (proc *Process) Sends(pkg *oceanus.Pkg) error

发送一组邮件

func (*Process) Stop

func (proc *Process) Stop()

type Remotes

type Remotes = map[MeshID]*remote.Mesh

type Router

type Router = abstract.Router

type RpcID

type RpcID = proto.RpcID