api

package
v1.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 3, 2023 License: MPL-2.0 Imports: 9 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DefaultFirewallSettings 

func DefaultFirewallSettings() map[string]interface{}

Types

type API 

type API struct {
	// contains filtered or unexported fields
}

func New 

func New(baseUrl, apiKey string, useragent string) *API

func (*API) AcceptVpcPeering 

func (api *API) AcceptVpcPeering(instanceID int, peeringID string, sleep, timeout int) (map[string]interface{}, error)

func (*API) AcceptVpcPeeringWithVpcId added in v1.6.0 

func (api *API) AcceptVpcPeeringWithVpcId(vpcID, peeringID string, sleep, timeout int) (map[string]interface{}, error)

func (*API) CreateAlarm 

func (api *API) CreateAlarm(instanceID int, params map[string]interface{}) (map[string]interface{}, error)

func (*API) CreateAwsEventBridge added in v1.11.0 

func (api *API) CreateAwsEventBridge(instanceID int, params map[string]interface{}) (map[string]interface{}, error)

func (*API) CreateCustomDomain added in v1.5.0 

func (api *API) CreateCustomDomain(instanceID int, hostname string) (map[string]interface{}, error)

func (*API) CreateFirewallSettings 

func (api *API) CreateFirewallSettings(instanceID int, params []map[string]interface{}, sleep,
	timeout int) ([]map[string]interface{}, error)

func (*API) CreateInstance 

func (api *API) CreateInstance(params map[string]interface{}) (map[string]interface{}, error)

func (*API) CreateIntegration added in v1.3.0 

func (api *API) CreateIntegration(instanceID int, intType string, intName string, params map[string]interface{}) (map[string]interface{}, error)

CreateIntegration enables integration communication, either for logs or metrics.

func (*API) CreateNotification 

func (api *API) CreateNotification(instanceID int, params map[string]interface{}) (map[string]interface{}, error)

func (*API) CreateVpcInstance added in v1.6.0 

func (api *API) CreateVpcInstance(params map[string]interface{}) (map[string]interface{}, error)

func (*API) CreateWebhook added in v1.3.4 

func (api *API) CreateWebhook(instanceID int, params map[string]interface{}) (map[string]interface{}, error)

CreateWebhook - create a webhook for a vhost and a specific qeueu

func (*API) DefaultRmqVersion 

func (api *API) DefaultRmqVersion() (map[string]interface{}, error)

func (*API) DeleteAlarm 

func (api *API) DeleteAlarm(instanceID int, params map[string]interface{}) error

func (*API) DeleteAwsEventBridge added in v1.11.0 

func (api *API) DeleteAwsEventBridge(instanceID int, eventbridgeID string) error

func (*API) DeleteCustomDomain added in v1.5.0 

func (api *API) DeleteCustomDomain(instanceID int) (map[string]interface{}, error)

func (*API) DeleteFirewallSettings 

func (api *API) DeleteFirewallSettings(instanceID, sleep, timeout int) ([]map[string]interface{}, error)

func (*API) DeleteInstance 

func (api *API) DeleteInstance(instanceID string, keep_vpc bool) error

func (*API) DeleteIntegration added in v1.3.0 

func (api *API) DeleteIntegration(instanceID int, intType, intID string) error

DeleteIntegration removes log or metric integration.

func (*API) DeleteNotification 

func (api *API) DeleteNotification(instanceID int, params map[string]interface{}) error

func (*API) DeletePlugin added in v1.3.2 

func (api *API) DeletePlugin(instanceID int, pluginName string) error

func (*API) DeleteRabbitMqConfiguration added in v1.8.1 

func (api *API) DeleteRabbitMqConfiguration() error

func (*API) DeleteVpcInstance added in v1.6.0 

func (api *API) DeleteVpcInstance(vpcID string) error

func (*API) DeleteWebhook added in v1.3.4 

func (api *API) DeleteWebhook(instanceID int, webhookID string) error

DeleteWebhook - removes a specific webhook for an instance

func (*API) DisablePlugin 

func (api *API) DisablePlugin(instanceID int, pluginName string) (map[string]interface{}, error)

func (*API) DisablePluginCommunity 

func (api *API) DisablePluginCommunity(instanceID int, pluginName string) (map[string]interface{}, error)
func (api *API) DisablePrivatelink(instanceID int) error

DisablePrivatelink: Disable the PrivateLink feature

func (*API) EnablePlugin 

func (api *API) EnablePlugin(instanceID int, pluginName string) (map[string]interface{}, error)

func (*API) EnablePluginCommunity 

func (api *API) EnablePluginCommunity(instanceID int, pluginName string) (map[string]interface{}, error)
func (api *API) EnablePrivatelink(instanceID int, params map[string][]interface{}, sleep, timeout int) error

