edgex_watermill

README

edgex-watermill

Watermill pub-sub binding for edgexfoundry application functions

Documentation

Index

• Constants
• func NewWatermillClient(ctx context.Context, pub message.Publisher, sub message.Subscriber, ...) (messaging.MessageClient, error)
• func NewWatermillTrigger(publisher message.Publisher, subscriber message.Subscriber, ...) appsdk.Trigger
• type EdgeXMessageFormat
• type MessageFormat
• type RawInputMessageFormat
• type RawMessageFormat
• type RawOutputMessageFormat
• type WatermillClientOptions
• type WatermillMarshaler
• type WatermillUnmarshaler

Constants

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

Functions

func NewWatermillClient

func NewWatermillClient(ctx context.Context, pub message.Publisher, sub message.Subscriber, format MessageFormat) (messaging.MessageClient, error)

func NewWatermillTrigger

func NewWatermillTrigger(publisher message.Publisher, subscriber message.Subscriber, format MessageFormat, ctx context.Context, contextFunc appsdk.TriggerContextBuilder, messageFunc appsdk.TriggerMessageProcessor) appsdk.Trigger

Types

type EdgeXMessageFormat

type EdgeXMessageFormat struct{}

type MessageFormat

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

type RawInputMessageFormat

type RawInputMessageFormat struct{}

type RawMessageFormat

type RawMessageFormat struct{}

type RawOutputMessageFormat

type RawOutputMessageFormat struct{}

type WatermillClientOptions

type WatermillClientOptions struct {
	Marshaler   WatermillMarshaler
	Unmarshaler WatermillUnmarshaler
}

type WatermillMarshaler

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

type WatermillUnmarshaler

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