broker

Documentation

Index

• func IsNotFoundError(err error) bool
• func RunTLS(ctx context.Context, addr string, cert string, key string) error
• type BindParametersDTO
  • func (params *BindParametersDTO) Validate() error
• type BindSuccessResponseDTO
• type CatalogSuccessResponseDTO
• type ClusterServiceBrokerSync
  • func NewClusterServiceBrokerSyncer(csbInterface v1beta12.ClusterServiceBrokerInterface, log logrus.FieldLogger) *ClusterServiceBrokerSync
  • func (r *ClusterServiceBrokerSync) Sync(name string, maxSyncRetries int) error
• type DeprovisionSuccessResponseDTO
• type LastOperationSuccessResponseDTO
• type OSBContextMiddleware
  • func (OSBContextMiddleware) ServeHTTP(rw http.ResponseWriter, r *http.Request, next http.HandlerFunc)
• type OsbContext
• type ProvisionRequestDTO
  • func (params *ProvisionRequestDTO) Validate() error
• type ProvisionSuccessResponseDTO
• type RequireAsyncMiddleware
  • func (RequireAsyncMiddleware) ServeHTTP(rw http.ResponseWriter, r *http.Request, next http.HandlerFunc)
• type Server
  • func New(bs bundleStorage, cs chartStorage, os operationStorage, is instanceStorage, ...) *Server
  • func (srv *Server) Addr() string
  • func (srv *Server) Run(ctx context.Context, addr string, startedCh chan struct{}) error

Functions

func IsNotFoundError

func IsNotFoundError(err error) bool

IsNotFoundError check if error is NotFound one.

func RunTLS

func RunTLS(ctx context.Context, addr string, cert string, key string) error

RunTLS is starting TLS server

Types

type BindParametersDTO

type BindParametersDTO struct {
	ServiceID string `json:"service_id"`
	PlanID    string `json:"plan_id"`
}

BindParametersDTO contains parameters sent by Service Catalog in the body of bind request.

func (*BindParametersDTO) Validate

func (params *BindParametersDTO) Validate() error

Validate checks if bind parameters aren't empty

type BindSuccessResponseDTO

type BindSuccessResponseDTO struct {
	// Credentials is a free-form hash of credentials that can be used by
	// applications or users to access the service.
	Credentials map[string]interface{} `json:"credentials,omitempty"`
}

BindSuccessResponseDTO represents response with credentials for service instance after successful binding

type CatalogSuccessResponseDTO

type CatalogSuccessResponseDTO struct{}

CatalogSuccessResponseDTO represents info about successful catalog response TODO: implement me based on osb.CatalogResponse

type ClusterServiceBrokerSync

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

ClusterServiceBrokerSync provide services to sync the ClusterServiceBroker

func NewClusterServiceBrokerSyncer

func NewClusterServiceBrokerSyncer(csbInterface v1beta12.ClusterServiceBrokerInterface, log logrus.FieldLogger) *ClusterServiceBrokerSync

NewClusterServiceBrokerSyncer allows to sync the ServiceBroker.

func (*ClusterServiceBrokerSync) Sync

func (r *ClusterServiceBrokerSync) Sync(name string, maxSyncRetries int) error

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

type DeprovisionSuccessResponseDTO

type DeprovisionSuccessResponseDTO struct {
	Operation *internal.OperationID `json:"operation,omitempty"`
}

DeprovisionSuccessResponseDTO represents response after successful deprovisioning

type LastOperationSuccessResponseDTO

type LastOperationSuccessResponseDTO struct {
	State       internal.OperationState `json:"state"`
	Description *string                 `json:"description,omitempty"`
}

LastOperationSuccessResponseDTO represents info response about last successful operation

type OSBContextMiddleware

type OSBContextMiddleware struct{}

OSBContextMiddleware implements Handler interface

func (OSBContextMiddleware) ServeHTTP

func (OSBContextMiddleware) ServeHTTP(rw http.ResponseWriter, r *http.Request, next http.HandlerFunc)

ServeHTTP adds content of Open Service Broker Api headers to the requests

type OsbContext

type OsbContext struct {
	APIVersion          string
	OriginatingIdentity string
}

OsbContext contains data sent in X-Broker-API-Version and X-Broker-API-Originating-Identity HTTP headers.

type ProvisionRequestDTO

type ProvisionRequestDTO struct {
	ServiceID        internal.ServiceID     `json:"service_id"`
	PlanID           internal.ServicePlanID `json:"plan_id"`
	OrganizationGUID string                 `json:"organization_guid"`
	SpaceGUID        string                 `json:"space_guid"`
	Parameters       map[string]interface{} `json:"parameters,omitempty"`
	Context          contextDTO             `json:"context,omitempty"`
}

ProvisionRequestDTO represents provision request

func (*ProvisionRequestDTO) Validate

func (params *ProvisionRequestDTO) Validate() error

Validate validates necessary provisioning parameters

type ProvisionSuccessResponseDTO

type ProvisionSuccessResponseDTO struct {
	DashboardURL *string               `json:"dashboard_url"`
	Operation    *internal.OperationID `json:"operation,omitempty"`
}

ProvisionSuccessResponseDTO represents response after successful provisioning

type RequireAsyncMiddleware

type RequireAsyncMiddleware struct{}

RequireAsyncMiddleware asserts if request allows for asynchronous response

func (RequireAsyncMiddleware) ServeHTTP

func (RequireAsyncMiddleware) ServeHTTP(rw http.ResponseWriter, r *http.Request, next http.HandlerFunc)

ServeHTTP handling asynchronous HTTP requests in Open Service Broker Api

type Server

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

Server implements HTTP server used to serve OSB API for helm broker.

func New

func New(bs bundleStorage, cs chartStorage, os operationStorage, is instanceStorage, ibd instanceBindDataStorage,
	bindTmplRenderer bindTemplateRenderer, bindTmplResolver bindTemplateResolver, hc helmClient, syncer syncer, log *logrus.Entry) *Server

New creates instance of broker.

func (*Server) Addr

func (srv *Server) Addr() string

Addr returns address server is listening on. Its use is targeted for cases when address is not known, e.g. tests.

func (*Server) Run

func (srv *Server) Run(ctx context.Context, addr string, startedCh chan struct{}) error

Run is starting HTTP server