blackhole

Documentation

Index

• type Blackhole
  • func NewBlackhole(vertex *dfv1.Vertex, fromBuffer isb.BufferReader, fetchWatermark fetch.Fetcher, ...) (*Blackhole, error)
  • func (b *Blackhole) Close() error
  • func (b *Blackhole) ForceStop()
  • func (b *Blackhole) GetName() string
  • func (b *Blackhole) GetPartitionIdx() int32
  • func (b *Blackhole) IsFull() bool
  • func (b *Blackhole) Start() <-chan struct{}
  • func (b *Blackhole) Stop()
  • func (b *Blackhole) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)
• type Option
  • func WithLogger(log *zap.SugaredLogger) Option

Types

type Blackhole

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

Blackhole is a sink to emulate /dev/null

func NewBlackhole

func NewBlackhole(vertex *dfv1.Vertex,
	fromBuffer isb.BufferReader,
	fetchWatermark fetch.Fetcher,
	publishWatermark map[string]publish.Publisher,
	whereToDecider forward.GoWhere,
	opts ...Option) (*Blackhole, error)

NewBlackhole returns Blackhole type.

func (*Blackhole) Close

func (b *Blackhole) Close() error

func (*Blackhole) ForceStop

func (b *Blackhole) ForceStop()

ForceStop stops sinking

func (*Blackhole) GetName

func (b *Blackhole) GetName() string

GetName returns the name.

func (*Blackhole) GetPartitionIdx

func (b *Blackhole) GetPartitionIdx() int32

GetPartitionIdx returns the partition index. for sink it is always 0.

func (*Blackhole) IsFull

func (b *Blackhole) IsFull() bool

IsFull returns whether sink is full, which is never true.

func (*Blackhole) Start

func (b *Blackhole) Start() <-chan struct{}

Start starts the sink.

func (*Blackhole) Stop

func (b *Blackhole) Stop()

Stop stops sinking

func (*Blackhole) Write

func (b *Blackhole) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)

Write writes to the blackhole.

type Option

type Option func(*Blackhole) error

func WithLogger

func WithLogger(log *zap.SugaredLogger) Option