Documentation
¶
Overview ¶
Package eventbus provides a portable event bus API with cross-cutting concerns.
Index ¶
- type EventBus
- func (eb *EventBus) CreateEventBus(ctx context.Context, config driver.EventBusConfig) (*driver.EventBusInfo, error)
- func (eb *EventBus) DeleteEventBus(ctx context.Context, name string) error
- func (eb *EventBus) DeleteRule(ctx context.Context, eventBus, ruleName string) error
- func (eb *EventBus) DisableRule(ctx context.Context, eventBus, ruleName string) error
- func (eb *EventBus) EnableRule(ctx context.Context, eventBus, ruleName string) error
- func (eb *EventBus) GetEventBus(ctx context.Context, name string) (*driver.EventBusInfo, error)
- func (eb *EventBus) GetEventHistory(ctx context.Context, eventBus string, limit int) ([]driver.Event, error)
- func (eb *EventBus) GetRule(ctx context.Context, eventBus, ruleName string) (*driver.Rule, error)
- func (eb *EventBus) ListEventBuses(ctx context.Context) ([]driver.EventBusInfo, error)
- func (eb *EventBus) ListRules(ctx context.Context, eventBus string) ([]driver.Rule, error)
- func (eb *EventBus) ListTargets(ctx context.Context, eventBus, ruleName string) ([]driver.Target, error)
- func (eb *EventBus) PutEvents(ctx context.Context, events []driver.Event) (*driver.PublishResult, error)
- func (eb *EventBus) PutRule(ctx context.Context, config *driver.RuleConfig) (*driver.Rule, error)
- func (eb *EventBus) PutTargets(ctx context.Context, eventBus, ruleName string, targets []driver.Target) error
- func (eb *EventBus) RemoveTargets(ctx context.Context, eventBus, ruleName string, targetIDs []string) error
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventBus ¶
type EventBus struct {
// contains filtered or unexported fields
}
EventBus is the portable event bus type wrapping a driver with cross-cutting concerns.
func NewEventBus ¶
NewEventBus creates a new portable EventBus wrapping the given driver.
func (*EventBus) CreateEventBus ¶
func (eb *EventBus) CreateEventBus(ctx context.Context, config driver.EventBusConfig) (*driver.EventBusInfo, error)
CreateEventBus creates a new event bus.
func (*EventBus) DeleteEventBus ¶
DeleteEventBus deletes an event bus.
func (*EventBus) DeleteRule ¶
DeleteRule deletes a rule.
func (*EventBus) DisableRule ¶
DisableRule disables a rule.
func (*EventBus) EnableRule ¶
EnableRule enables a rule.
func (*EventBus) GetEventBus ¶
GetEventBus retrieves event bus info.
func (*EventBus) GetEventHistory ¶
func (eb *EventBus) GetEventHistory(ctx context.Context, eventBus string, limit int) ([]driver.Event, error)
GetEventHistory retrieves event history for replay.
func (*EventBus) ListEventBuses ¶
ListEventBuses lists all event buses.
func (*EventBus) ListTargets ¶
func (eb *EventBus) ListTargets(ctx context.Context, eventBus, ruleName string) ([]driver.Target, error)
ListTargets lists targets for a rule.
func (*EventBus) PutEvents ¶
func (eb *EventBus) PutEvents(ctx context.Context, events []driver.Event) (*driver.PublishResult, error)
PutEvents publishes events to the event bus.
type Option ¶
type Option func(*EventBus)
Option configures a portable EventBus.
func WithErrorInjection ¶
WithErrorInjection sets the error injector.
func WithMetrics ¶
WithMetrics sets the metrics collector.
func WithRateLimiter ¶
WithRateLimiter sets the rate limiter.
Source Files
Directories