Versions in this module Expand all Collapse all v4 v4.22.0 Oct 23, 2023 Changes in this version + func Spec() docs.FieldSpecs + type APIReg interface + RegisterEndpoint func(path, desc string, h http.HandlerFunc) + type ErrResourceNotFound string + func (e ErrResourceNotFound) Error() string + type OptFunc func(*Type) + func OptSetAPIReg(r APIReg) OptFunc + func OptSetBloblangEnvironment(env *bloblang.Environment) OptFunc + func OptSetEnvironment(e *bundle.Environment) OptFunc + func OptSetFS(fs ifs.FS) OptFunc + func OptSetLogger(logger log.Modular) OptFunc + func OptSetMetrics(stats *metrics.Namespaced) OptFunc + func OptSetStreamHTTPNamespacing(enabled bool) OptFunc + func OptSetStreamsMode(b bool) OptFunc + func OptSetTracer(tracer trace.TracerProvider) OptFunc + type ResourceConfig struct + ResourceCaches []cache.Config + ResourceInputs []input.Config + ResourceOutputs []output.Config + ResourceProcessors []processor.Config + ResourceRateLimits []ratelimit.Config + func NewResourceConfig() ResourceConfig + func (r *ResourceConfig) AddFrom(extra *ResourceConfig) error + type Type struct + func New(conf ResourceConfig, opts ...OptFunc) (*Type, error) + func (t *Type) AccessCache(ctx context.Context, name string, fn func(cache.V1)) (err error) + func (t *Type) AccessInput(ctx context.Context, name string, fn func(input.Streamed)) (err error) + func (t *Type) AccessOutput(ctx context.Context, name string, fn func(output.Sync)) (err error) + func (t *Type) AccessProcessor(ctx context.Context, name string, fn func(processor.V1)) (err error) + func (t *Type) AccessRateLimit(ctx context.Context, name string, fn func(ratelimit.V1)) (err error) + func (t *Type) BloblEnvironment() *bloblang.Environment + func (t *Type) CloseObservability(ctx context.Context) error + func (t *Type) Environment() *bundle.Environment + func (t *Type) FS() ifs.FS + func (t *Type) ForStream(id string) bundle.NewManagement + func (t *Type) GetDocs(name string, ctype docs.Type) (docs.ComponentSpec, bool) + func (t *Type) GetPipe(name string) (<-chan message.Transaction, error) + func (t *Type) IntoPath(segments ...string) bundle.NewManagement + func (t *Type) Label() string + func (t *Type) Logger() log.Modular + func (t *Type) Metrics() metrics.Type + func (t *Type) NewBuffer(conf buffer.Config) (buffer.Streamed, error) + func (t *Type) NewCache(conf cache.Config) (cache.V1, error) + func (t *Type) NewInput(conf input.Config) (input.Streamed, error) + func (t *Type) NewOutput(conf output.Config, pipelines ...processor.PipelineConstructorFunc) (output.Streamed, error) + func (t *Type) NewProcessor(conf processor.Config) (processor.V1, error) + func (t *Type) NewRateLimit(conf ratelimit.Config) (ratelimit.V1, error) + func (t *Type) Path() []string + func (t *Type) ProbeCache(name string) bool + func (t *Type) ProbeInput(name string) bool + func (t *Type) ProbeOutput(name string) bool + func (t *Type) ProbeProcessor(name string) bool + func (t *Type) ProbeRateLimit(name string) bool + func (t *Type) RegisterEndpoint(apiPath, desc string, h http.HandlerFunc) + func (t *Type) RemoveCache(ctx context.Context, name string) error + func (t *Type) RemoveInput(ctx context.Context, name string) error + func (t *Type) RemoveOutput(ctx context.Context, name string) error + func (t *Type) RemoveProcessor(ctx context.Context, name string) error + func (t *Type) RemoveRateLimit(ctx context.Context, name string) error + func (t *Type) SetPipe(name string, tran <-chan message.Transaction) + func (t *Type) StoreCache(ctx context.Context, name string, conf cache.Config) error + func (t *Type) StoreInput(ctx context.Context, name string, conf input.Config) error + func (t *Type) StoreOutput(ctx context.Context, name string, conf output.Config) error + func (t *Type) StoreProcessor(ctx context.Context, name string, conf processor.Config) error + func (t *Type) StoreRateLimit(ctx context.Context, name string, conf ratelimit.Config) error + func (t *Type) Tracer() trace.TracerProvider + func (t *Type) TriggerCloseNow() + func (t *Type) TriggerStopConsuming() + func (t *Type) UnsetPipe(name string, tran <-chan message.Transaction) + func (t *Type) WaitForClose(ctx context.Context) error + func (t *Type) WithAddedMetrics(m metrics.Type) bundle.NewManagement + func (t *Type) WithMetricsMapping(m *metrics.Mapping) *Type
Go to main page