mqtt

Documentation

Index

• type Cache
  • func NewCache() *Cache
  • func (c *Cache) Delete(uid types.UID) error
  • func (c *Cache) Get(gvk schema.GroupVersionKind, k client.ObjectKey) (*mqttv1.ResourceMessage, error)
  • func (c *Cache) Update(msg *mqttv1.ResourceMessage) error
• type Connection
  • func NewConnection(log logr.Logger, opts ConnectionOptions) *Connection
  • func (c *Connection) Publish(ctx context.Context, m *paho.Publish) error
  • func (c *Connection) Start(ctx context.Context) error
• type ConnectionOptions
• type Decoder
  • func NewDecoder(sink DecoderSink) *Decoder
  • func (d *Decoder) Decode(m *paho.Publish) error
• type DecoderSink
• type DecoderSinkList
  • func (l DecoderSinkList) Delete(uid types.UID) error
  • func (l DecoderSinkList) Update(msg *mqttv1.ResourceMessage) error
• type EventClient
  • func NewEventClient() *EventClient
• type EventHub
  • func NewEventHub() *EventHub
  • func (h *EventHub) Broadcast(e event.GenericEvent)
  • func (h *EventHub) Delete(uid types.UID) error
  • func (h *EventHub) Register(c *EventClient)
  • func (h *EventHub) Start(ctx context.Context) error
  • func (h *EventHub) Unregister(c *EventClient)
  • func (h *EventHub) Update(msg *mqttv1.ResourceMessage) error

Types

type Cache

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

func NewCache

func NewCache() *Cache

func (*Cache) Delete

func (c *Cache) Delete(uid types.UID) error

func (*Cache) Get

func (c *Cache) Get(gvk schema.GroupVersionKind, k client.ObjectKey) (*mqttv1.ResourceMessage, error)

func (*Cache) Update

func (c *Cache) Update(msg *mqttv1.ResourceMessage) error

type Connection

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

func NewConnection

func NewConnection(
	log logr.Logger, opts ConnectionOptions,
) *Connection

func (*Connection) Publish

func (c *Connection) Publish(ctx context.Context, m *paho.Publish) error

func (*Connection) Start

func (c *Connection) Start(ctx context.Context) error

type ConnectionOptions

type ConnectionOptions struct {
	BrokerURLs         []string
	Topic              string
	KeepAlive          time.Duration
	ClientID           string
	Username, Password string
	OnMessage          func(m *paho.Publish)
}

type Decoder

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

Decodes MQTT messages into unstructured.Unstructured.

func NewDecoder

func NewDecoder(sink DecoderSink) *Decoder

func (*Decoder) Decode

func (d *Decoder) Decode(m *paho.Publish) error

type DecoderSink

type DecoderSink interface {
	Update(msg *mqttv1.ResourceMessage) error
	Delete(uid types.UID) error
}

type DecoderSinkList

type DecoderSinkList []DecoderSink

func (DecoderSinkList) Delete

func (l DecoderSinkList) Delete(uid types.UID) error

func (DecoderSinkList) Update

func (l DecoderSinkList) Update(msg *mqttv1.ResourceMessage) error

type EventClient

type EventClient struct {
	// Buffered channel of outbound messages.
	Channel chan event.GenericEvent
}

func NewEventClient

func NewEventClient() *EventClient

type EventHub

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

func NewEventHub

func NewEventHub() *EventHub

func (*EventHub) Broadcast

func (h *EventHub) Broadcast(e event.GenericEvent)

func (*EventHub) Delete

func (h *EventHub) Delete(uid types.UID) error

Decoder Sink

func (*EventHub) Register

func (h *EventHub) Register(c *EventClient)

func (*EventHub) Start

func (h *EventHub) Start(ctx context.Context) error

func (*EventHub) Unregister

func (h *EventHub) Unregister(c *EventClient)

func (*EventHub) Update

func (h *EventHub) Update(msg *mqttv1.ResourceMessage) error