mqtt

Documentation

Index

• func GetSink() api.Sink
• func GetSource() api.Source
• type AdConf
• type Conf
• type Sink
  • func (ms *Sink) Close(ctx api.StreamContext) error
  • func (ms *Sink) Collect(ctx api.StreamContext, item api.RawTuple) error
  • func (ms *Sink) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error
  • func (ms *Sink) Ping(ctx api.StreamContext, props map[string]any) error
  • func (ms *Sink) Provision(_ api.StreamContext, ps map[string]any) error
• type SourceConnector
  • func (ms *SourceConnector) Close(ctx api.StreamContext) error
  • func (ms *SourceConnector) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error
  • func (ms *SourceConnector) Ping(ctx api.StreamContext, props map[string]interface{}) error
  • func (ms *SourceConnector) Provision(ctx api.StreamContext, props map[string]any) error
  • func (ms *SourceConnector) SetEofIngest(eof api.EOFIngest)
  • func (ms *SourceConnector) Subscribe(ctx api.StreamContext, ingest api.BytesIngest, _ api.ErrorIngest) error

Functions

func GetSink

func GetSink() api.Sink

func GetSource

func GetSource() api.Source

Types

type AdConf

type AdConf struct {
	Tpc      string `json:"topic"`
	Qos      byte   `json:"qos"`
	Retained bool   `json:"retained"`
	SelId    string `json:"connectionSelector"`
}

AdConf is the advanced configuration for the mqtt sink

type Conf

type Conf struct {
	Topic      string `json:"datasource"`
	Qos        int    `json:"qos"`
	SelId      string `json:"connectionSelector"`
	EofMessage string `json:"eofMessage"`
}

type Sink

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

func (*Sink) Close

func (ms *Sink) Close(ctx api.StreamContext) error

func (*Sink) Collect

func (ms *Sink) Collect(ctx api.StreamContext, item api.RawTuple) error

func (*Sink) Connect

func (ms *Sink) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error

func (*Sink) Ping

func (ms *Sink) Ping(ctx api.StreamContext, props map[string]any) error

func (*Sink) Provision

func (ms *Sink) Provision(_ api.StreamContext, ps map[string]any) error

type SourceConnector

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

SourceConnector is the connector for mqtt source When sharing the same connection, each topic will have one single sourceConnector as the shared source node

func (*SourceConnector) Close

func (ms *SourceConnector) Close(ctx api.StreamContext) error

func (*SourceConnector) Connect

func (ms *SourceConnector) Connect(ctx api.StreamContext, sch api.StatusChangeHandler) error

func (*SourceConnector) Ping

func (ms *SourceConnector) Ping(ctx api.StreamContext, props map[string]interface{}) error

func (*SourceConnector) Provision

func (ms *SourceConnector) Provision(ctx api.StreamContext, props map[string]any) error

func (*SourceConnector) SetEofIngest

func (ms *SourceConnector) SetEofIngest(eof api.EOFIngest)

func (*SourceConnector) Subscribe

func (ms *SourceConnector) Subscribe(ctx api.StreamContext, ingest api.BytesIngest, _ api.ErrorIngest) error

Subscribe is a one time only operation for source. It connects to the mqtt broker and subscribe to the topic Run open before subscribe