queue

package

v0.1.2 Latest Latest Go to latest Published: May 8, 2019 License: Apache-2.0 Imports: 13 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/huaweicloud/huaweicloud-service-broker

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type BindingCredential
- func BuildBindingCredential(endpointname string, endpointport string, region string, projectid string, ...) (BindingCredential, error)
type DMSBroker
type MetadataParameters
type ProvisionParameters
- func (f *ProvisionParameters) MarshalJSON() ([]byte, error)
- func (f *ProvisionParameters) UnmarshalJSON(b []byte) error

Constants ¶

View Source

const (
	// ProtocolTypeHTTPS for HTTPS
	ProtocolTypeHTTPS string = "HTTPS"
	// ProtocolTypeTCP for TCP
	ProtocolTypeTCP string = "TCP"
	// AddtionalParamRequest for request
	AddtionalParamRequest string = "request"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BindingCredential ¶

type BindingCredential struct {
	Region       string `json:"region,omitempty"`
	ProjectID    string `json:"projectid,omitempty"`
	ProtocolType string `json:"protocoltype,omitempty"`
	URL          string `json:"url,omitempty"`
	AK           string `json:"ak,omitempty"`
	SK           string `json:"sk,omitempty"`
	QueueID      string `json:"queueid,omitempty"`
	GroupID      string `json:"groupid,omitempty"`
	Type         string `json:"type,omitempty"`
}

BindingCredential represent dms binding credential

func BuildBindingCredential ¶

func BuildBindingCredential(
	endpointname string,
	endpointport string,
	region string,
	projectid string,
	url string,
	ak string,
	sk string,
	queueid string,
	groupid string,
	servicetype string) (BindingCredential, error)

BuildBindingCredential from different dms instance

type DMSBroker ¶

type DMSBroker struct {
	CloudCredentials config.CloudCredentials
	Catalog          config.Catalog
	Logger           lager.Logger
}

DMSBroker define

func (*DMSBroker) Bind ¶

func (b *DMSBroker) Bind(instanceID, bindingID string, details brokerapi.BindDetails) (brokerapi.Binding, error)

Bind implematation

func (*DMSBroker) Deprovision ¶

func (b *DMSBroker) Deprovision(instanceID string, details brokerapi.DeprovisionDetails, asyncAllowed bool) (brokerapi.DeprovisionServiceSpec, error)

Deprovision implematation

func (*DMSBroker) GetPlanSchemas ¶ added in v0.1.2

func (b *DMSBroker) GetPlanSchemas(serviceID string, planID string, metadata *brokerapi.ServicePlanMetadata) (*brokerapi.PlanSchemas, error)

GetPlanSchemas implematation

func (*DMSBroker) LastOperation ¶

func (b *DMSBroker) LastOperation(instanceID string, operationData database.OperationDetails) (brokerapi.LastOperation, error)

LastOperation implematation

func (*DMSBroker) Provision ¶

func (b *DMSBroker) Provision(instanceID string, details brokerapi.ProvisionDetails, asyncAllowed bool) (brokerapi.ProvisionedServiceSpec, error)

Provision implematation

func (*DMSBroker) Unbind ¶

func (b *DMSBroker) Unbind(instanceID, bindingID string, details brokerapi.UnbindDetails) error

Unbind implematation

func (*DMSBroker) Update ¶

func (b *DMSBroker) Update(instanceID string, details brokerapi.UpdateDetails, asyncAllowed bool) (brokerapi.UpdateServiceSpec, error)

Update implematation is not necessary for DMSStandardServiceName, DMSActiveMQServiceName and DMSKafkaServiceName

type MetadataParameters ¶

type MetadataParameters struct {
	QueueMode       string `json:"queue_mode,omitempty"`
	EndpointName    string `json:"endpoint_name,omitempty"`
	EndpointPort    string `json:"endpoint_port,omitempty"`
	RedrivePolicy   string `json:"redrive_policy,omitempty"`
	MaxConsumeCount int    `json:"max_consume_count,omitempty"`
	RetentionHours  int    `json:"retention_hours,omitempty"`
}

MetadataParameters represent plan metadata parameters in config

type ProvisionParameters ¶

type ProvisionParameters struct {
	RedrivePolicy   string                 `json:"redrive_policy,omitempty" bson:"redrive_policy,omitempty"`
	MaxConsumeCount int                    `json:"max_consume_count,omitempty" bson:"max_consume_count,omitempty"`
	RetentionHours  int                    `json:"retention_hours,omitempty" bson:"retention_hours,omitempty"`
	QueueName       string                 `json:"queue_name,omitempty" bson:"queue_name,omitempty"`
	GroupName       string                 `json:"group_name,omitempty" bson:"group_name,omitempty"`
	Description     string                 `json:"description,omitempty" bson:"description,omitempty"`
	UnknownFields   map[string]interface{} `json:"-" bson:",inline"`
}

ProvisionParameters represent provision parameters

func (*ProvisionParameters) MarshalJSON ¶ added in v0.1.1

func (f *ProvisionParameters) MarshalJSON() ([]byte, error)

func (*ProvisionParameters) UnmarshalJSON ¶ added in v0.1.1

func (f *ProvisionParameters) UnmarshalJSON(b []byte) error

Collect unknown fields into "UnknownFields"

Source Files ¶

View all Source files

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