sbproxy

Documentation

Index

• Constants
• func DefaultEnv(additionalPFlags ...func(set *pflag.FlagSet)) env.Environment
• type ReconcileBrokersTask
  • func NewTask(ctx context.Context, group *sync.WaitGroup, platformClient platform.Client, ...) *ReconcileBrokersTask
  • func (r ReconcileBrokersTask) Run()
• type SMProxy
  • func (p *SMProxy) Run()
• type SMProxyBuilder
  • func New(ctx context.Context, env env.Environment, client platform.Client) *SMProxyBuilder
  • func (smb *SMProxyBuilder) Build() *SMProxy

Constants

const (
	// BrokerPathParam for the broker id
	BrokerPathParam = "brokerID"

	// APIPrefix for the Proxy OSB API
	APIPrefix = "/v1/osb"

	// Path for the Proxy OSB API
	Path = APIPrefix + "/{" + BrokerPathParam + "}"
)

const ProxyBrokerPrefix = "sm-proxy-"

ProxyBrokerPrefix prefixes names of brokers registered at the platform

Functions

func DefaultEnv

func DefaultEnv(additionalPFlags ...func(set *pflag.FlagSet)) env.Environment

DefaultEnv creates a default environment that can be used to boot up a Service Manager

Types

type ReconcileBrokersTask

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

ReconcileBrokersTask type represents a registration task that takes care of propagating broker creations and deletions to the platform. It reconciles the state of the proxy brokers in the platform to match the desired state provided by the Service Manager. TODO if the reg credentials are changed (the ones under cf.reg) we need to update the already registered brokers

func NewTask

func NewTask(ctx context.Context, group *sync.WaitGroup, platformClient platform.Client, smClient sm.Client, proxyPath string) *ReconcileBrokersTask

NewTask builds a new ReconcileBrokersTask

func (ReconcileBrokersTask) Run

func (r ReconcileBrokersTask) Run()

Run executes the registration task that is responsible for reconciling the state of the proxy brokers at the platform with the brokers provided by the Service Manager

type SMProxy

type SMProxy struct {
	*server.Server
	// contains filtered or unexported fields
}

SMProxy struct

func (*SMProxy) Run

func (p *SMProxy) Run()

Run starts the proxy

type SMProxyBuilder

type SMProxyBuilder struct {
	*web.API
	*cron.Cron
	// contains filtered or unexported fields
}

SMProxyBuilder type is an extension point that allows adding additional filters, plugins and controllers before running SMProxy.

func New

func New(ctx context.Context, env env.Environment, client platform.Client) *SMProxyBuilder

New creates service broker proxy that is configured from the provided environment and platform client.

func (*SMProxyBuilder) Build

func (smb *SMProxyBuilder) Build() *SMProxy

Build builds the Service Manager