blackhole

Documentation

Index

• type Blackhole
  • func NewBlackhole(ctx context.Context, vertexInstance *dfv1.VertexInstance) (*Blackhole, error)
  • func (b *Blackhole) Close() error
  • func (b *Blackhole) GetName() string
  • func (b *Blackhole) GetPartitionIdx() int32
  • func (b *Blackhole) IsFull() bool
  • func (b *Blackhole) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)

Types

type Blackhole

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

Blackhole is a sink to emulate /dev/null

func NewBlackhole

func NewBlackhole(ctx context.Context, vertexInstance *dfv1.VertexInstance) (*Blackhole, error)

NewBlackhole returns a new Blackhole sink.

func (*Blackhole) Close

func (b *Blackhole) Close() error

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) Write

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

Write writes to the blackhole.