plugin

Sep 5, 2023

Changes in this version

type FilterStatus

+ ErrorCount int

+ ErrorVelocity int

+ FilterCount int

+ FilterVelocity int

+ LastEventTs int64

+ SuccessCount int

+ SuccessVelocity int

type ManagerOption

+ func WithSyncer(tableSyncer syncer.DeltaSyncer) ManagerOption

+ func WithTenantStorer(t tenant.TenantStorer) ManagerOption

type ReceiverStatus

+ ErrorCount int

+ ErrorVelocity int

+ LastEventTs int64

+ SuccessCount int

+ SuccessVelocity int

type SenderStatus

+ ErrorCount int

+ ErrorVelocity int

+ LastEventTs int64

+ SuccessCount int

+ SuccessVelocity int

Feb 10, 2022

Changes in this version

type FilterStatus

+ Tid tenant.Id

type ReceiverStatus

+ Tid tenant.Id

type SenderStatus

+ Tid tenant.Id

Aug 27, 2021

Changes in this version

type ManagerOption

+ func WithSecretVaults(s secret.Vault) ManagerOption

Jun 4, 2021

Changes in this version

+ type FilterStatus struct

+ Config interface{}

+ Name string

+ Plugin string

+ ReferenceCount int

type Manager

+ FiltersStatus func() map[string]FilterStatus

+ ReceiversStatus func() map[string]ReceiverStatus

+ SendersStatus func() map[string]SenderStatus

+ type ReceiverStatus struct

+ Config interface{}

+ Name string

+ Plugin string

+ ReferenceCount int

+ type SenderStatus struct

+ Config interface{}

+ Name string

+ Plugin string

+ ReferenceCount int

May 26, 2021

Changes in this version

+ type Manager interface

+ Filterers func() map[string]pkgfilter.NewFilterer

+ Filters func() map[string]pkgfilter.Filterer

+ Receiverers func() map[string]pkgreceiver.NewReceiverer

+ Receivers func() map[string]pkgreceiver.Receiver

+ RegisterFilter func(ctx context.Context, plugin string, name string, config interface{}, ...) (pkgfilter.Filterer, error)

+ RegisterReceiver func(ctx context.Context, plugin string, name string, config interface{}, ...) (pkgreceiver.Receiver, error)

+ RegisterSender func(ctx context.Context, plugin string, name string, config interface{}, ...) (pkgsender.Sender, error)

+ Senderers func() map[string]pkgsender.NewSenderer

+ Senders func() map[string]pkgsender.Sender

+ UnregisterFilter func(ctx context.Context, f pkgfilter.Filterer) error

+ UnregisterReceiver func(ctx context.Context, r pkgreceiver.Receiver) error

+ UnregisterSender func(ctx context.Context, s pkgsender.Sender) error

+ func NewManager(options ...ManagerOption) (Manager, error)

+ type ManagerOption func(*manager) error

+ func WithLogger(l *zerolog.Logger) ManagerOption

+ func WithNextFnDeadline(d time.Duration) ManagerOption

+ func WithPluginManager(p pkgmanager.Manager) ManagerOption

+ func WithQuotaManager(q *quota.QuotaManager) ManagerOption

+ type NotRegisteredError struct

+ func (e *NotRegisteredError) Error() string

+ func (e *NotRegisteredError) Unwrap() error

+ type OptionError struct

+ Err error

+ Message string

+ func (e *OptionError) Error() string

+ func (e *OptionError) Unwrap() error

+ type RegistrationError struct

+ Err error

+ Message string

+ Name string

+ Plugin string

+ func (e *RegistrationError) Error() string

+ func (e *RegistrationError) Unwrap() error

+ type UnregistrationError struct

+ Err error

+ Message string

+ func (e *UnregistrationError) Error() string

+ func (e *UnregistrationError) Unwrap() error