broker

Documentation

Index

• Constants
• type ClusterFacade
  • func NewClusterBrokersFacade(client client.Client, workingNamespace, serviceName, clusterBrokerName string, ...) *ClusterFacade
  • func (f *ClusterFacade) Create() error
  • func (f *ClusterFacade) Delete() error
  • func (f *ClusterFacade) Exist() (bool, error)
  • func (f *ClusterFacade) SetNamespace(namespace string)
• type ClusterSyncer
  • func NewClusterBrokerSyncer(cli client.Client, clusterBrokerName string, log logrus.FieldLogger) *ClusterSyncer
  • func (r *ClusterSyncer) SetNamespace(namespace string)
  • func (r *ClusterSyncer) Sync() error
• type Facade
  • func NewBrokersFacade(cli client.Client, systemNamespace, serviceName string, log logrus.FieldLogger) *Facade
  • func (f *Facade) Create() error
  • func (f *Facade) Delete() error
  • func (f *Facade) Exist() (bool, error)
  • func (f *Facade) SetNamespace(namespace string)
• type Syncer
  • func NewBrokerSyncer(cli client.Client, log logrus.FieldLogger) *Syncer
  • func (r *Syncer) SetNamespace(namespace string)
  • func (r *Syncer) Sync() error

Constants

const (
	// NamespacedBrokerName name of the namespaced Service Broker
	NamespacedBrokerName = "helm-broker"
	// BrokerLabelKey key of the namespaced Service Broker label
	BrokerLabelKey = "namespaced-helm-broker"
	// BrokerLabelValue value of the namespaced Service Broker label
	BrokerLabelValue = "true"
)

Types

type ClusterFacade

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

ClusterFacade is responsible for creation k8s objects for namespaced broker

func NewClusterBrokersFacade

func NewClusterBrokersFacade(client client.Client, workingNamespace, serviceName, clusterBrokerName string, log logrus.FieldLogger) *ClusterFacade

NewClusterBrokersFacade returns facade

func (*ClusterFacade) Create

func (f *ClusterFacade) Create() error

Create creates ClusterServiceBroker. Errors don't stop execution of method. AlreadyExist errors are ignored.

func (*ClusterFacade) Delete

func (f *ClusterFacade) Delete() error

Delete removes ClusterServiceBroker. Errors don't stop execution of method. NotFound errors are ignored.

func (*ClusterFacade) Exist

func (f *ClusterFacade) Exist() (bool, error)

Exist check if ClusterServiceBroker exists.

func (*ClusterFacade) SetNamespace

func (f *ClusterFacade) SetNamespace(namespace string)

SetNamespace sets service's working namespace

type ClusterSyncer

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

ClusterSyncer provide services to sync the ClusterServiceBroker

func NewClusterBrokerSyncer

func NewClusterBrokerSyncer(cli client.Client, clusterBrokerName string, log logrus.FieldLogger) *ClusterSyncer

NewClusterBrokerSyncer allows to sync the ServiceBroker.

func (*ClusterSyncer) SetNamespace

func (r *ClusterSyncer) SetNamespace(namespace string)

SetNamespace sets service's working namespace

func (*ClusterSyncer) Sync

func (r *ClusterSyncer) Sync() error

Sync syncs the ServiceBrokers, does not fail if the broker does not exists

type Facade

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

Facade is responsible for creation k8s objects for namespaced broker. The Facade is not thread-safe.

func NewBrokersFacade

func NewBrokersFacade(cli client.Client, systemNamespace, serviceName string, log logrus.FieldLogger) *Facade

NewBrokersFacade returns facade

func (*Facade) Create

func (f *Facade) Create() error

Create creates ServiceBroker. Errors don't stop execution of method. AlreadyExist errors are ignored.

func (*Facade) Delete

func (f *Facade) Delete() error

Delete removes ServiceBroker. Errors don't stop execution of method. NotFound errors are ignored.

func (*Facade) Exist

func (f *Facade) Exist() (bool, error)

Exist check if ServiceBroker exists.

func (*Facade) SetNamespace

func (f *Facade) SetNamespace(namespace string)

SetNamespace sets service's working namespace

type Syncer

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

Syncer provide services to sync the ServiceBroker

func NewBrokerSyncer

func NewBrokerSyncer(cli client.Client, log logrus.FieldLogger) *Syncer

NewBrokerSyncer allows to sync the ServiceBroker.

func (*Syncer) SetNamespace

func (r *Syncer) SetNamespace(namespace string)

SetNamespace sets service's working namespace

func (*Syncer) Sync

func (r *Syncer) Sync() error

Sync syncs the ServiceBrokers, does not fail if the broker does not exists