brokers

package

v0.0.1 Latest Latest Go to latest Published: Nov 2, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/arterial-multicloud/builder

Documentation ¶

Index ¶

Variables
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
type ServiceBrokerConfig
- func NewServiceBrokerConfig(brokerType ServiceBrokerType, topic, subscription, cloudeventDomain string, ...) *ServiceBrokerConfig
type ServiceBrokerType
- func GetServiceBrokerType(serviceBrokerName string) 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)

func NewCloudEvent ¶

func NewCloudEvent(ctx context.Context, eventType services.EventType, source, subject string, payload []byte) (cloudevent []byte, err error)

func NewGcpPubSubBuilder ¶

func NewGcpPubSubBuilder() (spb *gcpPubSubBuilder)

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, topicId, 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) 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)

func (*ServiceBrokerConfig) Validate ¶

func (sc *ServiceBrokerConfig) Validate(ctx context.Context) (errorString 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) NewBuilder ¶

func (d ServiceBrokerType) NewBuilder() ServiceBrokerBuilderInterface

func (ServiceBrokerType) String ¶

func (d ServiceBrokerType) String() string

func (ServiceBrokerType) Type ¶

func (d ServiceBrokerType) Type() string

Source Files ¶

View all Source files

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