edgex

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

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 struct {
	// contains filtered or unexported fields
}

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

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