sink

Documentation

Index

• type Context
• type Factory
• type Manager
• type Sink
• type SinkFunc
  • func (sf SinkFunc) Emit(context Context, timestamp time.Time, topicName string, ...) error
  • func (sf SinkFunc) Start() error
  • func (sf SinkFunc) Stop() error

Types

type Context

type Context interface {
	SetTransientAttribute(key string, value string)
	TransientAttribute(key string) (value string, present bool)
	SetAttribute(key string, value string)
	Attribute(key string) (value string, present bool)
}

type Factory

type Factory = func(config *config.Config) (Sink, error)

type Manager

type Manager interface {
	Start() error
	Stop() error
	Emit(
		timestamp time.Time, topicName string, key, envelope schema.Struct,
	) error
}

type Sink

type Sink interface {
	Start() error
	Stop() error
	Emit(
		context Context, timestamp time.Time, topicName string, key, envelope schema.Struct,
	) error
}

type SinkFunc

type SinkFunc func(context Context, timestamp time.Time, topicName string, key, envelope schema.Struct) error

func (SinkFunc) Emit

func (sf SinkFunc) Emit(
	context Context, timestamp time.Time, topicName string, key, envelope schema.Struct,
) error

func (SinkFunc) Start

func (sf SinkFunc) Start() error

func (SinkFunc) Stop

func (sf SinkFunc) Stop() error