noop

Documentation

Index

• type Sink
  • func NewSink[K, V any]() *Sink[K, V]
  • func (n *Sink[K, V]) Write(messages ...msg.Message[K, V]) error
• type Source
  • func NewSource[K, V any](buf []msg.Message[K, V]) *Source[K, V]
  • func (n *Source[K, V]) Close()
  • func (n *Source[K, V]) Commit(messages ...msg.Message[K, V]) error
  • func (n *Source[K, V]) Messages() chan msg.Message[K, V]

Types

type Sink

type Sink[K, V any] struct {
	// contains filtered or unexported fields
}

Sink is a noop sink.

func NewSink

func NewSink[K, V any]() *Sink[K, V]

NewSink is a noop sink constructor.

func (*Sink[K, V]) Write

func (n *Sink[K, V]) Write(messages ...msg.Message[K, V]) error

Write is a noop sink writer.

type Source

type Source[K, V any] struct {
	// contains filtered or unexported fields
}

Source ...

func NewSource

func NewSource[K, V any](buf []msg.Message[K, V]) *Source[K, V]

NewSource ...

func (*Source[K, V]) Close

func (n *Source[K, V]) Close()

Close ...

func (*Source[K, V]) Commit

func (n *Source[K, V]) Commit(messages ...msg.Message[K, V]) error

Commit ...

func (*Source[K, V]) Messages

func (n *Source[K, V]) Messages() chan msg.Message[K, V]

Message ...