Documentation
¶
Overview ¶
Package eventbridge provides an in-memory mock implementation of AWS EventBridge.
Index ¶
- type Mock
- func (m *Mock) CreateEventBus(_ context.Context, cfg driver.EventBusConfig) (*driver.EventBusInfo, error)
- func (m *Mock) DeleteEventBus(_ context.Context, name string) error
- func (m *Mock) DeleteRule(_ context.Context, eventBus, ruleName string) error
- func (m *Mock) DisableRule(_ context.Context, eventBus, ruleName string) error
- func (m *Mock) EnableRule(_ context.Context, eventBus, ruleName string) error
- func (m *Mock) GetEventBus(_ context.Context, name string) (*driver.EventBusInfo, error)
- func (m *Mock) GetEventHistory(_ context.Context, eventBus string, limit int) ([]driver.Event, error)
- func (m *Mock) GetRule(_ context.Context, eventBus, ruleName string) (*driver.Rule, error)
- func (m *Mock) ListEventBuses(_ context.Context) ([]driver.EventBusInfo, error)
- func (m *Mock) ListRules(_ context.Context, eventBus string) ([]driver.Rule, error)
- func (m *Mock) ListTargets(_ context.Context, eventBus, ruleName string) ([]driver.Target, error)
- func (m *Mock) MatchedRules(event *driver.Event) []driver.Rule
- func (m *Mock) PutEvents(_ context.Context, events []driver.Event) (*driver.PublishResult, error)
- func (m *Mock) PutRule(_ context.Context, cfg *driver.RuleConfig) (*driver.Rule, error)
- func (m *Mock) PutTargets(_ context.Context, eventBus, ruleName string, targets []driver.Target) error
- func (m *Mock) RemoveTargets(_ context.Context, eventBus, ruleName string, targetIDs []string) error
- func (m *Mock) SetMonitoring(mon mondriver.Monitoring)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Mock ¶
type Mock struct {
// contains filtered or unexported fields
}
Mock is an in-memory mock implementation of AWS EventBridge.
func (*Mock) CreateEventBus ¶
func (m *Mock) CreateEventBus(_ context.Context, cfg driver.EventBusConfig) (*driver.EventBusInfo, error)
CreateEventBus creates a new EventBridge event bus.
func (*Mock) DeleteEventBus ¶
DeleteEventBus deletes an EventBridge event bus.
func (*Mock) DeleteRule ¶
DeleteRule deletes a rule from an event bus.
func (*Mock) DisableRule ¶
DisableRule disables a rule on an event bus.
func (*Mock) EnableRule ¶
EnableRule enables a rule on an event bus.
func (*Mock) GetEventBus ¶
GetEventBus retrieves information about an EventBridge event bus.
func (*Mock) GetEventHistory ¶
func (m *Mock) GetEventHistory(_ context.Context, eventBus string, limit int) ([]driver.Event, error)
GetEventHistory retrieves event history for an event bus.
func (*Mock) ListEventBuses ¶
ListEventBuses lists all EventBridge event buses.
func (*Mock) ListTargets ¶
ListTargets lists all targets for a rule.
func (*Mock) MatchedRules ¶
MatchedRules returns all rules that match the given event (exported for testing).
func (*Mock) PutTargets ¶
func (m *Mock) PutTargets(_ context.Context, eventBus, ruleName string, targets []driver.Target) error
PutTargets adds targets to a rule.
func (*Mock) RemoveTargets ¶
func (m *Mock) RemoveTargets(_ context.Context, eventBus, ruleName string, targetIDs []string) error
RemoveTargets removes targets from a rule.
func (*Mock) SetMonitoring ¶
func (m *Mock) SetMonitoring(mon mondriver.Monitoring)
SetMonitoring sets the monitoring backend for auto-metric generation.
Source Files