messages

type EventDefinition struct {
	Providers         []*ProviderDefinition `yaml:"messageProviders,omitempty"`
	EventDestinations []*EventNode          `yaml:"eventDestinations,omitempty"`
}

type EventNode struct {
	Name        string `yaml:"name"`
	Topic       string `yaml:"topic"`
	ProviderRef string `yaml:"providerRef"`
}

type Provider interface {
	// Send a new message to an eventDestination.
	// The first parameter is message body. The second parameter is optional header or context
	Send(*EventNode, []byte, interface{}) error
	// Subscribe to eventDefinition from an eventSource.
	Subscribe(*EventNode) error
	// Receive a message from an eventSource. The timeout can be configured by setting the timeout (in seconds) on the messageProvider.
	Receive(*EventNode) ([]byte, error)
	// Listen for eventDefinition on an eventSource and calls the specified ReceiverFunc on the event payload.
	ListenAndServe(*EventNode, ReceiverFunc)
}

type ProviderDefinition struct {
	Name          string        `yaml:"name"`
	ProviderType  string        `yaml:"providerType"`
	URL           string        `yaml:"url"`
	Timeout       time.Duration `yaml:"timeout"`
	SkipTLSVerify bool          `yaml:"skipTLSVerify,omitempty"`
}

type ReceiverFunc func([]byte)

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