Versions in this module Expand all Collapse all v0 v0.0.1 Nov 2, 2021 Changes in this version + var ServiceBrokerTypeList = []ServiceBrokerType + func NewAzServiceBusBuilder() (asbc *azServiceBusBuilder) + func NewCloudEvent(ctx context.Context, eventType services.EventType, source, subject string, ...) (cloudevent []byte, err error) + func NewGcpPubSubBuilder() (spb *gcpPubSubBuilder) + type ServiceBrokerBuilderInterface interface + Connect func(ctx context.Context, cfg *configV2.ServiceConfig, topicID string) error + CreateSubscription func(ctx context.Context, subID, topicName string, ackDeadline time.Duration) (err error) + CreateSubscriptionWithDeadLetter func(ctx context.Context, subID, topicName, DLTopicID string, ...) (err error) + CreateTopic func(ctx context.Context, topicName string) (err error) + DeleteSubscription func(ctx context.Context, topicId, subID string) (err error) + DeleteTopic func(ctx context.Context, topicName string) (err error) + GetSubscriptions func(ctx context.Context, subID, topicID string) ([]string, error) + GetTopics func(ctx context.Context) ([]string, error) + PrepareFoundation func(ctx context.Context, defaults *configV2.BrokerDefaults, ...) (err error) + QueryFoundation func(ctx context.Context, defaults *configV2.BrokerDefaults, ...) (err error) + RemoveFoundation func(ctx context.Context, defaults *configV2.BrokerDefaults, ...) (err error) + type ServiceBrokerConfig struct + func NewServiceBrokerConfig(brokerType ServiceBrokerType, topic, subscription, cloudeventDomain string, ...) *ServiceBrokerConfig + func (sc *ServiceBrokerConfig) GetBrokerType() string + func (sc *ServiceBrokerConfig) GetBrokerTypeModel() ServiceBrokerType + func (sc *ServiceBrokerConfig) GetCloudeventDomain() (s string) + func (sc *ServiceBrokerConfig) HasDeadletter(b bool) + func (sc *ServiceBrokerConfig) IsValidBrokerType() bool + func (sc *ServiceBrokerConfig) SetBrokerType(s string) + func (sc *ServiceBrokerConfig) SetCloudEventDomain(s string) + func (sc *ServiceBrokerConfig) SetConnectionString(s string) + func (sc *ServiceBrokerConfig) SetGCPProjectID(s string) + func (sc *ServiceBrokerConfig) SetSubscription(s string) + func (sc *ServiceBrokerConfig) SetTopic(s string) + func (sc *ServiceBrokerConfig) Validate(ctx context.Context) (errorString string) + type ServiceBrokerType int + const SERVICEBROKERTYPE_PUBSUB + const SERVICEBROKERTYPE_SERVICEBUS + const SERVICEBROKERTYPE_UNDEFINED + func GetServiceBrokerType(serviceBrokerName string) ServiceBrokerType + func (d ServiceBrokerType) Cloud() clouds.CloudType + func (d ServiceBrokerType) NewBuilder() ServiceBrokerBuilderInterface + func (d ServiceBrokerType) String() string + func (d ServiceBrokerType) Type() string