Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Configures the STOMP delivery to deliver notifications directly to
// the configured Destination.
//
// If true "Callback" is ignored.
// If false a notifier.Callback is delivered to the queue and clients
// utilize the pagination API to retrieve.
Direct bool `yaml:"direct"`
// Specifies the number of notifications delivered in single STOMP message
// when Direct is true.
//
// Ignored if Direct is not true
// If 0 or 1 is provided no rollup occurs and each notification is delivered
// separately.
Rollup int `yaml:"rollup"`
// The callback url where notifications are retrieved.
Callback string `yaml:"callback"`
// the destination messages will be delivered to
Destination string `yaml:"destination"`
// a list of URIs to send messages to.
// a linear search of this list is always performed.
URIs []string `yaml:"uris"`
// optional tls portion of config
TLS *TLS `yaml:"tls"`
// optional user login portion of config
Login *Login `yaml:"user"`
// contains filtered or unexported fields
}
type Deliverer ¶
type Deliverer struct {
// contains filtered or unexported fields
}
Deliverer is a STOMP deliverer which publishes a notifier.Callback to the the broker.
type DirectDeliverer ¶
type DirectDeliverer struct {
// contains filtered or unexported fields
}
Deliverer is a STOMP deliverer which publishes a notifier.Callback to the the broker.
func NewDirectDeliverer ¶
func NewDirectDeliverer(conf Config) (*DirectDeliverer, error)
func (*DirectDeliverer) Name ¶
func (d *DirectDeliverer) Name() string
func (*DirectDeliverer) Notifications ¶
func (d *DirectDeliverer) Notifications(ctx context.Context, n []notifier.Notification) error
Notifications will copy the provided notifications into a buffer for STOMP delivery.
Click to show internal directories.
Click to hide internal directories.