udp

Documentation

Index

• Constants
• type UdpGateway
  • func (o *UdpGateway) Broadcast(message *qtiny.Message) error
  • func (o *UdpGateway) GetMeta() map[string]interface{}
  • func (o *UdpGateway) GetType() string
  • func (o *UdpGateway) Init(config map[string]interface{}) error
  • func (o *UdpGateway) Poll(limit int) (chan *qtiny.Message, error)
  • func (o *UdpGateway) Post(message *qtiny.Message) error
  • func (o *UdpGateway) Start(config map[string]interface{}) error
  • func (o *UdpGateway) Stop(config map[string]interface{}) error
  • func (o *UdpGateway) String() string

Constants

const PathConnection = "/qconn"

const PathNodeQueue = "/qnode"

Types

type UdpGateway

type UdpGateway struct {
	memory.MemGateway
	// contains filtered or unexported fields
}

func (*UdpGateway) Broadcast

func (o *UdpGateway) Broadcast(message *qtiny.Message) error

func (*UdpGateway) GetMeta

func (o *UdpGateway) GetMeta() map[string]interface{}

func (*UdpGateway) GetType

func (o *UdpGateway) GetType() string

func (*UdpGateway) Init

func (o *UdpGateway) Init(config map[string]interface{}) error

func (*UdpGateway) Poll

func (o *UdpGateway) Poll(limit int) (chan *qtiny.Message, error)

func (*UdpGateway) Post

func (o *UdpGateway) Post(message *qtiny.Message) error

func (*UdpGateway) Start

func (o *UdpGateway) Start(config map[string]interface{}) error

func (*UdpGateway) Stop

func (o *UdpGateway) Stop(config map[string]interface{}) error

func (*UdpGateway) String

func (o *UdpGateway) String() string