Documentation ¶
Index ¶
- Variables
- func NewAzServiceBusBuilder() (asbc *azServiceBusBuilder)
- func NewCloudEvent(ctx context.Context, eventType services.EventType, source, subject string, ...) (cloudevent []byte, err error)
- type ServiceBrokerBuilderInterface
- type ServiceBrokerConfig
- func (sc *ServiceBrokerConfig) GetBrokerType() string
- func (sc *ServiceBrokerConfig) GetBrokerTypeModel() ServiceBrokerType
- func (sc *ServiceBrokerConfig) GetClient() ServiceBrokerClientInterface
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ServiceBrokerTypeList = []ServiceBrokerType{ SERVICEBROKERTYPE_UNDEFINED, SERVICEBROKERTYPE_PUBSUB, SERVICEBROKERTYPE_SERVICEBUS, }
The list that can be iterated
Functions ¶
func NewAzServiceBusBuilder ¶
func NewAzServiceBusBuilder() (asbc *azServiceBusBuilder)
Types ¶
type ServiceBrokerBuilderInterface ¶
type ServiceBrokerBuilderInterface interface { PrepareFoundation(ctx context.Context, defaults *configV2.BrokerDefaults, cfg *configV2.ServiceConfig) (err error) RemoveFoundation(ctx context.Context, defaults *configV2.BrokerDefaults, cfg *configV2.ServiceConfig) (err error) QueryFoundation(ctx context.Context, defaults *configV2.BrokerDefaults, cfg *configV2.ServiceConfig) (err error) Connect(ctx context.Context, cfg *configV2.ServiceConfig, topicID string) error CreateTopic(ctx context.Context, topicName string) (err error) DeleteTopic(ctx context.Context, topicName string) (err error) CreateSubscription(ctx context.Context, subID, topicName string, ackDeadline time.Duration) (err error) CreateSubscriptionWithDeadLetter(ctx context.Context, subID, topicName, DLTopicID string, ackDeadline time.Duration, maxDeliveryAttempts int) (err error) DeleteSubscription(ctx context.Context, subID string) (err error) GetTopics(ctx context.Context) ([]string, error) GetSubscriptions(ctx context.Context, subID, topicID string) ([]string, error) }
type ServiceBrokerConfig ¶
type ServiceBrokerConfig struct {
// contains filtered or unexported fields
}
func NewServiceBrokerConfig ¶
func NewServiceBrokerConfig(brokerType ServiceBrokerType, topic, subscription, cloudeventDomain string, hasDeadletter bool) *ServiceBrokerConfig
func (*ServiceBrokerConfig) GetBrokerType ¶
func (sc *ServiceBrokerConfig) GetBrokerType() string
func (*ServiceBrokerConfig) GetBrokerTypeModel ¶
func (sc *ServiceBrokerConfig) GetBrokerTypeModel() ServiceBrokerType
func (*ServiceBrokerConfig) GetClient ¶
func (sc *ServiceBrokerConfig) GetClient() ServiceBrokerClientInterface
func (*ServiceBrokerConfig) GetCloudeventDomain ¶
func (sc *ServiceBrokerConfig) GetCloudeventDomain() (s string)
func (*ServiceBrokerConfig) HasDeadletter ¶
func (sc *ServiceBrokerConfig) HasDeadletter(b bool)
func (*ServiceBrokerConfig) IsValidBrokerType ¶
func (sc *ServiceBrokerConfig) IsValidBrokerType() bool
func (*ServiceBrokerConfig) SetBrokerType ¶
func (sc *ServiceBrokerConfig) SetBrokerType(s string)
func (*ServiceBrokerConfig) SetCloudEventDomain ¶
func (sc *ServiceBrokerConfig) SetCloudEventDomain(s string)
func (*ServiceBrokerConfig) SetConnectionString ¶
func (sc *ServiceBrokerConfig) SetConnectionString(s string)
func (*ServiceBrokerConfig) SetGCPProjectID ¶
func (sc *ServiceBrokerConfig) SetGCPProjectID(s string)
func (*ServiceBrokerConfig) SetSubscription ¶
func (sc *ServiceBrokerConfig) SetSubscription(s string)
func (*ServiceBrokerConfig) SetTopic ¶
func (sc *ServiceBrokerConfig) SetTopic(s string)
type ServiceBrokerType ¶
type ServiceBrokerType int
const ( SERVICEBROKERTYPE_UNDEFINED ServiceBrokerType = iota SERVICEBROKERTYPE_PUBSUB SERVICEBROKERTYPE_SERVICEBUS )
func GetServiceBrokerType ¶
func GetServiceBrokerType(serviceBrokerName string) ServiceBrokerType
func (ServiceBrokerType) Cloud ¶
func (d ServiceBrokerType) Cloud() clouds.CloudType
func (ServiceBrokerType) String ¶
func (d ServiceBrokerType) String() string
func (ServiceBrokerType) Type ¶
func (d ServiceBrokerType) Type() string
Click to show internal directories.
Click to hide internal directories.