instaclustr

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultTimeout  = time.Second * 60
	OperatorVersion = "k8s v0.1.1"
)
View Source 
const (
	ClustersEndpoint                       = "/cluster-management/v2/data-sources/clusters/v2/"
	CassandraEndpoint                      = "/cluster-management/v2/resources/applications/cassandra/clusters/v2/"
	OpenSearchEndpoint                     = "/cluster-management/v2/resources/applications/opensearch/clusters/v2/"
	KafkaEndpoint                          = "/cluster-management/v2/resources/applications/kafka/clusters/v2/"
	KafkaConnectEndpoint                   = "/cluster-management/v2/resources/applications/kafka-connect/clusters/v2/"
	KafkaMirrorEndpoint                    = "/cluster-management/v2/resources/applications/kafka_connect/mirrors/v2/"
	KafkaTopicEndpoint                     = "/cluster-management/v2/resources/applications/kafka/topics/v2/"
	KafkaTopicConfigsUpdateEndpoint        = "/cluster-management/v2/operations/applications/kafka/topics/v2/%s/modify-configs/v2"
	ZookeeperEndpoint                      = "/cluster-management/v2/resources/applications/zookeeper/clusters/v2/"
	AWSPeeringEndpoint                     = "/cluster-management/v2/resources/providers/aws/vpc-peers/v2/"
	AzurePeeringEndpoint                   = "/cluster-management/v2/resources/providers/azure/vnet-peers/v2/"
	ClusterNetworkFirewallRuleEndpoint     = "/cluster-management/v2/resources/network-firewall-rules/v2/"
	AWSSecurityGroupFirewallRuleEndpoint   = "/cluster-management/v2/resources/providers/aws/security-group-firewall-rules/v2/"
	GCPPeeringEndpoint                     = "/cluster-management/v2/resources/providers/gcp/vpc-peers/v2/"
	KafkaUserEndpoint                      = "/cluster-management/v2/resources/applications/kafka/users/v3/"
	KafkauserCertificatesEndpoint          = "/cluster-management/v2/resources/applications/kafka/user-certificates/v2/"
	KafkaUserCertificatesRenewEndpoint     = "/cluster-management/v2/operations/applications/kafka/user-certificates/renew/v2/"
	KafkaACLEndpoint                       = "/cluster-management/v2/resources/applications/kafka/acls/v2/"
	CadenceEndpoint                        = "/cluster-management/v2/resources/applications/cadence/clusters/v2/"
	RedisEndpoint                          = "/cluster-management/v2/resources/applications/redis/clusters/v2/"
	RedisUserEndpoint                      = "/cluster-management/v2/resources/applications/redis/users/v2/"
	PGSQLEndpoint                          = "/cluster-management/v2/resources/applications/postgresql/clusters/v2/"
	PGSQLConfigEndpoint                    = "%s/cluster-management/v2/data-sources/postgresql_cluster/%s/configurations"
	PGSQLConfigManagementEndpoint          = "%s/cluster-management/v2/resources/applications/postgresql/configurations/v2/"
	PGSQLUpdateDefaultUserPasswordEndpoint = "%s/cluster-management/v2/operations/applications/postgresql/clusters/v2/%s/update-default-user-password"
	NodeReloadEndpoint                     = "%s/cluster-management/v2/operations/applications/postgresql/nodes/v2/%s/reload"
	AWSEncryptionKeyEndpoint               = "/cluster-management/v2/resources/providers/aws/encryption-keys/v2/"
	ListAppsVersionsEndpoint               = "%s/cluster-management/v2/data-sources/applications/%s/versions/v2/"
	ClusterSettingsEndpoint                = "%s/cluster-management/v2/operations/clusters/v2/%s/change-settings/v2"
	OpenSearchEgressRulesEndpoint          = "/cluster-management/v2/resources/applications/opensearch/egress-rules/v2"
	AWSEndpointServicePrincipalEndpoint    = "/cluster-management/v2/resources/aws-endpoint-service-principals/v2/"
	ClusterResizeOperationsEndpoint        = "/cluster-management/v2/data-sources/cluster-data-centres/v2/%s/resize/operations/v2"
)

