nsbroker

Documentation

Index

• Constants
• type Facade
  • func NewFacade(brokerGetter scbeta.ServiceBrokersGetter, ...) *Facade
  • func (f *Facade) Create(destinationNs string) error
  • func (f *Facade) Delete(destinationNs string) error
  • func (f *Facade) Exist(destinationNs string) (bool, error)
• type MigrationService
  • func NewMigrationService(serviceInterface typedCorev1.ServicesGetter, ...) (*MigrationService, error)
  • func (s *MigrationService) Migrate()

Constants

const (

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

Types

type Facade

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

Facade is responsible for creation k8s objects for namespaced broker

func NewFacade

func NewFacade(brokerGetter scbeta.ServiceBrokersGetter,
	servicesGetter typedCorev1.ServicesGetter,
	brokerSyncer brokerSyncer,
	workingNamespace, abSelectorKey, abSelectorValue string, serviceName string,
	abTargetPort int32, log logrus.FieldLogger) *Facade

NewFacade returns facade

func (*Facade) Create

func (f *Facade) Create(destinationNs string) error

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

func (*Facade) Delete

func (f *Facade) Delete(destinationNs string) error

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

func (*Facade) Exist

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

Exist check if ServiceBroker exists.

type MigrationService

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

MigrationService performs migration from old setup - one service per servicebroker to current solution

func NewMigrationService

func NewMigrationService(serviceInterface typedCorev1.ServicesGetter, brokerGetter scbeta.ServiceBrokersGetter, workingNamespace, serviceName string, log logrus.FieldLogger) (*MigrationService, error)

NewMigrationService creates new MigrationService instance

func (*MigrationService) Migrate

func (s *MigrationService) Migrate()

Migrate performs the migration