edgex

package
v2.0.0-alpha.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 16, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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) 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) 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"`
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL