mocks

Documentation

Index

• type Emitter
  • func NewEmitter() *Emitter
  • func (m *Emitter) Get() []models.Record
  • func (m *Emitter) GetAllData() []*v1beta2.Asset
  • func (m *Emitter) Push(record models.Record)
• type Extractor
  • func NewExtractor() *Extractor
  • func (m *Extractor) Extract(ctx context.Context, emit plugins.Emit) error
  • func (m *Extractor) SetEmit(records []models.Record)
• type Plugin
  • func (m *Plugin) Info() plugins.Info
  • func (m *Plugin) Init(ctx context.Context, config plugins.Config) error
  • func (m *Plugin) Validate(config plugins.Config) error
• type Processor
  • func NewProcessor() *Processor
  • func (m *Processor) Process(ctx context.Context, src models.Record) (models.Record, error)
• type Sink
  • func NewSink() *Sink
  • func (m *Sink) Close() error
  • func (m *Sink) Sink(ctx context.Context, batch []models.Record) error

Types

type Emitter

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

func NewEmitter

func NewEmitter() *Emitter

func (*Emitter) Get

func (m *Emitter) Get() []models.Record

func (*Emitter) GetAllData

func (m *Emitter) GetAllData() []*v1beta2.Asset

func (*Emitter) Push

func (m *Emitter) Push(record models.Record)

type Extractor

type Extractor struct {
	Plugin
	// contains filtered or unexported fields
}

func NewExtractor

func NewExtractor() *Extractor

func (*Extractor) Extract

func (m *Extractor) Extract(ctx context.Context, emit plugins.Emit) error

func (*Extractor) SetEmit

func (m *Extractor) SetEmit(records []models.Record)

type Plugin

type Plugin struct {
	mock.Mock
}

func (*Plugin) Info

func (m *Plugin) Info() plugins.Info

func (*Plugin) Init

func (m *Plugin) Init(ctx context.Context, config plugins.Config) error

func (*Plugin) Validate

func (m *Plugin) Validate(config plugins.Config) error

type Processor

type Processor struct {
	Plugin
}

func NewProcessor

func NewProcessor() *Processor

func (*Processor) Process

func (m *Processor) Process(ctx context.Context, src models.Record) (models.Record, error)

type Sink

type Sink struct {
	Plugin
}

func NewSink

func NewSink() *Sink

func (*Sink) Close

func (m *Sink) Close() error

func (*Sink) Sink

func (m *Sink) Sink(ctx context.Context, batch []models.Record) error