The highest tagged major version is v6.

cache

package

v0.5.4 Latest Latest Go to latest Published: Aug 3, 2018 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewSink(cache cache.Cache, expire time.Duration, batch int) *Sink

NewSink creates a new cache insert sink.

func (p *Sink) Close() error

Close closes the processor.

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

Process processes the stream record.

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

WithPipe sets the pipe on the Processor.