broker

package

Go to main page

Versions in this module

v1

v1.0.4

Oct 6, 2021

Changes in this version

+ type MetricsCollector struct

+ Actions *prom.CounterVec

+ func NewMetricsCollector() *MetricsCollector

+ func (c *MetricsCollector) Collect(ch chan<- prom.Metric)

+ func (c *MetricsCollector) Describe(ch chan<- *prom.Desc)

v1.0.3

Mar 29, 2021

Changes in this version

+ func AwsLambdaClientGetter(sess *session.Session) lambdaiface.LambdaAPI

type AwsClients

+ NewLambda GetLambdaClient

+ type CfnCost struct

+ Amount map[string]float64

+ Unit string

+ type CfnServicePlan struct

+ Cost string

+ Costs []CfnCost

+ Description string

+ DisplayName string

+ LongDescription string

+ ParameterDefaults map[string]string

+ ParameterValues map[string]string

+ type GetLambdaClient func(sess *session.Session) lambdaiface.LambdaAPI

v1.0.2

Jun 22, 2020

v1.0.1

May 31, 2019

v1.0.0

Feb 27, 2019

Changes in this version

+ var CacheTTL = 1 * time.Hour

+ func AddFlags(o *Options)

+ func AwsDdbClientGetter(sess *session.Session) *dynamodb.DynamoDB

+ func AwsIamClientGetter(sess *session.Session) iamiface.IAMAPI

+ func AwsSessionGetter(keyid string, secretkey string, region string, accountId string, ...) *session.Session

+ func AwsSsmClientGetter(sess *session.Session) ssmiface.SSMAPI

+ func AwsStsClientGetter(sess *session.Session) *sts.STS

+ func GetCallerId(svc stsiface.STSAPI) (*sts.GetCallerIdentityOutput, error)

+ func ListTemplates(s3source *BucketDetailsRequest, b *AwsBroker) (*[]ServiceLastUpdate, error)

+ func ListingUpdate(l *[]ServiceLastUpdate, c cache.Cache) error

+ func MetadataUpdate(l cache.Cache, c cache.Cache, bd BucketDetailsRequest, s3svc S3Client, db Db, ...) error

+ func PollUpdate(interval int, l cache.Cache, c cache.Cache, bd BucketDetailsRequest, ...)

+ func UpdateCatalog(listingcache cache.Cache, catalogcache cache.Cache, bd BucketDetailsRequest, ...) error

+ type AwsBroker struct

+ Clients AwsClients

+ GetSession GetAwsSession

+ func NewAWSBroker(o Options, awssess GetAwsSession, clients AwsClients, ...) (*AwsBroker, error)

+ func (b *AwsBroker) Bind(request *osb.BindRequest, c *broker.RequestContext) (*broker.BindResponse, error)

+ func (b *AwsBroker) BindingLastOperation(request *osb.BindingLastOperationRequest, c *broker.RequestContext) (*broker.LastOperationResponse, error)

+ func (b *AwsBroker) Deprovision(request *osb.DeprovisionRequest, c *broker.RequestContext) (*broker.DeprovisionResponse, error)

+ func (b *AwsBroker) GetBinding(request *osb.GetBindingRequest, c *broker.RequestContext) (*broker.GetBindingResponse, error)

+ func (b *AwsBroker) GetCatalog(c *broker.RequestContext) (*broker.CatalogResponse, error)

+ func (b *AwsBroker) LastOperation(request *osb.LastOperationRequest, c *broker.RequestContext) (*broker.LastOperationResponse, error)

+ func (b *AwsBroker) Provision(request *osb.ProvisionRequest, c *broker.RequestContext) (*broker.ProvisionResponse, error)

+ func (b *AwsBroker) Unbind(request *osb.UnbindRequest, c *broker.RequestContext) (*broker.UnbindResponse, error)

+ func (b *AwsBroker) Update(request *osb.UpdateInstanceRequest, c *broker.RequestContext) (*broker.UpdateInstanceResponse, error)

