Documentation
¶
Index ¶
- type MQTTClient
- func (c *MQTTClient) Connect() error
- func (c *MQTTClient) Disconnect()
- func (c *MQTTClient) ErrorInformation() *helpers.DriverError
- func (c *MQTTClient) IdentityInformation() helpers.TransportIdentity
- func (c *MQTTClient) IsConnected() bool
- func (c *MQTTClient) Registration(msg *arc.Registration) error
- func (c *MQTTClient) Reply(msg *arc.Reply) error
- func (c *MQTTClient) Request(msg *arc.Request) error
- func (c *MQTTClient) Subscribe(identity string) (<-chan *arc.Request, func())
- func (c *MQTTClient) SubscribeJob(requestId string) (<-chan *arc.Reply, func())
- func (c *MQTTClient) SubscribeRegistrations() (<-chan *arc.Registration, func())
- func (c *MQTTClient) SubscribeReplies() (<-chan *arc.Reply, func())
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQTTClient ¶
type MQTTClient struct {
// contains filtered or unexported fields
}
func New ¶
func New(config arc_config.Config, isServer bool) (*MQTTClient, error)
func (*MQTTClient) Connect ¶
func (c *MQTTClient) Connect() error
func (*MQTTClient) Disconnect ¶
func (c *MQTTClient) Disconnect()
func (*MQTTClient) ErrorInformation ¶
func (c *MQTTClient) ErrorInformation() *helpers.DriverError
func (*MQTTClient) IdentityInformation ¶
func (c *MQTTClient) IdentityInformation() helpers.TransportIdentity
func (*MQTTClient) IsConnected ¶
func (c *MQTTClient) IsConnected() bool
func (*MQTTClient) Registration ¶
func (c *MQTTClient) Registration(msg *arc.Registration) error
func (*MQTTClient) Subscribe ¶
func (c *MQTTClient) Subscribe(identity string) (<-chan *arc.Request, func())
func (*MQTTClient) SubscribeJob ¶
func (c *MQTTClient) SubscribeJob(requestId string) (<-chan *arc.Reply, func())
func (*MQTTClient) SubscribeRegistrations ¶
func (c *MQTTClient) SubscribeRegistrations() (<-chan *arc.Registration, func())
func (*MQTTClient) SubscribeReplies ¶
func (c *MQTTClient) SubscribeReplies() (<-chan *arc.Reply, func())
Source Files
Click to show internal directories.
Click to hide internal directories.