transport

Documentation

Index

• func NewProcessorMultiplexer(conf interface{}) (core.IMultiplexer, error)
• func NewTransportMultiplexer(conf interface{}) (core.IMultiplexer, error)
• type ProcessorMultiplexer
  • func (m *ProcessorMultiplexer) AddNode(nodeName string, node interface{}) bool
  • func (m *ProcessorMultiplexer) GetChannel(nodeName, serviceID string) (interface{}, bool)
  • func (m *ProcessorMultiplexer) GetNode(nodeName string) (interface{}, bool)
  • func (m *ProcessorMultiplexer) PreStart()
  • func (m *ProcessorMultiplexer) PreStartChannel(nodeName, serviceID string) bool
  • func (m *ProcessorMultiplexer) Send(nodeName, serviceID string, obj interface{}) error
  • func (m *ProcessorMultiplexer) SendAndRecv(nodeName, serviceID string, obj interface{}) error
  • func (m *ProcessorMultiplexer) SendAndRecvWithRetry(nodeName, serviceID string, obj interface{}) error
  • func (m *ProcessorMultiplexer) SendNode(nodeName, serviceID string, obj interface{}) error
  • func (m *ProcessorMultiplexer) SendRecvNode(nodeName, serviceID string, obj interface{}) (interface{}, error)
  • func (m *ProcessorMultiplexer) SendWithRetry(nodeName, serviceID string, obj interface{}) error
  • func (m *ProcessorMultiplexer) Start()
• type TransportMultiplexer
  • func (m *TransportMultiplexer) AddNode(nodeName string, node interface{}) bool
  • func (m *TransportMultiplexer) GetChannel(nodeName, serviceID string) (interface{}, bool)
  • func (m *TransportMultiplexer) GetNode(nodeName string) (interface{}, bool)
  • func (m *TransportMultiplexer) PreStart()
  • func (m *TransportMultiplexer) PreStartChannel(nodeName, serviceID string) bool
  • func (m *TransportMultiplexer) Send(nodeName, serviceID string, obj interface{}) error
  • func (m *TransportMultiplexer) SendAndRecv(nodeName, serviceID string, obj interface{}) error
  • func (m *TransportMultiplexer) SendAndRecvWithRetry(nodeName, serviceID string, obj interface{}) error
  • func (m *TransportMultiplexer) SendNode(nodeName, serviceID string, obj interface{}) error
  • func (m *TransportMultiplexer) SendRecvNode(nodeName, serviceID string, obj interface{}) (interface{}, error)
  • func (m *TransportMultiplexer) SendWithRetry(nodeName, serviceID string, obj interface{}) error
  • func (m *TransportMultiplexer) Start()

Functions

func NewProcessorMultiplexer

func NewProcessorMultiplexer(conf interface{}) (core.IMultiplexer, error)

func NewTransportMultiplexer

func NewTransportMultiplexer(conf interface{}) (core.IMultiplexer, error)

Types

type ProcessorMultiplexer

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

func (*ProcessorMultiplexer) AddNode

func (m *ProcessorMultiplexer) AddNode(nodeName string, node interface{}) bool

func (*ProcessorMultiplexer) GetChannel

func (m *ProcessorMultiplexer) GetChannel(nodeName, serviceID string) (interface{}, bool)

func (*ProcessorMultiplexer) GetNode

func (m *ProcessorMultiplexer) GetNode(nodeName string) (interface{}, bool)

func (*ProcessorMultiplexer) PreStart

func (m *ProcessorMultiplexer) PreStart()

func (*ProcessorMultiplexer) PreStartChannel

func (m *ProcessorMultiplexer) PreStartChannel(nodeName, serviceID string) bool

func (*ProcessorMultiplexer) Send

func (m *ProcessorMultiplexer) Send(nodeName, serviceID string, obj interface{}) error

func (*ProcessorMultiplexer) SendAndRecv

func (m *ProcessorMultiplexer) SendAndRecv(nodeName, serviceID string, obj interface{}) error

func (*ProcessorMultiplexer) SendAndRecvWithRetry

func (m *ProcessorMultiplexer) SendAndRecvWithRetry(nodeName, serviceID string, obj interface{}) error

func (*ProcessorMultiplexer) SendNode

func (m *ProcessorMultiplexer) SendNode(nodeName, serviceID string, obj interface{}) error

func (*ProcessorMultiplexer) SendRecvNode

func (m *ProcessorMultiplexer) SendRecvNode(nodeName, serviceID string, obj interface{}) (interface{}, error)

func (*ProcessorMultiplexer) SendWithRetry

func (m *ProcessorMultiplexer) SendWithRetry(nodeName, serviceID string, obj interface{}) error

func (*ProcessorMultiplexer) Start

func (m *ProcessorMultiplexer) Start()

type TransportMultiplexer

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

func (*TransportMultiplexer) AddNode

func (m *TransportMultiplexer) AddNode(nodeName string, node interface{}) bool

func (*TransportMultiplexer) GetChannel

func (m *TransportMultiplexer) GetChannel(nodeName, serviceID string) (interface{}, bool)

func (*TransportMultiplexer) GetNode

func (m *TransportMultiplexer) GetNode(nodeName string) (interface{}, bool)

func (*TransportMultiplexer) PreStart

func (m *TransportMultiplexer) PreStart()

func (*TransportMultiplexer) PreStartChannel

func (m *TransportMultiplexer) PreStartChannel(nodeName, serviceID string) bool

func (*TransportMultiplexer) Send

func (m *TransportMultiplexer) Send(nodeName, serviceID string, obj interface{}) error

func (*TransportMultiplexer) SendAndRecv

func (m *TransportMultiplexer) SendAndRecv(nodeName, serviceID string, obj interface{}) error

func (*TransportMultiplexer) SendAndRecvWithRetry

func (m *TransportMultiplexer) SendAndRecvWithRetry(nodeName, serviceID string, obj interface{}) error

func (*TransportMultiplexer) SendNode

func (m *TransportMultiplexer) SendNode(nodeName, serviceID string, obj interface{}) error

func (*TransportMultiplexer) SendRecvNode

func (m *TransportMultiplexer) SendRecvNode(nodeName, serviceID string, obj interface{}) (interface{}, error)

func (*TransportMultiplexer) SendWithRetry

func (m *TransportMultiplexer) SendWithRetry(nodeName, serviceID string, obj interface{}) error

func (*TransportMultiplexer) Start

func (m *TransportMultiplexer) Start()