constants for API v2

View Source 
const (
	// ClustersEndpoint is used for GET, DELETE and UPDATE clusters
	ClustersEndpointV1           = "/provisioning/v1/"
	GetClusterBackupEndpoint     = "%s/cluster-management/v2/data-sources/applications/%s/clusters/v2/%s/list-backups/v2"
	TriggerClusterBackupEndpoint = "%s/cluster-management/v2/operations/applications/%s/clusters/v2/%s/trigger-backup/v2"

	RestoreEndpoint = "%s/cluster-management/v2/operations/applications/%s/restore/v2"

	ExclusionWindowEndpoint            = "/cluster-management/v2/resources/exclusion-windows/v2/"
	MaintenanceEventRescheduleEndpoint = "%s/cluster-management/v2/operations/maintenance-events/%s/v2/reschedule-maintenance-event/v2/"
	MaintenanceEventStatusEndpoint     = "%s/cluster-management/v2/data-sources/cluster/%s/maintenance-events/v2/%s/v2/"
)

constants for API v1

View Source 
const (
	APIv1UserEndpoint   = "%s/provisioning/v1/%s/%s/users"
	RedisUserIDFmt      = "%s_%s"
	CassandraBundleUser = "apache_cassandra"
)
View Source 
const MsgDeleteUser = "If you want to delete the user, remove it from the clusters specifications first"
View Source 
const MsgInstaclustrResourceNotFound = "The resource is not found on Instaclustr, changing its state to deleted"

Variables

View Source 
var (
	ClusterNotRunning         = errors.New("сluster is not running")
	NotFound                  = errors.New("not found")
	ClusterIsNotReadyToResize = errors.New("cluster is not ready to resize yet")
)

Functions

This section is empty.

Types

type API 

