writer

Documentation

Index

• func Register(name string, factory WriterFactory)
• type Writer
  • func New(typ, schema, topic, sourceID string, cfg WriterConfig) (Writer, error)
• type WriterConfig
• type WriterFactory

Functions

func Register

func Register(name string, factory WriterFactory)

Types

type Writer

type Writer interface {
	Write(data string) error
	Close() error
}

func New

func New(typ, schema, topic, sourceID string, cfg WriterConfig) (Writer, error)

type WriterConfig

type WriterConfig interface {
	IsMeteringWriter()
	Type() string
}

type WriterFactory

type WriterFactory func(schema, topic, sourceID string, cfg WriterConfig) (Writer, error)