single

Documentation

Index

• type Mode
  • func New(client mode.ProtocolClient, maxAttempts int, ...) (*Mode, error)
  • func (s *Mode) Close() error
  • func (s *Mode) PublishEvent(signaler op.Signaler, opts outputs.Options, event common.MapStr) error
  • func (s *Mode) PublishEvents(signaler op.Signaler, opts outputs.Options, events []common.MapStr) error

Types

type Mode

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

Mode sends all Output on one single connection. If connection is not available, the output plugin blocks until the connection is either available again or the connection mode is closed by Close.

func New

func New(
	client mode.ProtocolClient,
	maxAttempts int,
	waitRetry, timeout, maxWaitRetry time.Duration,
) (*Mode, error)

New creates a new single connection mode using exactly one ProtocolClient connection.

func (*Mode) Close

func (s *Mode) Close() error

Close closes the underlying connection.

func (*Mode) PublishEvent

func (s *Mode) PublishEvent(
	signaler op.Signaler,
	opts outputs.Options,
	event common.MapStr,
) error

PublishEvent forwards a single event. On failure PublishEvent tries to reconnect.

func (*Mode) PublishEvents

func (s *Mode) PublishEvents(
	signaler op.Signaler,
	opts outputs.Options,
	events []common.MapStr,
) error

PublishEvents tries to publish the events with retries if connection becomes unavailable. On failure PublishEvents tries to reconnect.