edgex

Documentation

Index

• Constants
• func GetSink() api.Sink
• func GetSource() api.Source
• type EdgexMsgBusSink
  • func (ems *EdgexMsgBusSink) Close(ctx api.StreamContext) error
  • func (ems *EdgexMsgBusSink) Collect(ctx api.StreamContext, data api.MessageTuple) error
  • func (ems *EdgexMsgBusSink) CollectList(ctx api.StreamContext, data api.MessageTupleList) error
  • func (ems *EdgexMsgBusSink) Connect(ctx api.StreamContext, sc api.StatusChangeHandler) error
  • func (ems *EdgexMsgBusSink) Provision(ctx api.StreamContext, ps map[string]any) error
• type SinkConf
• type Source
  • func (es *Source) Close(ctx api.StreamContext) error
  • func (es *Source) Connect(ctx api.StreamContext, sc api.StatusChangeHandler) error
  • func (es *Source) Provision(_ api.StreamContext, props map[string]any) error
  • func (es *Source) SubId(props map[string]any) string
  • func (es *Source) Subscribe(ctx api.StreamContext, ingest api.TupleIngest, ingestErr api.ErrorIngest) error
• type SourceConf
• type SubConf

Constants

const (
	MessageTypeEvent   messageType = "event"
	MessageTypeRequest messageType = "request"
)

Functions

func GetSink

func GetSink() api.Sink

func GetSource

func GetSource() api.Source

Types

type EdgexMsgBusSink

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

func (*EdgexMsgBusSink) Close

func (ems *EdgexMsgBusSink) Close(ctx api.StreamContext) error

func (*EdgexMsgBusSink) Collect

func (ems *EdgexMsgBusSink) Collect(ctx api.StreamContext, data api.MessageTuple) error

func (*EdgexMsgBusSink) CollectList

func (ems *EdgexMsgBusSink) CollectList(ctx api.StreamContext, data api.MessageTupleList) error

func (*EdgexMsgBusSink) Connect

func (ems *EdgexMsgBusSink) Connect(ctx api.StreamContext, sc api.StatusChangeHandler) error

func (*EdgexMsgBusSink) Provision

func (ems *EdgexMsgBusSink) Provision(ctx api.StreamContext, ps map[string]any) error

type SinkConf

type SinkConf struct {
	Topic        string      `json:"topic"`
	TopicPrefix  string      `json:"topicPrefix"`
	MessageType  messageType `json:"messageType"`
	ContentType  string      `json:"contentType"`
	DeviceName   string      `json:"deviceName"`
	ProfileName  string      `json:"profileName"`
	SourceName   string      `json:"sourceName"`
	Metadata     string      `json:"metadata"`
	DataTemplate string      `json:"dataTemplate"`
	Fields       []string    `json:"fields"`
	DataField    string      `json:"dataField"`
}

type Source

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

func (*Source) Close

func (es *Source) Close(ctx api.StreamContext) error

func (*Source) Connect

func (es *Source) Connect(ctx api.StreamContext, sc api.StatusChangeHandler) error

func (*Source) Provision

func (es *Source) Provision(_ api.StreamContext, props map[string]any) error

func (*Source) SubId

func (es *Source) SubId(props map[string]any) string

func (*Source) Subscribe

func (es *Source) Subscribe(ctx api.StreamContext, ingest api.TupleIngest, ingestErr api.ErrorIngest) error

type SourceConf

type SourceConf struct {
	Topic       string      `json:"topic"`
	MessageType messageType `json:"messageType"`
	BufferLen   int         `json:"bufferLength"`
}

type SubConf

type SubConf struct {
	Topic string `json:"topic"`
}