The highest tagged major version is v6.

channel

package

v2.6.0 Latest Latest Go to latest Published: Jan 29, 2019 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Sink represents a channel sink.

func NewSink(ch chan *streams.Message, batch int) *Sink

NewSink creates a new channel Sink.

A batch size of 0 will never commit.

func (s *Sink) Close() error

Close closes the processor.

func (s *Sink) Process(msg *streams.Message) error

Process processes the stream Message.

func (s *Sink) WithPipe(pipe streams.Pipe)

WithPipe sets the pipe on the Processor.

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

Source represents a source that consumes messages from a channel.

func NewSource(ch chan *streams.Message) *Source

NewSource creates a new channel Source.

func (s *Source) Close() error

Close closes the Source.

func (s *Source) Commit(interface{}) error

Commit marks the consumed records as processed.

func (s *Source) Consume() (*streams.Message, error)

Consume gets the next record from the Source.