multi

Documentation

Index

• type SubWriter
• type Writer
  • func New(writers ...SubWriter) *Writer
  • func (w *Writer) Run(ctx context.Context) (async.Task, error)
  • func (w *Writer) Stream(row block.Row) error
  • func (w *Writer) Write(key key.Key, val []byte) error

Types

type SubWriter

type SubWriter interface {
	Write(key.Key, []byte) error
}

SubWriter represents the sub-writer

type Writer

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

Writer represents a writer that writes into multiple sub-writers.

func New

func New(writers ...SubWriter) *Writer

New ...

func (*Writer) Run

func (w *Writer) Run(ctx context.Context) (async.Task, error)

Run launches the asynchronous infinite loop for streamers to start streaming data

func (*Writer) Stream

func (w *Writer) Stream(row block.Row) error

Stream streams the data to the sink

func (*Writer) Write

func (w *Writer) Write(key key.Key, val []byte) error

Write writes the data to the sink.