component

package
v4.35.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 13, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrTimeout    = errors.New("action timed out")
	ErrTypeClosed = errors.New("type was closed")

	ErrNotConnected = errors.New("not connected to target source or sink")

	// ErrAlreadyStarted is returned when an input or output type gets started a
	// second time.
	ErrAlreadyStarted = errors.New("type has already been started")

	ErrNoAck = errors.New("failed to receive acknowledgement")

	ErrFailedSend = errors.New("message failed to reach a target destination")
)

Errors used throughout the codebase.

View Source
var (
	ErrInputNotFound     = errors.New("input not found")
	ErrCacheNotFound     = errors.New("cache not found")
	ErrProcessorNotFound = errors.New("processor not found")
	ErrRateLimitNotFound = errors.New("rate limit not found")
	ErrOutputNotFound    = errors.New("output not found")
	ErrKeyAlreadyExists  = errors.New("key already exists")
	ErrKeyNotFound       = errors.New("key does not exist")
	ErrPipeNotFound      = errors.New("pipe was not found")
)

Manager errors.

View Source
var (
	ErrMessageTooLarge = errors.New("message body larger than buffer space")
)

Buffer errors.

View Source
var ErrNotUnwrapped = errors.New("something has gone wrong during the registering of this component, please open an issue https://github.com/redpanda-data/benthos/issues/new to let us know")

ErrNotUnwrapped is returned in cases where a component was meant to be unwrapped either from the public packages or to the public packages but for some reason this did not happen. Unwrapping should only occur in times when it's guaranteed to succeed, so this error indicates that an assumption was incorrect during the migration of certain components which will need to be immediately addressed by maintainers.

Functions

func ErrInvalidType

func ErrInvalidType(typeStr, tried string) error

ErrInvalidType creates an error that describes a component type being initialized with an unrecognised implementation.

Types

type ConnectionStatus added in v4.31.0

type ConnectionStatus struct {
	Label     string
	Path      []string
	Connected bool
	Err       error
}

ConnectionStatus represents the current connection status of a given component.

func ConnectionActive added in v4.31.0

func ConnectionActive(o Observability) *ConnectionStatus

ConnectionActive returns a ConnectionStatus representing a component connection where we have an active connection.

func ConnectionClosed added in v4.31.0

func ConnectionClosed(o Observability) *ConnectionStatus

ConnectionClosed returns a ConnectionStatus representing a component that has intentionally closed its connection.

func ConnectionFailing added in v4.31.0

func ConnectionFailing(o Observability, err error) *ConnectionStatus

ConnectionFailing returns a ConnectionStatus representing a component connection where we are attempting to connect to the service but are currently unable due to the provided error.

func ConnectionPending added in v4.31.0

func ConnectionPending(o Observability) *ConnectionStatus

ConnectionPending returns a ConnectionStatus representing a component that has not yet attempted to establish its connection.

type ConnectionStatuses added in v4.31.0

type ConnectionStatuses []*ConnectionStatus

ConnectionStatuses represents an aggregate of connection statuses.

func (ConnectionStatuses) AllActive added in v4.31.0

func (s ConnectionStatuses) AllActive() bool

AllActive returns true if there is one or more connections and they are all active.

type ErrBackOff

type ErrBackOff struct {
	Err  error
	Wait time.Duration
}

ErrBackOff is an error returned that allows for a back off duration to be specified

func (*ErrBackOff) Error

func (e *ErrBackOff) Error() string

Error returns the Error string.

type LabelledError added in v4.31.0

type LabelledError struct {
	Label string
	Err   error
}

LabelledError is an error that could be returned by components annotated by their label (or path) in order to provide extra context to which specific component within a config is yielding it. This is particularly useful in situations such as ConnectionStatus aggregates where a broker yields multiple errors from a range of child components.

func (*LabelledError) Error added in v4.31.0

func (e *LabelledError) Error() string

Error returns a formatted error string.

func (*LabelledError) Unwrap added in v4.31.0

func (e *LabelledError) Unwrap() error

Unwrap returns the underlying error value.

type Observability

type Observability interface {
	Metrics() metrics.Type
	Logger() log.Modular
	Tracer() trace.TracerProvider
	Path() []string
	Label() string
}

Observability is an interface implemented by components that provide a range of observability APIs to components. This is primarily done the service-wide managers.

func NoopObservability

func NoopObservability() Observability

NoopObservability returns an implementation of Observability that does nothing.

Directories

Path Synopsis
config
Package config contains reusable config definitions and parsers for inputs defined via the public/service package.
Package config contains reusable config definitions and parsers for inputs defined via the public/service package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL