helper

Documentation

Index

• func NewTwoStageInputPlugin(full, incremental core.Input) (core.Input, error)
• type TwoStageInputPlugin
  • func (i *TwoStageInputPlugin) Close()
  • func (i *TwoStageInputPlugin) Done() chan position_store.Position
  • func (i *TwoStageInputPlugin) Identity() uint32
  • func (i *TwoStageInputPlugin) NewPositionStore() (position_store.PositionStore, error)
  • func (i *TwoStageInputPlugin) PositionStore() position_store.PositionStore
  • func (i *TwoStageInputPlugin) SendDeadSignal() error
  • func (i *TwoStageInputPlugin) Stage() config.InputMode
  • func (i *TwoStageInputPlugin) Start(emitter core.Emitter) error
  • func (i *TwoStageInputPlugin) Wait()

Functions

func NewTwoStageInputPlugin

func NewTwoStageInputPlugin(full, incremental core.Input) (core.Input, error)

Types

type TwoStageInputPlugin

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

func (*TwoStageInputPlugin) Close

func (i *TwoStageInputPlugin) Close()

func (*TwoStageInputPlugin) Done

func (i *TwoStageInputPlugin) Done() chan position_store.Position

func (*TwoStageInputPlugin) Identity

func (i *TwoStageInputPlugin) Identity() uint32

func (*TwoStageInputPlugin) NewPositionStore

func (i *TwoStageInputPlugin) NewPositionStore() (position_store.PositionStore, error)

func (*TwoStageInputPlugin) PositionStore

func (i *TwoStageInputPlugin) PositionStore() position_store.PositionStore

func (*TwoStageInputPlugin) SendDeadSignal

func (i *TwoStageInputPlugin) SendDeadSignal() error

func (*TwoStageInputPlugin) Stage

func (i *TwoStageInputPlugin) Stage() config.InputMode

func (*TwoStageInputPlugin) Start

func (i *TwoStageInputPlugin) Start(emitter core.Emitter) error

func (*TwoStageInputPlugin) Wait

func (i *TwoStageInputPlugin) Wait()