Versions in this module Expand all Collapse all v0 v0.1.1 Dec 20, 2017 Changes in this version + const DefaultResyncPeriod + const DefaultWorkerNumber + const EventSubscriber + const FunctionSubscriber + var EventDriverTemplates = map[string]map[string]bool + var EventManagerFlags = struct{ ... } + func NewEventController(manager SubscriptionManager, backend DriverBackend, ...) controller.Controller + type Driver struct + Config map[string]string + Type string + type DriverBackend interface + Delete func(*Driver) error + Deploy func(*Driver) error + Update func(*Driver) error + func NewK8sBackend() (DriverBackend, error) + type DriverBackendMock struct + func (_m *DriverBackendMock) Delete(_a0 *Driver) error + func (_m *DriverBackendMock) Deploy(_a0 *Driver) error + func (_m *DriverBackendMock) Update(_a0 *Driver) error + type EventControllerConfig struct + OrganizationID string + ResyncPeriod time.Duration + WorkerNumber int + type Handlers struct + EQ events.Queue + Store entitystore.EntityStore + Watcher controller.Watcher + func (h *Handlers) ConfigureHandlers(api middleware.RoutableAPI) + type K8sBackendConfig struct + EnableReadinessProbe bool + Namespace string + Replicas int32 + type Subscriber struct + Name string + Type string + type Subscription struct + Secrets []string + Subscriber Subscriber + Topic string + type SubscriptionManager interface + Create func(*Subscription) error + Delete func(*Subscription) error + Run func([]*Subscription) error + func NewSubscriptionManager(mq events.Queue, fnClient client.FunctionsClient) (SubscriptionManager, error) + type SubscriptionManagerMock struct + func (_m *SubscriptionManagerMock) Create(_a0 *Subscription) error + func (_m *SubscriptionManagerMock) Delete(_a0 *Subscription) error + func (_m *SubscriptionManagerMock) Run(_a0 []*Subscription) error
Go to main page