output

Documentation

Index

• func Available() []string
• func Register(protocol string, factory Factory)
• type Factory
• type Options
• type Output
  • func Initialize(opts *Options, logger *zap.SugaredLogger, ctx context.Context) (Output, error)
  • func New(opts *Options) (Output, error)
• type WebhookOptions

Functions

func Available

func Available() []string

func Register

func Register(protocol string, factory Factory)

Types

type Factory

type Factory func(options *Options) (Output, error)

type Options

type Options struct {
	Addr        string        // Destination address (host:port).
	Delay       time.Duration // Delay start after start signal.
	Protocol    string        // Protocol (udp/tcp/tls).
	Retries     int           // Number of connection retries for tcp based protocols.
	StartSignal string        // OS signal to wait on before starting.

	WebhookOptions
}

type Output

type Output interface {
	DialContext(ctx context.Context) error
	io.WriteCloser
}

func Initialize

func Initialize(opts *Options, logger *zap.SugaredLogger, ctx context.Context) (Output, error)

func New

func New(opts *Options) (Output, error)

type WebhookOptions

type WebhookOptions struct {
	ContentType string   // Content-Type header.
	Headers     []string // Headers in Key=Value format.
	Username    string   // Basic auth username.
	Password    string   // Basic auth password.
}