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 ¶
View Source
const ( EdgeXContentType = "edgex_content_type" EdgeXChecksum = "edgex_checksum" )
Variables ¶
This section is empty.
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)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.