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) 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) 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 ¶
View Source
const ( MessageTypeEvent messageType = "event" MessageTypeRequest messageType = "request" )
Variables ¶
This section is empty.
Functions ¶
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) 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) Subscribe ¶
func (es *Source) Subscribe(ctx api.StreamContext, ingest api.TupleIngest, ingestErr api.ErrorIngest) error
type SourceConf ¶
Click to show internal directories.
Click to hide internal directories.