type API interface {
	DoRequest(url string, method string, data []byte) (*http.Response, error)
	CreateCluster(url string, clusterSpec any) (string, error)
	GetOpenSearch(id string) ([]byte, error)
	UpdateOpenSearch(id string, o models.OpenSearchInstAPIUpdateRequest) error
	UpdateDescriptionAndTwoFactorDelete(clusterEndpoint, clusterID, description string, twoFactorDelete *v1beta1.TwoFactorDelete) error
	UpdateCluster(id, clusterEndpoint string, instaDCs any) error
	DeleteCluster(id, clusterEndpoint string) error
	GetPeeringStatus(peerID, peeringEndpoint string) (*clusterresourcesv1beta1.PeeringStatus, error)
	GetAWSVPCPeering(peerID string) (*models.AWSVPCPeering, error)
	UpdatePeering(peerID, peeringEndpoint string, peerSpec any) error
	DeletePeering(peerID, peeringEndpoint string) error
	CreateAzureVNetPeering(peeringSpec *clusterresourcesv1beta1.AzureVNetPeeringSpec, cdcId string) (*clusterresourcesv1beta1.PeeringStatus, error)
	CreateGCPVPCPeering(peeringSpec *clusterresourcesv1beta1.GCPVPCPeeringSpec, cdcId string) (*clusterresourcesv1beta1.PeeringStatus, error)
	CreateAWSVPCPeering(peeringSpec *clusterresourcesv1beta1.AWSVPCPeeringSpec, cdcId string) (*clusterresourcesv1beta1.PeeringStatus, error)
	GetFirewallRuleStatus(firewallRuleID string, firewallRuleEndpoint string) (*clusterresourcesv1beta1.FirewallRuleStatus, error)
	CreateAWSSecurityGroupFirewallRule(firewallRuleSpec *clusterresourcesv1beta1.AWSSecurityGroupFirewallRuleSpec, clusterID string) (*clusterresourcesv1beta1.FirewallRuleStatus, error)
	CreateClusterNetworkFirewallRule(firewallRuleSpec *clusterresourcesv1beta1.ClusterNetworkFirewallRuleSpec, clusterID string) (*clusterresourcesv1beta1.FirewallRuleStatus, error)
	DeleteFirewallRule(firewallRuleID string, firewallRuleEndpoint string) error
	CreateKafkaUser(url string, kafkaUser *models.KafkaUser) (*kafkamanagementv1beta1.KafkaUserStatus, error)
	UpdateKafkaUser(kafkaUserID string, kafkaUserSpec *models.KafkaUser) error
	DeleteKafkaUser(kafkaUserID, kafkaUserEndpoint string) error
	CreateKafkaUserCertificate(certRequest *models.CertificateRequest) (*models.Certificate, error)
	DeleteKafkaUserCertificate(certificateID string) error
	RenewKafkaUserCertificate(certificateID string) (*models.Certificate, error)
	GetTopicStatus(id string) ([]byte, error)
	CreateKafkaTopic(url string, topic *kafkamanagementv1beta1.Topic) error
	DeleteKafkaTopic(url, id string) error
	UpdateKafkaTopic(url string, topic *kafkamanagementv1beta1.Topic) error
	CreateKafkaMirror(m *kafkamanagementv1beta1.MirrorSpec) (*kafkamanagementv1beta1.MirrorStatus, error)
	GetMirrorStatus(id string) (*kafkamanagementv1beta1.MirrorStatus, error)
	DeleteKafkaMirror(id string) error
	UpdateKafkaMirror(id string, latency int32) error
	GetClusterBackups(clusterID, clusterKind string) (*models.ClusterBackup, error)
	TriggerClusterBackup(clusterID, clusterKind string) error
	CreateExclusionWindow(clusterID string, window *clusterresourcesv1beta1.ExclusionWindowSpec) (string, error)
	GetExclusionWindowsStatus(windowID string) (string, error)
	DeleteExclusionWindow(id string) error
	GetMaintenanceEvents(clusterID, eventType string) ([]*clusterresourcesv1beta1.MaintenanceEventStatus, error)
	FetchMaintenanceEventStatuses(clusterID string) ([]*clusterresourcesv1beta1.ClusteredMaintenanceEventStatus, error)
	RescheduleMaintenanceEvent(me *clusterresourcesv1beta1.MaintenanceEventReschedule) error
	CreateNodeReload(nr *clusterresourcesv1beta1.Node) error
	GetNodeReloadStatus(nodeID string) (*models.NodeReloadStatus, error)
	GetRedis(id string) ([]byte, error)
	UpdateRedis(id string, r *models.RedisDataCentreUpdate) error
	CreateRedisUser(user *models.RedisUser) (string, error)
	UpdateRedisUser(user *models.RedisUserUpdate) error
	DeleteRedisUser(id string) error
	GetRedisUser(id string) (*models.RedisUser, error)
	CreateKafkaACL(url string, kafkaACL *kafkamanagementv1beta1.KafkaACLSpec) (*kafkamanagementv1beta1.KafkaACLStatus, error)
	GetKafkaACLStatus(kafkaACLID, kafkaACLEndpoint string) (*kafkamanagementv1beta1.KafkaACLStatus, error)
	DeleteKafkaACL(kafkaACLID, kafkaACLEndpoint string) error
	UpdateKafkaACL(kafkaACLID, kafkaACLEndpoint string, kafkaACLSpec any) error
	GetCassandra(id string) ([]byte, error)
	UpdateCassandra(id string, cassandra models.CassandraClusterAPIUpdate) error
	GetKafka(id string) ([]byte, error)
	GetKafkaConnect(id string) ([]byte, error)
	UpdateKafkaConnect(id string, kc models.KafkaConnectAPIUpdate) error
	GetZookeeper(id string) ([]byte, error)
	RestoreCluster(restoreData any, clusterKind string) (string, error)
	GetPostgreSQL(id string) ([]byte, error)
	UpdatePostgreSQL(id string, r *models.PGClusterUpdate) error
	GetPostgreSQLConfigs(id string) ([]*models.PGConfigs, error)
	CreatePostgreSQLConfiguration(id, name, value string) error
	UpdatePostgreSQLConfiguration(id, name, value string) error
	ResetPostgreSQLConfiguration(id, name string) error
	GetCadence(id string) ([]byte, error)
	UpdatePostgreSQLDefaultUserPassword(id, password string) error
	ListClusters() ([]*models.ActiveClusters, error)
	CreateEncryptionKey(encryptionKeySpec any) (*clusterresourcesv1beta1.AWSEncryptionKeyStatus, error)
	GetEncryptionKeyStatus(encryptionKeyID string, encryptionKeyEndpoint string) (*clusterresourcesv1beta1.AWSEncryptionKeyStatus, error)
	DeleteEncryptionKey(encryptionKeyID string) error
	CreateUser(userSpec any, clusterID, app string) error
	DeleteUser(username, clusterID, app string) error
	FetchUsers(clusterID, app string) ([]string, error)
	ListAppVersions(app string) ([]*models.AppVersions, error)
	GetDefaultCredentialsV1(clusterID string) (string, string, error)
	UpdateClusterSettings(clusterID string, settings *models.ClusterSettings) error
	GetAWSEndpointServicePrincipal(id string) (*models.AWSEndpointServicePrincipal, error)
	CreateOpenSearchEgressRules(rule *clusterresourcesv1beta1.OpenSearchEgressRules) (string, error)
	GetOpenSearchEgressRule(id string) (*clusterresourcesv1beta1.OpenSearchEgressRulesStatus, error)
	DeleteOpenSearchEgressRule(id string) error
	CreateAWSEndpointServicePrincipal(spec clusterresourcesv1beta1.AWSEndpointServicePrincipalSpec, CDCID string) ([]byte, error)
	DeleteAWSEndpointServicePrincipal(principalID string) error
	GetResizeOperationsByClusterDataCentreID(cdcID string) ([]*v1beta1.ResizeOperation, error)
}

