queue

Documentation

Index

• Constants
• type BindingCredential
  • func BuildBindingCredential(endpointname string, endpointport string, region string, projectid string, ...) (BindingCredential, error)
• type DMSBroker
  • func (b *DMSBroker) Bind(instanceID, bindingID string, details brokerapi.BindDetails) (brokerapi.Binding, error)
  • func (b *DMSBroker) Deprovision(instanceID string, details brokerapi.DeprovisionDetails, asyncAllowed bool) (brokerapi.DeprovisionServiceSpec, error)
  • func (b *DMSBroker) GetPlanSchemas(serviceID string, planID string, metadata *brokerapi.ServicePlanMetadata) (*brokerapi.PlanSchemas, error)
  • func (b *DMSBroker) LastOperation(instanceID string, operationData database.OperationDetails) (brokerapi.LastOperation, error)
  • func (b *DMSBroker) Provision(instanceID string, details brokerapi.ProvisionDetails, asyncAllowed bool) (brokerapi.ProvisionedServiceSpec, error)
  • func (b *DMSBroker) Unbind(instanceID, bindingID string, details brokerapi.UnbindDetails) error
  • func (b *DMSBroker) Update(instanceID string, details brokerapi.UpdateDetails, asyncAllowed bool) (brokerapi.UpdateServiceSpec, error)
• type MetadataParameters
• type ProvisionParameters
  • func (f *ProvisionParameters) MarshalJSON() ([]byte, error)
  • func (f *ProvisionParameters) UnmarshalJSON(b []byte) error

Constants

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

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

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

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

func (*ProvisionParameters) UnmarshalJSON

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

Collect unknown fields into "UnknownFields"