eventmanager

Documentation

Index

• Variables
• func NewEventController(manager subscriptions.Manager, backend drivers.Backend, ...) controller.Controller
• type EventControllerConfig
• type Handlers
  • func (h *Handlers) ConfigureHandlers(api middleware.RoutableAPI)

Variables

var Flags = struct {
	Config            string   `long:"config" description:"Path to Config file" default:"./config.dev.json"`
	DbFile            string   `long:"db-file" description:"Backend DB URL/Path" default:"./db.bolt"`
	DbBackend         string   `long:"db-backend" description:"Backend DB Name" default:"boltdb"`
	DbUser            string   `long:"db-username" description:"Backend DB Username" default:"dispatch"`
	DbPassword        string   `long:"db-password" description:"Backend DB Password" default:"dispatch"`
	DbDatabase        string   `long:"db-database" description:"Backend DB Name" default:"dispatch"`
	FunctionManager   string   `long:"function-manager" description:"Function manager endpoint" default:"localhost:8001"`
	Transport         string   `long:"transport" description:"Event transport to use" default:"kafka"`
	KafkaBrokers      []string `long:"kafka-broker" description:"host:port of Kafka broker(s)" default:"localhost:9092"`
	RabbitMQURL       string   `long:"rabbitmq-url" description:"URL to RabbitMQ broker" default:"amqp://guest:guest@localhost:5672/"`
	OrgID             string   `long:"organization" description:"(temporary) Static organization id" default:"dispatch"`
	ResyncPeriod      int      `long:"resync-period" description:"The time period (in seconds) to sync with underlying k8s" default:"60"`
	K8sConfig         string   `long:"kubeconfig" description:"Path to kubernetes config file" default:""`
	K8sNamespace      string   `long:"namespace" description:"Kubernetes namespace" default:"default"`
	EventDriverImage  string   `long:"event-driver-image" description:"Default event driver image"`
	EventSidecarImage string   `long:"event-sidecar-image" description:"Event sidecar image"`
	SecretStore       string   `long:"secret-store" description:"Secret store endpoint" default:"localhost:8003"`
	Tracer            string   `long:"tracer" description:"Open Tracing Tracer endpoint" default:""`
}{}

Flags are configuration flags for the event manager

Functions

func NewEventController

func NewEventController(manager subscriptions.Manager, backend drivers.Backend, store entitystore.EntityStore, config EventControllerConfig) controller.Controller

NewEventController creates a new controller to manage the reconciliation of event manager entities

Types

type EventControllerConfig

type EventControllerConfig struct {
	ResyncPeriod   time.Duration
	OrganizationID string
	WorkerNumber   int
}

EventControllerConfig defines configuration for controller

type Handlers

type Handlers struct {
	Store     entitystore.EntityStore
	Transport events.Transport
	Watcher   controller.Watcher
	// contains filtered or unexported fields
}

Handlers is a base struct for event manager API handlers.

func (*Handlers) ConfigureHandlers

func (h *Handlers) ConfigureHandlers(api middleware.RoutableAPI)

ConfigureHandlers registers the function manager handlers to the API