Versions in this module Expand all Collapse all v4 v4.14.1 Apr 26, 2023 Changes in this version + func OptOnClose(onClose func()) func(*Type) + func Spec() docs.FieldSpecs + type Config struct + Buffer buffer.Config + Input input.Config + Output output.Config + Pipeline pipeline.Config + func NewConfig() Config + func (c Config) Sanitised() (any, error) + type Type struct + func New(conf Config, mgr bundle.NewManagement, opts ...func(*Type)) (*Type, error) + func (t *Type) IsReady() bool + func (t *Type) Stop(ctx context.Context) error + func (t *Type) StopGracefully(ctx context.Context) (err error) + func (t *Type) StopUnordered(ctx context.Context) (err error)
Go to main page