cache

Documentation

Index

• type Sink
  • func NewSink(cache cache.Cache, expire time.Duration, batch int) *Sink
  • func (p *Sink) Close() error
  • func (p *Sink) Process(msg *streams.Message) error
  • func (p *Sink) WithPipe(pipe streams.Pipe)

Types

type Sink

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

Sink represents a Cache streams sink.

func NewSink

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

NewSink creates a new cache insert sink.

func (*Sink) Close

func (p *Sink) Close() error

Close closes the processor.

func (*Sink) Process

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

Process processes the stream record.

func (*Sink) WithPipe

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

WithPipe sets the pipe on the Processor.