gatherer

Documentation

Index

• func NewGatherer(cfg *api.GathererConfig) api.Gatherer
• type FetcherGatherer
  • func (f *FetcherGatherer) Ack(lastOffset event.Offset)
  • func (f *FetcherGatherer) Boot(ctx context.Context)
  • func (f *FetcherGatherer) OutputDataChannel() <-chan *queue.SequenceEvent
  • func (f *FetcherGatherer) Prepare() error
  • func (f *FetcherGatherer) SetProcessor(m module.Module) error
  • func (f *FetcherGatherer) Shutdown()
• type ReceiverGatherer
  • func (r *ReceiverGatherer) Ack(lastOffset event.Offset)
  • func (r *ReceiverGatherer) Boot(ctx context.Context)
  • func (r *ReceiverGatherer) OutputDataChannel() <-chan *queue.SequenceEvent
  • func (r *ReceiverGatherer) Prepare() error
  • func (r *ReceiverGatherer) SetProcessor(m module.Module) error
  • func (r *ReceiverGatherer) Shutdown()
  • func (r *ReceiverGatherer) SyncInvoke(d *v1.SniffData) (*v1.SniffData, error)

Functions

func NewGatherer

func NewGatherer(cfg *api.GathererConfig) api.Gatherer

NewGatherer returns a gatherer module

Types

type FetcherGatherer

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

func (*FetcherGatherer) Ack

func (f *FetcherGatherer) Ack(lastOffset event.Offset)

func (*FetcherGatherer) Boot

func (f *FetcherGatherer) Boot(ctx context.Context)

func (*FetcherGatherer) OutputDataChannel

func (f *FetcherGatherer) OutputDataChannel() <-chan *queue.SequenceEvent

func (*FetcherGatherer) Prepare

func (f *FetcherGatherer) Prepare() error

func (*FetcherGatherer) SetProcessor

func (f *FetcherGatherer) SetProcessor(m module.Module) error

func (*FetcherGatherer) Shutdown

func (f *FetcherGatherer) Shutdown()

type ReceiverGatherer

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

func (*ReceiverGatherer) Ack

func (r *ReceiverGatherer) Ack(lastOffset event.Offset)

func (*ReceiverGatherer) Boot

func (r *ReceiverGatherer) Boot(ctx context.Context)

func (*ReceiverGatherer) OutputDataChannel

func (r *ReceiverGatherer) OutputDataChannel() <-chan *queue.SequenceEvent

func (*ReceiverGatherer) Prepare

func (r *ReceiverGatherer) Prepare() error

func (*ReceiverGatherer) SetProcessor

func (r *ReceiverGatherer) SetProcessor(m module.Module) error

func (*ReceiverGatherer) Shutdown

func (r *ReceiverGatherer) Shutdown()

func (*ReceiverGatherer) SyncInvoke

func (r *ReceiverGatherer) SyncInvoke(d *v1.SniffData) (*v1.SniffData, error)