broker

Documentation

Index

• func PrepareCluster(config *config.Config, cluster k8s.Cluster, helmClient my_helm.MyHelmClient, ...) error
• func PrepareDefaultCluster(config *config.Config, clusterFactory k8s.ClusterFactory, ...) error
• type PksServiceBroker
  • func NewPksServiceBroker(config *config.Config, clusterFactory k8s.ClusterFactory, ...) *PksServiceBroker
  • func (broker *PksServiceBroker) Bind(ctx context.Context, instanceID, bindingID string, ...) (brokerapi.Binding, error)
  • func (broker *PksServiceBroker) Deprovision(ctx context.Context, instanceID string, details brokerapi.DeprovisionDetails, ...) (brokerapi.DeprovisionServiceSpec, error)
  • func (broker *PksServiceBroker) FlushRepoChartCache() error
  • func (broker *PksServiceBroker) GetBinding(ctx context.Context, instanceID, bindingID string) (brokerapi.GetBindingSpec, error)
  • func (broker *PksServiceBroker) GetChartsMap() (map[string]*my_helm.MyChart, error)
  • func (broker *PksServiceBroker) GetInstance(context context.Context, instanceID string) (brokerapi.GetInstanceDetailsSpec, error)
  • func (broker *PksServiceBroker) LastBindingOperation(ctx context.Context, instanceID, bindingID string, ...) (brokerapi.LastOperation, error)
  • func (broker *PksServiceBroker) LastOperation(ctx context.Context, instanceID string, details brokerapi.PollDetails) (brokerapi.LastOperation, error)
  • func (broker *PksServiceBroker) Provision(ctx context.Context, instanceID string, details brokerapi.ProvisionDetails, ...) (brokerapi.ProvisionedServiceSpec, error)
  • func (broker *PksServiceBroker) Services(ctx context.Context) ([]brokerapi.Service, error)
  • func (broker *PksServiceBroker) Unbind(ctx context.Context, instanceID, bindingID string, ...) (brokerapi.UnbindSpec, error)
  • func (broker *PksServiceBroker) Update(ctx context.Context, instanceID string, details brokerapi.UpdateDetails, ...) (brokerapi.UpdateServiceSpec, error)

Functions

func PrepareCluster

func PrepareCluster(config *config.Config, cluster k8s.Cluster, helmClient my_helm.MyHelmClient, serviceAccountInstaller k8s.ServiceAccountInstaller, installerFactory my_helm.InstallerFactory, operators []*my_helm.MyChart, logger *logrus.Logger) error

func PrepareDefaultCluster

func PrepareDefaultCluster(
	config *config.Config,
	clusterFactory k8s.ClusterFactory,
	helmClientFactory my_helm.HelmClientFactory,
	serviceAccountInstallerFactory k8s.ServiceAccountInstallerFactory,
	installerFactory my_helm.InstallerFactory,
	logger *logrus.Logger,
	operators []*my_helm.MyChart,
) error

Types

type PksServiceBroker

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

func NewPksServiceBroker

func NewPksServiceBroker(
	config *config.Config, clusterFactory k8s.ClusterFactory, helmClientFactory my_helm.HelmClientFactory,
	serviceAccountInstallerFactory k8s.ServiceAccountInstallerFactory, helmInstallerFactory my_helm.InstallerFactory,
	repo repository.Repository, cs credstore.CredStore, operators []*my_helm.MyChart, logger *logrus.Logger,
) *PksServiceBroker

func (*PksServiceBroker) Bind

func (broker *PksServiceBroker) Bind(ctx context.Context, instanceID, bindingID string, details brokerapi.BindDetails, asyncAllowed bool) (brokerapi.Binding, error)

func (*PksServiceBroker) Deprovision

func (broker *PksServiceBroker) Deprovision(ctx context.Context, instanceID string, details brokerapi.DeprovisionDetails, asyncAllowed bool) (brokerapi.DeprovisionServiceSpec, error)

func (*PksServiceBroker) FlushRepoChartCache

func (broker *PksServiceBroker) FlushRepoChartCache() error

func (*PksServiceBroker) GetBinding

func (broker *PksServiceBroker) GetBinding(ctx context.Context, instanceID, bindingID string) (brokerapi.GetBindingSpec, error)

func (*PksServiceBroker) GetChartsMap

func (broker *PksServiceBroker) GetChartsMap() (map[string]*my_helm.MyChart, error)

func (*PksServiceBroker) GetInstance

func (broker *PksServiceBroker) GetInstance(context context.Context, instanceID string) (brokerapi.GetInstanceDetailsSpec, error)

func (*PksServiceBroker) LastBindingOperation

func (broker *PksServiceBroker) LastBindingOperation(ctx context.Context, instanceID, bindingID string, details brokerapi.PollDetails) (brokerapi.LastOperation, error)

func (*PksServiceBroker) LastOperation

func (broker *PksServiceBroker) LastOperation(ctx context.Context, instanceID string, details brokerapi.PollDetails) (brokerapi.LastOperation, error)

func (*PksServiceBroker) Provision

func (broker *PksServiceBroker) Provision(ctx context.Context, instanceID string, details brokerapi.ProvisionDetails, asyncAllowed bool) (brokerapi.ProvisionedServiceSpec, error)

func (*PksServiceBroker) Services

func (broker *PksServiceBroker) Services(ctx context.Context) ([]brokerapi.Service, error)

func (*PksServiceBroker) Unbind

func (broker *PksServiceBroker) Unbind(ctx context.Context, instanceID, bindingID string, details brokerapi.UnbindDetails, asyncAllowed bool) (brokerapi.UnbindSpec, error)

func (*PksServiceBroker) Update

func (broker *PksServiceBroker) Update(ctx context.Context, instanceID string, details brokerapi.UpdateDetails, asyncAllowed bool) (brokerapi.UpdateServiceSpec, error)