core

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

type RawInputWireFormat struct{}

type RawOutputWireFormat struct{}

type RawWireFormat struct{}

type WatermillClientOptions struct {
	Marshaler   WatermillMarshaler
	Unmarshaler WatermillUnmarshaler
}

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 struct {
	WatermillTrigger WatermillConfig
}

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

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

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

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