type Client 

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

func NewClient 

func NewClient(
	username string,
	key string,
	serverHostname string,
	timeout time.Duration,
) *Client

func (*Client) CreateAWSEndpointServicePrincipal added in v0.1.2 

func (c *Client) CreateAWSEndpointServicePrincipal(spec clusterresourcesv1beta1.AWSEndpointServicePrincipalSpec, CDCID string) ([]byte, error)

func (*Client) CreateAWSSecurityGroupFirewallRule added in v0.1.4 

func (c *Client) CreateAWSSecurityGroupFirewallRule(
	firewallRuleSpec *clusterresourcesv1beta1.AWSSecurityGroupFirewallRuleSpec,
	clusterID string,
) (*clusterresourcesv1beta1.FirewallRuleStatus, error)

func (*Client) CreateAWSVPCPeering added in v0.1.4 

func (c *Client) CreateAWSVPCPeering(peeringSpec *clusterresourcesv1beta1.AWSVPCPeeringSpec, cdcId string) (*clusterresourcesv1beta1.PeeringStatus, error)

func (*Client) CreateAzureVNetPeering added in v0.1.4 

func (c *Client) CreateAzureVNetPeering(peeringSpec *clusterresourcesv1beta1.AzureVNetPeeringSpec, cdcId string) (*clusterresourcesv1beta1.PeeringStatus, error)

func (*Client) CreateCluster 

func (c *Client) CreateCluster(url string, cluster any) (string, error)

func (*Client) CreateClusterNetworkFirewallRule added in v0.1.4 

func (c *Client) CreateClusterNetworkFirewallRule(
	firewallRuleSpec *clusterresourcesv1beta1.ClusterNetworkFirewallRuleSpec,
	clusterID string,
) (*clusterresourcesv1beta1.FirewallRuleStatus, error)

func (*Client) CreateEncryptionKey added in v0.0.3 

func (c *Client) CreateEncryptionKey(
	encryptionKeySpec any,
) (*clusterresourcesv1beta1.AWSEncryptionKeyStatus, error)

func (*Client) CreateExclusionWindow 

func (c *Client) CreateExclusionWindow(clusterID string, window *clusterresourcesv1beta1.ExclusionWindowSpec) (string, error)

func (*Client) CreateGCPVPCPeering added in v0.1.4 