EnablePrivatelink: Enable PrivateLink and wait until finished. Need to enable VPC for an instance, if no standalone VPC used. Wait until finished with configureable sleep and timeout.

func (*API) ListInstances added in v1.5.0 

func (api *API) ListInstances() ([]map[string]interface{}, error)

func (*API) ListVpcs added in v1.6.0 

func (api *API) ListVpcs() ([]map[string]interface{}, error)

func (*API) PostAction added in v1.7.0 

func (api *API) PostAction(instanceID int, nodeName string, action string) (map[string]interface{}, error)

PostAction - request an action for the node (e.g. start/stop/restart RabbitMQ)

func (*API) ReadAlarm 

func (api *API) ReadAlarm(instanceID int, alarmID string) (map[string]interface{}, error)

func (*API) ReadAlarms 

func (api *API) ReadAlarms(instanceID int) ([]map[string]interface{}, error)

func (*API) ReadAwsEventBridge added in v1.11.0 

func (api *API) ReadAwsEventBridge(instanceID int, eventbridgeID string) (map[string]interface{}, error)

func (*API) ReadAwsEventBridges added in v1.11.0 

func (api *API) ReadAwsEventBridges(instanceID int) (map[string]interface{}, error)

func (*API) ReadCredentials 

func (api *API) ReadCredentials(id int) (map[string]interface{}, error)

func (*API) ReadCustomDomain added in v1.5.0 

func (api *API) ReadCustomDomain(instanceID int) (map[string]interface{}, error)

func (*API) ReadFirewallSettings 

func (api *API) ReadFirewallSettings(instanceID int) ([]map[string]interface{}, error)

func (*API) ReadInstance 

func (api *API) ReadInstance(instanceID string) (map[string]interface{}, error)

func (*API) ReadInstances 

func (api *API) ReadInstances() ([]map[string]interface{}, error)

func (*API) ReadIntegration added in v1.3.0 

func (api *API) ReadIntegration(instanceID int, intType, intID string) (map[string]interface{}, error)

ReadIntegration retrieves a specific logs or metrics integration

func (*API) ReadNode added in v1.7.0 

func (api *API) ReadNode(instanceID int, nodeName string) (map[string]interface{}, error)

ReadNode - read out node information of a single node

func (*API) ReadNodes added in v1.3.1 

func (api *API) ReadNodes(instanceID int) ([]map[string]interface{}, error)

ReadNodes - read out node information of the cluster

func (*API) ReadNotification 

func (api *API) ReadNotification(instanceID int, recipientID string) (map[string]interface{}, error)

func (*API) ReadNotifications added in v1.1.1 

func (api *API) ReadNotifications(instanceID int) ([]map[string]interface{}, error)

func (*API) ReadPlugin 

func (api *API) ReadPlugin(instanceID int, pluginName string) (map[string]interface{}, error)

func (*API) ReadPluginCommunity 

func (api *API) ReadPluginCommunity(instanceID int, pluginName string) (map[string]interface{}, error)

func (*API) ReadPlugins 

func (api *API) ReadPlugins(instanceID int) ([]map[string]interface{}, error)

func (*API) ReadPluginsCommunity 

func (api *API) ReadPluginsCommunity(instanceID int) ([]map[string]interface{}, error)
func (api *API) ReadPrivatelink(instanceID int) (map[string]interface{}, error)

ReadPrivatelink: Reads PrivateLink information

func (*API) ReadRabbitMqConfiguration added in v1.8.1 

func (api *API) ReadRabbitMqConfiguration(instanceID, sleep, timeout int) (map[string]interface{}, error)

func (*API) ReadVersions added in v1.7.0 

func (api *API) ReadVersions(instanceID int) (map[string]interface{}, error)

ReadVersions - Read versions RabbitMQ and Erlang can upgrade to

func (*API) ReadVpcGcpInfo added in v1.5.3 

func (api *API) ReadVpcGcpInfo(instanceID int) (map[string]interface{}, error)

func (*API) ReadVpcGcpInfoWithVpcId added in v1.6.0 

func (api *API) ReadVpcGcpInfoWithVpcId(vpcID string) (map[string]interface{}, error)

func (*API) ReadVpcGcpPeering added in v1.5.3 

func (api *API) ReadVpcGcpPeering(instanceID int, peerID string) (map[string]interface{}, error)

func (*API) ReadVpcGcpPeeringWithVpcId added in v1.6.0 

func (api *API) ReadVpcGcpPeeringWithVpcId(vpcID, peerID string) (map[string]interface{}, error)

func (*API) ReadVpcInfo 

func (api *API) ReadVpcInfo(instanceID int) (map[string]interface{}, error)

func (*API) ReadVpcInfoWithVpcId added in v1.6.0 

func (api *API) ReadVpcInfoWithVpcId(vpcID string) (map[string]interface{}, error)

