serviceinstance

Documentation

Index

• Variables
• func RunLoop(ctx context.Context, watchFn WatchServiceInstanceFunc, ...) error
• type UpdateServiceInstanceFunc
  • func NewK8sUpdateServiceInstanceFunc(cl *dynamic.Client) UpdateServiceInstanceFunc
• type WatchServiceInstanceFunc
  • func NewK8sWatchServiceInstanceFunc(cl *dynamic.Client) WatchServiceInstanceFunc

Variables

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

Functions

func RunLoop

func RunLoop(
	ctx context.Context,
	watchFn WatchServiceInstanceFunc,
	updateFn UpdateServiceInstanceFunc,
	getServiceClassFn refs.ServiceClassGetterFunc,
	getServiceBrokerFn refs.ServiceBrokerGetterFunc,
	lifecycler framework.Lifecycler,
) error

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

Types

type UpdateServiceInstanceFunc

type UpdateServiceInstanceFunc func(*data.ServiceInstance) (*data.ServiceInstance, error)

UpdateServiceInstanceFunc is the function that can update a service instance

func NewK8sUpdateServiceInstanceFunc

func NewK8sUpdateServiceInstanceFunc(cl *dynamic.Client) UpdateServiceInstanceFunc

NewK8sUpdateServiceInstanceFunc returns an UpdateServiceInstanceFunc backed by a Kubernetes client

type WatchServiceInstanceFunc

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

WatchServiceInstanceFunc is the function that returns a watch interface for service instance resources

func NewK8sWatchServiceInstanceFunc

func NewK8sWatchServiceInstanceFunc(cl *dynamic.Client) WatchServiceInstanceFunc

NewK8sWatchServiceInstanceFunc returns a WatchServiceInstanceFunc backed by a Kubernetes client