mocks

package

v0.13.0 Latest Latest Go to latest Published: Apr 19, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewEmitter() *Emitter

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

func (m *Emitter) GetAllEdges() []*meteorv1beta1.Edge

func (m *Emitter) GetAllEntities() []*meteorv1beta1.Entity

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

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

func NewExtractor() *Extractor

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

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

type Plugin struct {
	mock.Mock
}

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 struct {
	Plugin
}

func NewProcessor() *Processor

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

type Sink struct {
	Plugin
}

func NewSink() *Sink

func (m *Sink) Close() error

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