servicebroker

Documentation

Index

• Variables
• func RunLoop(ctx context.Context, namespace string, fn WatchServiceBrokerFunc, ...) error
• type CreateServiceClassFunc
  • func NewK8sCreateServiceClassFunc(cl *dynamic.Client) CreateServiceClassFunc
• type UpdateServiceBrokerFunc
  • func NewK8sUpdateServiceBrokerFunc(cl *dynamic.Client) UpdateServiceBrokerFunc
• type WatchServiceBrokerFunc
  • func NewK8sWatchServiceBrokerFunc(cl *dynamic.Client) WatchServiceBrokerFunc

Variables

var (
	ErrCancelled         = errors.New("stopped")
	ErrNotAServiceBroker = errors.New("not a service broker")
	ErrWatchClosed       = errors.New("watch closed")
)

Functions

func RunLoop

func RunLoop(
	ctx context.Context,
	namespace string,
	fn WatchServiceBrokerFunc,
	updateFn UpdateServiceBrokerFunc,
	cataloger framework.Cataloger,
	createSvcClassFunc CreateServiceClassFunc) error

RunLoop starts a blocking control loop that watches and takes action on service broker resources

Types

type CreateServiceClassFunc

type CreateServiceClassFunc func(*data.ServiceClass) error

CreateServiceClassFunc is the function that can successfully create a ServiceClass

func NewK8sCreateServiceClassFunc

func NewK8sCreateServiceClassFunc(cl *dynamic.Client) CreateServiceClassFunc

NewK8sCreateServiceClassFunc returns a CreateServiceClassFunc implemented with restIFace

type UpdateServiceBrokerFunc

type UpdateServiceBrokerFunc func(*data.ServiceBroker) (*data.ServiceBroker, error)

UpdateServiceBrokerFunc is the function that can update a service broker

func NewK8sUpdateServiceBrokerFunc

func NewK8sUpdateServiceBrokerFunc(cl *dynamic.Client) UpdateServiceBrokerFunc

NewK8sUpdateServiceBrokerFunc returns an UpdateServiceBrokerFunc backed by a Kubernetes client

type WatchServiceBrokerFunc

type WatchServiceBrokerFunc func(namespace string) (watch.Interface, error)

WatchServiceBrokerFunc is the function that returns a watch interface for service broker resources

func NewK8sWatchServiceBrokerFunc

func NewK8sWatchServiceBrokerFunc(cl *dynamic.Client) WatchServiceBrokerFunc

NewK8sWatchServiceBrokerFunc returns a WatchServiceBrokerFunc backed by a Kubernetes client