drivers

Documentation

Index

• type Backend
  • func NewK8sBackend(secretsClient client.SecretsClient, config ConfigOpts) (Backend, error)
• type Causer
• type ConfigOpts
• type EntityHandler
  • func NewEntityHandler(store entitystore.EntityStore, backend Backend) *EntityHandler
  • func (h *EntityHandler) Add(ctx context.Context, obj entitystore.Entity) (err error)
  • func (h *EntityHandler) Delete(ctx context.Context, obj entitystore.Entity) error
  • func (h *EntityHandler) Error(ctx context.Context, obj entitystore.Entity) error
  • func (h *EntityHandler) Sync(ctx context.Context, resyncPeriod time.Duration) ([]entitystore.Entity, error)
  • func (h *EntityHandler) Type() reflect.Type
  • func (h *EntityHandler) Update(ctx context.Context, obj entitystore.Entity) (err error)
• type EventdriverErrorDeploymentAlreadyExists
  • func (err *EventdriverErrorDeploymentAlreadyExists) Cause() error
  • func (err *EventdriverErrorDeploymentAlreadyExists) Error() string
• type EventdriverErrorDeploymentNotAvaialble
  • func (err *EventdriverErrorDeploymentNotAvaialble) Cause() error
  • func (err *EventdriverErrorDeploymentNotAvaialble) Error() string
• type EventdriverErrorDeploymentNotFound
  • func (err *EventdriverErrorDeploymentNotFound) Cause() error
  • func (err *EventdriverErrorDeploymentNotFound) Error() string
• type EventdriverErrorIngressAlreadyExists
  • func (err *EventdriverErrorIngressAlreadyExists) Cause() error
  • func (err *EventdriverErrorIngressAlreadyExists) Error() string
• type EventdriverErrorServiceAlreadyExists
  • func (err *EventdriverErrorServiceAlreadyExists) Cause() error
  • func (err *EventdriverErrorServiceAlreadyExists) Error() string
• type EventdriverErrorUnknown
  • func (err *EventdriverErrorUnknown) Cause() error
  • func (err *EventdriverErrorUnknown) Error() string
• type Handlers
  • func NewHandlers(store entitystore.EntityStore, watcher controller.Watcher, ...) *Handlers
  • func (h *Handlers) ConfigureHandlers(api middleware.RoutableAPI)

Types

type Backend

type Backend interface {
	Deploy(context.Context, *entities.Driver) error
	Expose(context.Context, *entities.Driver) error
	Update(context.Context, *entities.Driver) error
	Delete(context.Context, *entities.Driver) error
}

Backend defines the event driver backend interface

func NewK8sBackend

func NewK8sBackend(secretsClient client.SecretsClient, config ConfigOpts) (Backend, error)

NewK8sBackend creates a new K8s backend driver

type Causer

type Causer interface {
	Cause() error
}

Causer defines interface for eventdriver error

type ConfigOpts

type ConfigOpts struct {
	SidecarImage    string
	TransportType   string
	RabbitMQURL     string
	KafkaBrokers    []string
	Tracer          string
	K8sConfig       string
	DriverNamespace string
	Host            string
}

ConfigOpts configures K8s driver backend

type EntityHandler

type EntityHandler struct {
	// contains filtered or unexported fields
}

EntityHandler handles driver entity operations

func NewEntityHandler

func NewEntityHandler(store entitystore.EntityStore, backend Backend) *EntityHandler

NewEntityHandler creates new instance of EntityHandler

func (*EntityHandler) Add

func (h *EntityHandler) Add(ctx context.Context, obj entitystore.Entity) (err error)

Add adds new driver to the store, and executes its deployment.

func (*EntityHandler) Delete

func (h *EntityHandler) Delete(ctx context.Context, obj entitystore.Entity) error

Delete deletes the driver from the backend

func (*EntityHandler) Error

func (h *EntityHandler) Error(ctx context.Context, obj entitystore.Entity) error

Error handles error state

func (*EntityHandler) Sync

