mock

Documentation

Index

• type Manager
  • func NewManager() *Manager
  • func (m *Manager) ForStream(id string) interop.Manager
  • func (m *Manager) IntoPath(segments ...string) interop.Manager
  • func (m *Manager) NewBuffer(conf buffer.Config) (buffer.Streamed, error)
  • func (m *Manager) NewCache(conf cache.Config) (cache.V1, error)
  • func (m *Manager) NewInput(conf linput.Config, pipelines ...processor.PipelineConstructorFunc) (input.Streamed, error)
  • func (m *Manager) NewOutput(conf loutput.Config, pipelines ...processor.PipelineConstructorFunc) (output.Streamed, error)
  • func (m *Manager) NewProcessor(conf lprocessor.Config) (processor.V1, error)
  • func (m *Manager) NewRateLimit(conf ratelimit.Config) (ratelimit.V1, error)
  • func (m *Manager) StoreCache(ctx context.Context, name string, conf cache.Config) error
  • func (m *Manager) StoreInput(ctx context.Context, name string, conf linput.Config) error
  • func (m *Manager) StoreOutput(ctx context.Context, name string, conf loutput.Config) error
  • func (m *Manager) StoreProcessor(ctx context.Context, name string, conf lprocessor.Config) error
  • func (m *Manager) StoreRateLimit(ctx context.Context, name string, conf ratelimit.Config) error
  • func (m *Manager) WithAddedMetrics(m2 metrics.Type) interop.Manager

Types

type Manager

type Manager struct {
	*mock.Manager
}

Manager provides a mock benthos manager that components can use to test interactions with fake resources.

func NewManager

func NewManager() *Manager

NewManager provides a new mock manager.

func (*Manager) ForStream

func (m *Manager) ForStream(id string) interop.Manager

ForStream returns the same mock manager.

func (*Manager) IntoPath

func (m *Manager) IntoPath(segments ...string) interop.Manager

IntoPath returns the same mock manager.

func (*Manager) NewBuffer

func (m *Manager) NewBuffer(conf buffer.Config) (buffer.Streamed, error)

NewBuffer always errors on invalid type.

func (*Manager) NewCache

func (m *Manager) NewCache(conf cache.Config) (cache.V1, error)

NewCache always errors on invalid type.

func (*Manager) NewInput

func (m *Manager) NewInput(conf linput.Config, pipelines ...processor.PipelineConstructorFunc) (input.Streamed, error)

NewInput always errors on invalid type.

func (*Manager) NewOutput

func (m *Manager) NewOutput(conf loutput.Config, pipelines ...processor.PipelineConstructorFunc) (output.Streamed, error)

NewOutput always errors on invalid type.

func (*Manager) NewProcessor

func (m *Manager) NewProcessor(conf lprocessor.Config) (processor.V1, error)

NewProcessor always errors on invalid type.

func (*Manager) NewRateLimit

func (m *Manager) NewRateLimit(conf ratelimit.Config) (ratelimit.V1, error)

NewRateLimit always errors on invalid type.

func (*Manager) StoreCache

func (m *Manager) StoreCache(ctx context.Context, name string, conf cache.Config) error

StoreCache always errors on invalid type.

func (*Manager) StoreInput

func (m *Manager) StoreInput(ctx context.Context, name string, conf linput.Config) error

StoreInput always errors on invalid type.

func (*Manager) StoreOutput

func (m *Manager) StoreOutput(ctx context.Context, name string, conf loutput.Config) error

StoreOutput always errors on invalid type.

func (*Manager) StoreProcessor

func (m *Manager) StoreProcessor(ctx context.Context, name string, conf lprocessor.Config) error

StoreProcessor always errors on invalid type.

func (*Manager) StoreRateLimit

func (m *Manager) StoreRateLimit(ctx context.Context, name string, conf ratelimit.Config) error

StoreRateLimit always errors on invalid type.

func (*Manager) WithAddedMetrics

func (m *Manager) WithAddedMetrics(m2 metrics.Type) interop.Manager

WithAddedMetrics returns the same mock manager.