plugins

Documentation

Index

• Variables
• func Register(name PluginName, plugin Plugin)
• type BootstrapPlugin
• type CaPlugin
• type DbVersion
• type DiscoveryPlugin
• type MutablePluginContext
• type MutableRegistry
  • func NewRegistry() MutableRegistry
• type Plugin
• type PluginConfig
• type PluginContext
• type PluginName
• type Registry
  • func Plugins() Registry
• type RegistryMutator
• type ResourceStorePlugin
• type RuntimePlugin
• type SecretStorePlugin

Variables

var AlreadyMigrated = errors.New("database already migrated")

Functions

func Register

func Register(name PluginName, plugin Plugin)

Types

type BootstrapPlugin

type BootstrapPlugin interface {
	Plugin
	Bootstrap(*MutablePluginContext, PluginConfig) error
}

BootstrapPlugin is responsible for environment-specific initialization at start up, e.g. Kubernetes-specific part of configuration. Unlike other plugins, can mutate plugin context directly.

type CaPlugin

type CaPlugin interface {
	Plugin
	NewCaManager(PluginContext, PluginConfig) (core_ca.Manager, error)
}

CaPlugin is responsible for providing Certificate Authority Manager

type DbVersion

type DbVersion = uint

ResourceStorePlugin is responsible for instantiating a particular ResourceStore.

type DiscoveryPlugin

type DiscoveryPlugin interface {
	Plugin
	StartDiscovering(PluginContext, PluginConfig) error
}

DiscoveryPlugin is responsible for discovering Dataplanes for given environment.

type MutablePluginContext

type MutablePluginContext = core_runtime.Builder

type MutableRegistry

type MutableRegistry interface {
	Registry
	RegistryMutator
}

func NewRegistry

func NewRegistry() MutableRegistry

type Plugin

type Plugin interface{}

type PluginConfig

type PluginConfig interface{}

type PluginContext

type PluginContext = core_runtime.BuilderContext

type PluginName

type PluginName string

const (
	Kubernetes PluginName = "k8s"
	Universal  PluginName = "universal"
	Memory     PluginName = "memory"
	Postgres   PluginName = "postgres"

	CaBuiltin  PluginName = "builtin"
	CaProvided PluginName = "provided"
)

type Registry

type Registry interface {
	Bootstrap(PluginName) (BootstrapPlugin, error)
	ResourceStore(name PluginName) (ResourceStorePlugin, error)
	SecretStore(name PluginName) (SecretStorePlugin, error)
	Discovery(name PluginName) (DiscoveryPlugin, error)
	Runtime(name PluginName) (RuntimePlugin, error)
	Ca(name PluginName) (CaPlugin, error)
	CaPlugins() map[PluginName]CaPlugin
}

func Plugins

func Plugins() Registry

type RegistryMutator

type RegistryMutator interface {
	Register(PluginName, Plugin) error
}

type ResourceStorePlugin

type ResourceStorePlugin interface {
	Plugin
	NewResourceStore(PluginContext, PluginConfig) (core_store.ResourceStore, error)
	Migrate(PluginContext, PluginConfig) (DbVersion, error)
}

type RuntimePlugin

type RuntimePlugin interface {
	Plugin
	Customize(core_runtime.Runtime) error
}

RuntimePlugin is responsible for registering environment-specific components, e.g. Kubernetes admission web hooks.

type SecretStorePlugin

type SecretStorePlugin interface {
	Plugin
	NewSecretStore(PluginContext, PluginConfig) (secret_store.SecretStore, error)
}

SecretStorePlugin is responsible for instantiating a particular SecretStore.