+ func (b *AwsBroker) ValidateBrokerAPIVersion(version string) error

+ type AwsClients struct

+ NewCfn GetCfnClient

+ NewDdb GetDdbClient

+ NewIam GetIamClient

+ NewS3 GetS3Client

+ NewSsm GetSsmClient

+ NewSts GetStsClient

+ type AwsTags []struct

+ type BucketDetailsRequest struct

+ type CfnClient struct

+ Client cloudformationiface.CloudFormationAPI

+ func AwsCfnClientGetter(sess *session.Session) CfnClient

+ type CfnTemplate struct

+ Description string

+ Metadata struct{ ... }

+ Outputs map[string]struct{ ... }

+ Parameters map[string]struct{ ... }

+ type DataStore interface

+ DeleteServiceBinding func(id string) error

+ DeleteServiceInstance func(sid string) error

+ GetParam func(paramname string) (value string, err error)

+ GetServiceBinding func(id string) (*serviceinstance.ServiceBinding, error)

+ GetServiceDefinition func(serviceuuid string) (*osb.Service, error)

+ GetServiceInstance func(sid string) (*serviceinstance.ServiceInstance, error)

+ PutParam func(paramname string, paramvalue string) error

+ PutServiceBinding func(sb serviceinstance.ServiceBinding) error

+ PutServiceDefinition func(sd osb.Service) error

+ PutServiceInstance func(si serviceinstance.ServiceInstance) error

+ type Db struct

+ Accountid string

+ Accountuuid uuid.UUID

+ Brokerid string

+ DataStorePort DataStore

+ func (db Db) ServiceDefinitionToOsb(sd CfnTemplate) osb.Service

+ type GetAwsSession func(keyid string, secretkey string, region string, accountId string, ...) *session.Session

+ type GetCallerIder func(svc stsiface.STSAPI) (*sts.GetCallerIdentityOutput, error)

+ type GetCfnClient func(sess *session.Session) CfnClient

+ type GetDdbClient func(sess *session.Session) *dynamodb.DynamoDB

+ type GetIamClient func(sess *session.Session) iamiface.IAMAPI

+ type GetS3Client func(sess *session.Session) S3Client

+ type GetSsmClient func(sess *session.Session) ssmiface.SSMAPI

+ type GetStsClient func(sess *session.Session) *sts.STS

+ type ListTemplateser func(s3source *BucketDetailsRequest, b *AwsBroker) (*[]ServiceLastUpdate, error)

+ type ListingUpdater func(l *[]ServiceLastUpdate, c cache.Cache) error

+ type MetadataUpdater func(l cache.Cache, c cache.Cache, bd BucketDetailsRequest, s3svc S3Client, db Db, ...) error

+ type OpenshiftFormDefinition struct

+ Items []string

+ Title string

+ Type string

+ type Options struct

+ BrokerID string

+ CatalogPath string

+ KeyID string

+ PrescribeOverrides bool

+ Profile string

+ Region string

+ RoleArn string

+ S3Bucket string

+ S3Key string

+ S3Region string

+ SecretKey string

+ TableName string

+ TemplateFilter string

+ type PollUpdater func(interval int, l cache.Cache, c cache.Cache, bd BucketDetailsRequest, ...)

+ type S3Client struct

+ Client s3iface.S3API

+ func AwsS3ClientGetter(sess *session.Session) S3Client

+ type ServiceLastUpdate struct

+ Date time.Time

+ Name string

+ type ServiceNeedsUpdate struct

+ Name string

+ Update bool

+ type UpdateCataloger func(listingcache cache.Cache, catalogcache cache.Cache, bd BucketDetailsRequest, ...) error

v1.0.0-beta.4

Feb 27, 2019

v1.0.0-beta.3

Nov 8, 2018

v1.0.0-beta.2

Oct 3, 2018

v1.0.0-beta

Sep 20, 2018

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