sink

README

sink

Contains interfaces and methods for sinking data to external services. As a general rule, sinks should support all formats of data if possible.

Each sink must use a select statement to read data from its channel and check if context was cancelled to prevent goroutine leaks (learn more about goroutine leaks here).

Information for each sink is available in the GoDoc.

Documentation

Index

• type Sink
  • func New(cfg config.Config) (Sink, error)

Types

type Sink

type Sink interface {
	Send(context.Context, *config.Channel) error
}

func New

func New(cfg config.Config) (Sink, error)

New returns a configured Sink from a sink configuration.