func (c *Client) CreateGCPVPCPeering(peeringSpec *clusterresourcesv1beta1.GCPVPCPeeringSpec, cdcId string) (*clusterresourcesv1beta1.PeeringStatus, error)

func (*Client) CreateKafkaACL 

func (c *Client) CreateKafkaACL(
	url string,
	kafkaACL *kafkamanagementv1beta1.KafkaACLSpec,
) (*kafkamanagementv1beta1.KafkaACLStatus, error)

func (*Client) CreateKafkaMirror 

func (c *Client) CreateKafkaMirror(m *kafkamanagementv1beta1.MirrorSpec) (*kafkamanagementv1beta1.MirrorStatus, error)

func (*Client) CreateKafkaTopic 

func (c *Client) CreateKafkaTopic(url string, t *kafkamanagementv1beta1.Topic) error

func (*Client) CreateKafkaUser 

func (c *Client) CreateKafkaUser(
	url string,
	kafkaUser *models.KafkaUser,
) (*kafkamanagementv1beta1.KafkaUserStatus, error)

func (*Client) CreateKafkaUserCertificate added in v0.1.2 

func (c *Client) CreateKafkaUserCertificate(certRequest *models.CertificateRequest) (*models.Certificate, error)

func (*Client) CreateNodeReload 

func (c *Client) CreateNodeReload(nr *clusterresourcesv1beta1.Node) error

func (*Client) CreateOpenSearchEgressRules added in v0.1.3 

func (c *Client) CreateOpenSearchEgressRules(rule *clusterresourcesv1beta1.OpenSearchEgressRules) (string, error)

func (*Client) CreatePostgreSQLConfiguration 

func (c *Client) CreatePostgreSQLConfiguration(id, name, value string) error

func (*Client) CreateRedisUser added in v0.0.2 

func (c *Client) CreateRedisUser(user *models.RedisUser) (string, error)

func (*Client) CreateUser added in v0.0.6 

func (c *Client) CreateUser(userSpec any, clusterID, app string) error

func (*Client) DeleteAWSEndpointServicePrincipal added in v0.1.2 

func (c *Client) DeleteAWSEndpointServicePrincipal(principalID string) error

func (*Client) DeleteCluster 

func (c *Client) DeleteCluster(id, clusterEndpoint string) error

func (*Client) DeleteEncryptionKey added in v0.0.3 

func (c *Client) DeleteEncryptionKey(
	encryptionKeyID string,
) error

func (*Client) DeleteExclusionWindow 

func (c *Client) DeleteExclusionWindow(id string) error

func (*Client) DeleteFirewallRule 

func (c *Client) DeleteFirewallRule(
	firewallRuleID string,
	firewallRuleEndpoint string,
) error

func (*Client) DeleteKafkaACL 

func (c *Client) DeleteKafkaACL(
	kafkaACLID,
	kafkaACLEndpoint string,
) error

func (*Client) DeleteKafkaMirror 

func (c *Client) DeleteKafkaMirror(id string) error

func (*Client) DeleteKafkaTopic 

func (c *Client) DeleteKafkaTopic(url, id string) error

func (*Client) DeleteKafkaUser 

func (c *Client) DeleteKafkaUser(kafkaUserID, kafkaUserEndpoint string) error

func (*Client) DeleteKafkaUserCertificate added in v0.1.2 

func (c *Client) DeleteKafkaUserCertificate(certificateID string) error

func (*Client) DeleteOpenSearchEgressRule added in v0.1.3 

func (c *Client) DeleteOpenSearchEgressRule(id string) error

func (*Client) DeletePeering 

func (c *Client) DeletePeering(peerID, peeringEndpoint string) error

func (*Client) DeleteRedisUser added in v0.0.2 

func (c *Client) DeleteRedisUser(id string) error

func (*Client) DeleteUser added in v0.0.6 

func (c *Client) DeleteUser(username, clusterID, app string) error

func (*Client) DoRequest 

func (c *Client) DoRequest(url string, method string, data []byte) (*http.Response, error)

func (*Client) FetchMaintenanceEventStatuses added in v0.1.2 