func (h *EntityHandler) Sync(ctx context.Context, resyncPeriod time.Duration) ([]entitystore.Entity, error)

Sync Executes sync loop

func (*EntityHandler) Type

func (h *EntityHandler) Type() reflect.Type

Type returns Entity Handler type

func (*EntityHandler) Update

func (h *EntityHandler) Update(ctx context.Context, obj entitystore.Entity) (err error)

Update updates the driver by updating the deployment

type EventdriverErrorDeploymentAlreadyExists

type EventdriverErrorDeploymentAlreadyExists struct {
	Err error `json:"err"`
}

EventdriverErrorDeploymentAlreadyExists defines deployment already exists error for event driver

func (*EventdriverErrorDeploymentAlreadyExists) Cause

func (err *EventdriverErrorDeploymentAlreadyExists) Cause() error

Cause returns the underlying cause error

func (*EventdriverErrorDeploymentAlreadyExists) Error

func (err *EventdriverErrorDeploymentAlreadyExists) Error() string

type EventdriverErrorDeploymentNotAvaialble

type EventdriverErrorDeploymentNotAvaialble struct {
	Err error `json:"err"`
}

EventdriverErrorDeploymentNotAvaialble defines deployment not available error for event driver

func (*EventdriverErrorDeploymentNotAvaialble) Cause

func (err *EventdriverErrorDeploymentNotAvaialble) Cause() error

Cause returns the underlying cause error

func (*EventdriverErrorDeploymentNotAvaialble) Error

func (err *EventdriverErrorDeploymentNotAvaialble) Error() string

type EventdriverErrorDeploymentNotFound

type EventdriverErrorDeploymentNotFound struct {
	Err error `json:"err"`
}

EventdriverErrorDeploymentNotFound defines deployment not found error for event driver

func (*EventdriverErrorDeploymentNotFound) Cause

func (err *EventdriverErrorDeploymentNotFound) Cause() error

Cause returns the underlying cause error

func (*EventdriverErrorDeploymentNotFound) Error

func (err *EventdriverErrorDeploymentNotFound) Error() string

type EventdriverErrorIngressAlreadyExists

type EventdriverErrorIngressAlreadyExists struct {
	Err error `json:"err"`
}

EventdriverErrorIngressAlreadyExists defines ingress already exists error for event driver

func (*EventdriverErrorIngressAlreadyExists) Cause

func (err *EventdriverErrorIngressAlreadyExists) Cause() error

Cause returns the underlying cause error

func (*EventdriverErrorIngressAlreadyExists) Error

func (err *EventdriverErrorIngressAlreadyExists) Error() string

type EventdriverErrorServiceAlreadyExists

type EventdriverErrorServiceAlreadyExists struct {
	Err error `json:"err"`
}

EventdriverErrorServiceAlreadyExists defines service already exists error for event driver

func (*EventdriverErrorServiceAlreadyExists) Cause

func (err *EventdriverErrorServiceAlreadyExists) Cause() error

Cause returns the underlying cause error

func (*EventdriverErrorServiceAlreadyExists) Error

func (err *EventdriverErrorServiceAlreadyExists) Error() string

type EventdriverErrorUnknown

type EventdriverErrorUnknown struct {
	Err error `json:"err"`
}

EventdriverErrorUnknown defines unknonwn error for event driver

func (*EventdriverErrorUnknown) Cause

func (err *EventdriverErrorUnknown) Cause() error

Cause returns the underlying cause error

func (*EventdriverErrorUnknown) Error

func (err *EventdriverErrorUnknown) Error() string

type Handlers

type Handlers struct {
	// contains filtered or unexported fields
}

Handlers is a base struct for event manager drivers API handlers.

func NewHandlers

func NewHandlers(store entitystore.EntityStore, watcher controller.Watcher, secretsClient client.SecretsClient) *Handlers

NewHandlers Creates new instance of driver handlers

func (*Handlers) ConfigureHandlers

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

ConfigureHandlers configures API handlers for driver endpoints