Documentation
¶
Index ¶
- type Cache
- func (c *Cache) Add(ctx context.Context, key string, value []byte, ttl *time.Duration) error
- func (c *Cache) Close(ctx context.Context) error
- func (c *Cache) Delete(ctx context.Context, key string) error
- func (c *Cache) Get(ctx context.Context, key string) ([]byte, error)
- func (c *Cache) Set(ctx context.Context, key string, value []byte, ttl *time.Duration) error
- func (c *Cache) SetMulti(ctx context.Context, kvs map[string]cache.TTLItem) error
- type CacheItem
- type Input
- type Manager
- func (m *Manager) AccessCache(ctx context.Context, name string, fn func(cache.V1)) error
- func (m *Manager) AccessInput(ctx context.Context, name string, fn func(input.Streamed)) error
- func (m *Manager) AccessOutput(ctx context.Context, name string, fn func(output.Sync)) error
- func (m *Manager) AccessProcessor(ctx context.Context, name string, fn func(processor.V1)) error
- func (m *Manager) AccessRateLimit(ctx context.Context, name string, fn func(ratelimit.V1)) error
- func (m *Manager) BloblEnvironment() *bloblang.Environment
- func (m *Manager) ForStream(id string) interop.Manager
- func (m *Manager) GetPipe(name string) (<-chan message.Transaction, error)
- func (m *Manager) IntoPath(segments ...string) interop.Manager
- func (m *Manager) Label() string
- func (m *Manager) Logger() log.Modular
- func (m *Manager) Metrics() metrics.Type
- func (m *Manager) Path() []string
- func (m *Manager) ProbeCache(name string) bool
- func (m *Manager) ProbeInput(name string) bool
- func (m *Manager) ProbeOutput(name string) bool
- func (m *Manager) ProbeProcessor(name string) bool
- func (m *Manager) ProbeRateLimit(name string) bool
- func (m *Manager) RegisterEndpoint(path, desc string, h http.HandlerFunc)
- func (m *Manager) SetPipe(name string, t <-chan message.Transaction)
- func (m *Manager) UnsetPipe(name string, t <-chan message.Transaction)
- func (m *Manager) WithAddedMetrics(m2 metrics.Type) interop.Manager
- type OutputChanneled
- type OutputWriter
- type Processor
- type RateLimit
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cache ¶
Cache provides a mock cache implementation
type Input ¶
type Input struct {
TChan chan message.Transaction
// contains filtered or unexported fields
}
Input provides a mocked input implementation.
func NewInput ¶
NewInput creates a new mock input that will return transactions containing a list of batches, then exit.
func (*Input) TransactionChan ¶
func (f *Input) TransactionChan() <-chan message.Transaction
TransactionChan returns a transaction channel.
type Manager ¶
type Manager struct {
Inputs map[string]*Input
Caches map[string]map[string]CacheItem
RateLimits map[string]RateLimit
Outputs map[string]OutputWriter
Processors map[string]Processor
Pipes map[string]<-chan message.Transaction
// OnRegisterEndpoint can be set in order to intercept endpoints registered
// by components.
OnRegisterEndpoint func(path string, h http.HandlerFunc)
}
Manager provides a mock benthos manager that components can use to test interactions with fake resources.
func (*Manager) AccessCache ¶
AccessCache executes a closure on a cache resource.
func (*Manager) AccessInput ¶
AccessInput executes a closure on an input resource.
func (*Manager) AccessOutput ¶
AccessOutput executes a closure on an output resource.
func (*Manager) AccessProcessor ¶
AccessProcessor executes a closure on a processor resource.
func (*Manager) AccessRateLimit ¶
AccessRateLimit executes a closure on a rate limit resource.
func (*Manager) BloblEnvironment ¶
func (m *Manager) BloblEnvironment() *bloblang.Environment
BloblEnvironment always returns the global environment.
func (*Manager) GetPipe ¶
func (m *Manager) GetPipe(name string) (<-chan message.Transaction, error)
GetPipe attempts to find a service wide transaction chan by its name.
func (*Manager) ProbeCache ¶
ProbeCache returns true if a cache resource exists under the provided name.
func (*Manager) ProbeInput ¶
ProbeInput returns true if an input resource exists under the provided name.
func (*Manager) ProbeOutput ¶
ProbeOutput returns true if an output resource exists under the provided name.
func (*Manager) ProbeProcessor ¶
ProbeProcessor returns true if a processor resource exists under the provided name.
func (*Manager) ProbeRateLimit ¶
ProbeRateLimit returns true if a rate limit resource exists under the provided name.
func (*Manager) RegisterEndpoint ¶
func (m *Manager) RegisterEndpoint(path, desc string, h http.HandlerFunc)
RegisterEndpoint registers a server wide HTTP endpoint.
func (*Manager) SetPipe ¶
func (m *Manager) SetPipe(name string, t <-chan message.Transaction)
SetPipe registers a transaction chan under a name.
type OutputChanneled ¶
type OutputChanneled struct {
TChan <-chan message.Transaction
}
OutputChanneled implements the output.Type interface around an exported transaction channel.
func (*OutputChanneled) CloseAsync ¶
func (m *OutputChanneled) CloseAsync()
CloseAsync does nothing.
func (*OutputChanneled) Connected ¶
func (m *OutputChanneled) Connected() bool
Connected returns true.
func (*OutputChanneled) Consume ¶
func (m *OutputChanneled) Consume(msgs <-chan message.Transaction) error
Consume sets the read channel. This implementation is NOT thread safe.
func (OutputChanneled) WaitForClose ¶
func (m OutputChanneled) WaitForClose(t time.Duration) error
WaitForClose does nothing.
type OutputWriter ¶
type OutputWriter func(context.Context, message.Transaction) error
OutputWriter provides a mock implementation of types.OutputWriter.
func (OutputWriter) Connected ¶
func (o OutputWriter) Connected() bool
Connected always returns true.
func (OutputWriter) WaitForClose ¶
func (o OutputWriter) WaitForClose(time.Duration) error
WaitForClose does nothing.
func (OutputWriter) WriteTransaction ¶
func (o OutputWriter) WriteTransaction(ctx context.Context, t message.Transaction) error
WriteTransaction attempts to write a transaction to an output.
type Processor ¶
Processor provides a mock processor implementation around a closure.
func (Processor) ProcessMessage ¶
ProcessMessage returns the closure result executed on a batch.
Source Files