func (c *Client) FetchMaintenanceEventStatuses(
	clusterID string,
) ([]*clusterresourcesv1beta1.ClusteredMaintenanceEventStatus,
	error)

func (*Client) FetchUsers added in v0.1.3 

func (c *Client) FetchUsers(clusterID, app string) ([]string, error)

func (*Client) GetAWSEndpointServicePrincipal added in v0.1.3 

func (c *Client) GetAWSEndpointServicePrincipal(principalID string) (*models.AWSEndpointServicePrincipal, error)

func (*Client) GetAWSVPCPeering added in v0.1.3 

func (c *Client) GetAWSVPCPeering(peerID string) (*models.AWSVPCPeering, error)

func (*Client) GetCadence added in v0.0.2 

func (c *Client) GetCadence(id string) ([]byte, error)

func (*Client) GetCassandra 

func (c *Client) GetCassandra(id string) ([]byte, error)

func (*Client) GetClusterBackups 

func (c *Client) GetClusterBackups(clusterID, clusterKind string) (*models.ClusterBackup, error)

func (*Client) GetDefaultCredentialsV1 added in v0.1.1 

func (c *Client) GetDefaultCredentialsV1(clusterID string) (string, string, error)

func (*Client) GetEncryptionKeyStatus added in v0.0.3 

func (c *Client) GetEncryptionKeyStatus(
	encryptionKeyID string,
	encryptionKeyEndpoint string,
) (*clusterresourcesv1beta1.AWSEncryptionKeyStatus, error)

func (*Client) GetExclusionWindowsStatus added in v0.1.2 

func (c *Client) GetExclusionWindowsStatus(windowID string) (string, error)

func (*Client) GetFirewallRuleStatus 

func (c *Client) GetFirewallRuleStatus(
	firewallRuleID string,
	firewallRuleEndpoint string,
) (*clusterresourcesv1beta1.FirewallRuleStatus, error)

func (*Client) GetKafka added in v0.0.2 

func (c *Client) GetKafka(id string) ([]byte, error)

func (*Client) GetKafkaACLStatus 

func (c *Client) GetKafkaACLStatus(
	kafkaACLID,
	kafkaACLEndpoint string,
) (*kafkamanagementv1beta1.KafkaACLStatus, error)

func (*Client) GetKafkaConnect added in v0.0.2 

func (c *Client) GetKafkaConnect(id string) ([]byte, error)

func (*Client) GetMaintenanceEvents added in v0.0.2 

func (c *Client) GetMaintenanceEvents(clusterID, eventType string) ([]*clusterresourcesv1beta1.MaintenanceEventStatus, error)

func (*Client) GetMirrorStatus 

func (c *Client) GetMirrorStatus(id string) (*kafkamanagementv1beta1.MirrorStatus, error)

func (*Client) GetNodeReloadStatus 

func (c *Client) GetNodeReloadStatus(nodeID string) (*models.NodeReloadStatus, error)

func (*Client) GetOpenSearch added in v0.0.2 

func (c *Client) GetOpenSearch(id string) ([]byte, error)

func (*Client) GetOpenSearchEgressRule added in v0.1.3 

func (c *Client) GetOpenSearchEgressRule(id string) (*clusterresourcesv1beta1.OpenSearchEgressRulesStatus, error)

func (*Client) GetPeeringStatus 

func (c *Client) GetPeeringStatus(peerID,
	peeringEndpoint string,
) (*clusterresourcesv1beta1.PeeringStatus, error)

func (*Client) GetPostgreSQL 

func (c *Client) GetPostgreSQL(id string) ([]byte, error)

func (*Client) GetPostgreSQLConfigs 

func (c *Client) GetPostgreSQLConfigs(id string) ([]*models.PGConfigs, error)

func (*Client) GetRedis added in v0.0.2 

func (c *Client) GetRedis(id string) ([]byte, error)

func (*Client) GetRedisUser added in v0.1.2 

func (c *Client) GetRedisUser(id string) (*models.RedisUser, error)

func (*Client) GetResizeOperationsByClusterDataCentreID added in v0.1.3 

func (c *Client) GetResizeOperationsByClusterDataCentreID(cdcID string) ([]*v1beta1.ResizeOperation, error)

