broker

package

v0.2.50 Latest Latest Go to latest Published: Dec 4, 2019 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cf-platform-eng/kibosh

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL