core

Documentation

Index

• Constants
• func NewLogAdapter(client logger.LoggingClient, fields watermill.LogFields) watermill.LoggerAdapter
• func NewWatermillClient(ctx context.Context, pub message.Publisher, sub message.Subscriber, ...) (messaging.MessageClient, error)
• func NewWatermillTrigger(publisher message.Publisher, subscriber message.Subscriber, format WireFormat, ...) (interfaces.Trigger, error)
• type EdgeXWireFormat
• type RawInputWireFormat
• type RawOutputWireFormat
• type RawWireFormat
• type WatermillClientOptions
• type WatermillConfig
• type WatermillConfigWrapper
  • func (w *WatermillConfigWrapper) UpdateFromRaw(rawConfig interface{}) bool
• type WatermillMarshaler
• type WatermillSender
  • func NewWatermillSender(pub message.Publisher, proceed bool, config *WatermillConfig) (WatermillSender, error)
• type WatermillUnmarshaler
• type WireFormat

Constants

const (
	AES256SHA512 = "aes256-sha512"
	AES256SHA384 = "aes256-sha384"
	AES192SHA384 = "aes192-sha384"
	AES128SHA256 = "es128-sha256"
)

const (
	EdgeXContentType = "edgex_content_type"
	EdgeXChecksum    = "edgex_checksum"
)

Functions

func NewLogAdapter

func NewLogAdapter(client logger.LoggingClient, fields watermill.LogFields) watermill.LoggerAdapter

func NewWatermillClient

func NewWatermillClient(ctx context.Context, pub message.Publisher, sub message.Subscriber, format WireFormat, watermillConfig *WatermillConfig) (messaging.MessageClient, error)

func NewWatermillTrigger

func NewWatermillTrigger(publisher message.Publisher, subscriber message.Subscriber, format WireFormat, watermillConfig *WatermillConfigWrapper, edgeXConfig interfaces.TriggerConfig) (interfaces.Trigger, error)

Types

type EdgeXWireFormat

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

type RawInputWireFormat

type RawInputWireFormat struct{}

type RawOutputWireFormat

type RawOutputWireFormat struct{}

type RawWireFormat

type RawWireFormat struct{}

type WatermillClientOptions

type WatermillClientOptions struct {
	Marshaler   WatermillMarshaler
	Unmarshaler WatermillUnmarshaler
}

type WatermillConfig

type WatermillConfig struct {
	Type                string
	BrokerUrl           string
	ClientId            string
	SubscribeTopics     string
	PublishTopic        string
	WireFormat          string
	ConsumerGroup       string
	Optional            map[string]string
	EncryptionAlgorithm string
	EncryptionKey       string
}

type WatermillConfigWrapper

type WatermillConfigWrapper struct {
	WatermillTrigger WatermillConfig
}

func (*WatermillConfigWrapper) UpdateFromRaw

func (w *WatermillConfigWrapper) UpdateFromRaw(rawConfig interface{}) bool

type WatermillMarshaler

type WatermillMarshaler func(envelope types.MessageEnvelope, encrypt binaryModifier) (*message.Message, error)

type WatermillSender

type WatermillSender interface {
	Send(interfaces.AppFunctionContext, interface{}) (bool, interface{})
}

func NewWatermillSender

func NewWatermillSender(pub message.Publisher, proceed bool, config *WatermillConfig) (WatermillSender, error)

type WatermillUnmarshaler

type WatermillUnmarshaler func(msg *message.Message, decrypt binaryModifier) (types.MessageEnvelope, error)

type WireFormat

type WireFormat interface {
	// contains filtered or unexported methods
}