func (*Client) GetTopicStatus added in v0.0.2 

func (c *Client) GetTopicStatus(id string) ([]byte, error)

func (*Client) GetZookeeper added in v0.0.2 

func (c *Client) GetZookeeper(id string) ([]byte, error)

func (*Client) ListAppVersions added in v0.0.5 

func (c *Client) ListAppVersions(app string) ([]*models.AppVersions, error)

func (*Client) ListClusters added in v0.0.2 

func (c *Client) ListClusters() ([]*models.ActiveClusters, error)

func (*Client) RenewKafkaUserCertificate added in v0.1.2 

func (c *Client) RenewKafkaUserCertificate(certificateID string) (*models.Certificate, error)

func (*Client) RescheduleMaintenanceEvent added in v0.1.2 

func (c *Client) RescheduleMaintenanceEvent(me *clusterresourcesv1beta1.MaintenanceEventReschedule) error

func (*Client) ResetPostgreSQLConfiguration 

func (c *Client) ResetPostgreSQLConfiguration(id, name string) error

func (*Client) RestoreCluster added in v0.1.3 

func (c *Client) RestoreCluster(restoreData any, clusterKind string) (string, error)

func (*Client) TriggerClusterBackup 

func (c *Client) TriggerClusterBackup(clusterID, clusterKind string) error

func (*Client) UpdateCassandra added in v0.0.2 

func (c *Client) UpdateCassandra(id string, cassandra models.CassandraClusterAPIUpdate) error

func (*Client) UpdateCluster 

func (c *Client) UpdateCluster(id, clusterEndpoint string, InstaDCs any) error

func (*Client) UpdateClusterSettings added in v0.1.2 

func (c *Client) UpdateClusterSettings(clusterID string, settings *models.ClusterSettings) error

func (*Client) UpdateDescriptionAndTwoFactorDelete 

func (c *Client) UpdateDescriptionAndTwoFactorDelete(clusterEndpoint, clusterID, description string, twoFactorDelete *v1beta1.TwoFactorDelete) error

func (*Client) UpdateKafkaACL 

func (c *Client) UpdateKafkaACL(
	kafkaACLID,
	kafkaACLEndpoint string,
	kafkaACLSpec any,
) error

func (*Client) UpdateKafkaConnect added in v0.0.2 

func (c *Client) UpdateKafkaConnect(id string, kc models.KafkaConnectAPIUpdate) error

func (*Client) UpdateKafkaMirror 

func (c *Client) UpdateKafkaMirror(id string, latency int32) error

func (*Client) UpdateKafkaTopic 

func (c *Client) UpdateKafkaTopic(url string, t *kafkamanagementv1beta1.Topic) error

func (*Client) UpdateKafkaUser 

func (c *Client) UpdateKafkaUser(
	kafkaUserID string,
	kafkaUserSpec *models.KafkaUser,
) error

func (*Client) UpdateOpenSearch added in v0.0.6 

func (c *Client) UpdateOpenSearch(id string, o models.OpenSearchInstAPIUpdateRequest) error

func (*Client) UpdatePeering 

func (c *Client) UpdatePeering(peerID,
	peeringEndpoint string,
	peerSpec any,
) error

func (*Client) UpdatePostgreSQL added in v0.1.3 

func (c *Client) UpdatePostgreSQL(id string, r *models.PGClusterUpdate) error

func (*Client) UpdatePostgreSQLConfiguration 

func (c *Client) UpdatePostgreSQLConfiguration(id, name, value string) error

func (*Client) UpdatePostgreSQLDefaultUserPassword added in v0.0.2 

func (c *Client) UpdatePostgreSQLDefaultUserPassword(id, password string) error

func (*Client) UpdateRedis added in v0.1.1 

func (c *Client) UpdateRedis(id string, r *models.RedisDataCentreUpdate) error

func (*Client) UpdateRedisUser added in v0.0.2 

func (c *Client) UpdateRedisUser(user *models.RedisUserUpdate) error

Source Files

View all Source files

Directories

Path Synopsis
server command
server/go

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.