func (*API) ReadVpcInstance added in v1.6.0 

func (api *API) ReadVpcInstance(vpcID string) (map[string]interface{}, error)

func (*API) ReadVpcPeeringRequest 

func (api *API) ReadVpcPeeringRequest(instanceID int, peeringID string) (map[string]interface{}, error)

func (*API) ReadVpcPeeringRequestWithVpcId added in v1.6.0 

func (api *API) ReadVpcPeeringRequestWithVpcId(vpcID, peeringID string) (map[string]interface{}, error)

func (*API) ReadWebhook added in v1.3.4 

func (api *API) ReadWebhook(instanceID int, webhookID string) (map[string]interface{}, error)

ReadWebhook - retrieves a specific webhook for an instance

func (*API) ReadWebhooks added in v1.3.4 

func (api *API) ReadWebhooks(instanceID int) (map[string]interface{}, error)

ReadWebhooks - retrieves all webhooks for an instance.

func (*API) RemoveVpcGcpPeering added in v1.5.3 

func (api *API) RemoveVpcGcpPeering(instanceID int, peerID string) error

func (*API) RemoveVpcGcpPeeringWithVpcId added in v1.6.0 

func (api *API) RemoveVpcGcpPeeringWithVpcId(vpcID, peerID string) error

func (*API) RemoveVpcPeering 

func (api *API) RemoveVpcPeering(instanceID int, peeringID string, sleep, timeout int) error

func (*API) RemoveVpcPeeringWithVpcId added in v1.6.0 

func (api *API) RemoveVpcPeeringWithVpcId(vpcID, peeringID string, sleep, timeout int) error

func (*API) RequestVpcGcpPeering added in v1.5.3 

func (api *API) RequestVpcGcpPeering(instanceID int, params map[string]interface{}) (map[string]interface{}, error)

func (*API) RequestVpcGcpPeeringWithVpcId added in v1.6.0 

func (api *API) RequestVpcGcpPeeringWithVpcId(vpcID string, params map[string]interface{}) (map[string]interface{}, error)

func (*API) ResizeDisk added in v1.9.0 

func (api *API) ResizeDisk(instanceID int, params map[string]interface{}, sleep, timeout int) (map[string]interface{}, error)

func (*API) UpdateAlarm 

func (api *API) UpdateAlarm(instanceID int, params map[string]interface{}) error

func (*API) UpdateCustomDomain added in v1.5.0 

func (api *API) UpdateCustomDomain(instanceID int, hostname string) (map[string]interface{}, error)

func (*API) UpdateFirewallSettings 

func (api *API) UpdateFirewallSettings(instanceID int, params []map[string]interface{},
	sleep, timeout int) ([]map[string]interface{}, error)

func (*API) UpdateInstance 

func (api *API) UpdateInstance(instanceID string, params map[string]interface{}) error

func (*API) UpdateIntegration added in v1.3.0 

func (api *API) UpdateIntegration(instanceID int, intType, intID string, params map[string]interface{}) error

UpdateIntegration updated the integration with new information

func (*API) UpdateNotification 

func (api *API) UpdateNotification(instanceID int, params map[string]interface{}) error

func (*API) UpdatePlugin 

func (api *API) UpdatePlugin(instanceID int, params map[string]interface{}) (map[string]interface{}, error)

func (*API) UpdatePluginCommunity 

func (api *API) UpdatePluginCommunity(instanceID int, params map[string]interface{}) (map[string]interface{}, error)
func (api *API) UpdatePrivatelink(instanceID int, params map[string][]interface{}) error

UpdatePrivatelink: Update allowed principals or subscriptions

func (*API) UpdateRabbitMqConfiguration added in v1.8.1 

func (api *API) UpdateRabbitMqConfiguration(instanceID int, params map[string]interface{},
	sleep, timeout int) error

func (*API) UpdateVpcGcpPeering added in v1.5.3 

func (api *API) UpdateVpcGcpPeering(instanceID int, peerID string) (map[string]interface{}, error)

func (*API) UpdateVpcGcpPeeringWithVpcId added in v1.6.0 

func (api *API) UpdateVpcGcpPeeringWithVpcId(vpcID, peerID string) (map[string]interface{}, error)

func (*API) UpdateVpcInstance added in v1.6.0 

func (api *API) UpdateVpcInstance(vpcID string, params map[string]interface{}) error

func (*API) UpgradeRabbitMQ added in v1.7.0 

func (api *API) UpgradeRabbitMQ(instanceID int) (string, error)

UpgradeRabbitMQ - Upgrade to latest possible versions for both RabbitMQ and Erlang.

func (*API) UrlInformation 

func (api *API) UrlInformation(url string) map[string]interface{}

type PluginParams 

type PluginParams struct {
	Name    string `json:"plugin_name,omitempty"`
	Enabled bool   `json:"enabled,omitempty"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.