plugin

type FilterStatus struct {
	Name            string
	Plugin          string
	Config          interface{}
	ReferenceCount  int
	SuccessCount    int
	ErrorCount      int
	FilterCount     int
	SuccessVelocity int
	ErrorVelocity   int
	FilterVelocity  int
	LastEventTs     int64
	Tid             tenant.Id
}

type Manager interface {
	Receiverers() map[string]pkgreceiver.NewReceiverer
	RegisterReceiver(
		ctx context.Context, plugin string,
		name string, config interface{},
		tid tenant.Id,
	) (pkgreceiver.Receiver, error)
	Receivers() map[string]pkgreceiver.Receiver
	ReceiversStatus() map[string]ReceiverStatus
	UnregisterReceiver(ctx context.Context, r pkgreceiver.Receiver) error

	Filterers() map[string]pkgfilter.NewFilterer
	RegisterFilter(
		ctx context.Context, plugin string,
		name string, config interface{},
		tid tenant.Id,
	) (pkgfilter.Filterer, error)
	Filters() map[string]pkgfilter.Filterer
	FiltersStatus() map[string]FilterStatus
	UnregisterFilter(ctx context.Context, f pkgfilter.Filterer) error

	Senderers() map[string]pkgsender.NewSenderer
	RegisterSender(
		ctx context.Context, plugin string,
		name string, config interface{},
		tid tenant.Id,
	) (pkgsender.Sender, error)
	Senders() map[string]pkgsender.Sender
	SendersStatus() map[string]SenderStatus
	UnregisterSender(ctx context.Context, s pkgsender.Sender) error
}

type ManagerOption func(*manager) error

type NotRegisteredError struct{}

type OptionError struct {
	Message string
	Err     error
}

type ReceiverStatus struct {
	Name            string
	Plugin          string
	Config          interface{}
	ReferenceCount  int
	SuccessCount    int
	ErrorCount      int
	SuccessVelocity int
	ErrorVelocity   int
	LastEventTs     int64
	Tid             tenant.Id
}

type RegistrationError struct {
	Message string
	Plugin  string
	Name    string
	Err     error
}

type SenderStatus struct {
	Name            string
	Plugin          string
	Config          interface{}
	ReferenceCount  int
	SuccessCount    int
	ErrorCount      int
	SuccessVelocity int
	ErrorVelocity   int
	LastEventTs     int64
	Tid             tenant.Id
}

type UnregistrationError struct {
	Message string
	Err     error
}