dbaas

Documentation

Overview

Package dbaas contains logic related to communication with dbaas-controller.

Index

• type Client
  • func NewClient(dbaasControllerAPIAddress string) *Client
  • func (c *Client) CheckKubernetesClusterConnection(ctx context.Context, kubeConfig string) (*controllerv1beta1.CheckKubernetesClusterConnectionResponse, error)
  • func (c *Client) Connect(ctx context.Context) error
  • func (c *Client) CreatePSMDBCluster(ctx context.Context, in *controllerv1beta1.CreatePSMDBClusterRequest, ...) (*controllerv1beta1.CreatePSMDBClusterResponse, error)
  • func (c *Client) CreateXtraDBCluster(ctx context.Context, in *controllerv1beta1.CreateXtraDBClusterRequest, ...) (*controllerv1beta1.CreateXtraDBClusterResponse, error)
  • func (c *Client) DeletePSMDBCluster(ctx context.Context, in *controllerv1beta1.DeletePSMDBClusterRequest, ...) (*controllerv1beta1.DeletePSMDBClusterResponse, error)
  • func (c *Client) DeleteXtraDBCluster(ctx context.Context, in *controllerv1beta1.DeleteXtraDBClusterRequest, ...) (*controllerv1beta1.DeleteXtraDBClusterResponse, error)
  • func (c *Client) Disconnect() error
  • func (c *Client) GetLogs(ctx context.Context, in *controllerv1beta1.GetLogsRequest, ...) (*controllerv1beta1.GetLogsResponse, error)
  • func (c *Client) GetPSMDBClusterCredentials(ctx context.Context, in *controllerv1beta1.GetPSMDBClusterCredentialsRequest, ...) (*controllerv1beta1.GetPSMDBClusterCredentialsResponse, error)
  • func (c *Client) GetResources(ctx context.Context, in *controllerv1beta1.GetResourcesRequest, ...) (*controllerv1beta1.GetResourcesResponse, error)
  • func (c *Client) GetXtraDBClusterCredentials(ctx context.Context, in *controllerv1beta1.GetXtraDBClusterCredentialsRequest, ...) (*controllerv1beta1.GetXtraDBClusterCredentialsResponse, error)
  • func (c *Client) ListPSMDBClusters(ctx context.Context, in *controllerv1beta1.ListPSMDBClustersRequest, ...) (*controllerv1beta1.ListPSMDBClustersResponse, error)
  • func (c *Client) ListXtraDBClusters(ctx context.Context, in *controllerv1beta1.ListXtraDBClustersRequest, ...) (*controllerv1beta1.ListXtraDBClustersResponse, error)
  • func (c *Client) RestartPSMDBCluster(ctx context.Context, in *controllerv1beta1.RestartPSMDBClusterRequest, ...) (*controllerv1beta1.RestartPSMDBClusterResponse, error)
  • func (c *Client) RestartXtraDBCluster(ctx context.Context, in *controllerv1beta1.RestartXtraDBClusterRequest, ...) (*controllerv1beta1.RestartXtraDBClusterResponse, error)
  • func (c *Client) UpdatePSMDBCluster(ctx context.Context, in *controllerv1beta1.UpdatePSMDBClusterRequest, ...) (*controllerv1beta1.UpdatePSMDBClusterResponse, error)
  • func (c *Client) UpdateXtraDBCluster(ctx context.Context, in *controllerv1beta1.UpdateXtraDBClusterRequest, ...) (*controllerv1beta1.UpdateXtraDBClusterResponse, error)

Types

type Client

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

Client is a client for dbaas-controller.

func NewClient

func NewClient(dbaasControllerAPIAddress string) *Client

NewClient creates new Client object.

func (*Client) CheckKubernetesClusterConnection

func (c *Client) CheckKubernetesClusterConnection(ctx context.Context, kubeConfig string) (*controllerv1beta1.CheckKubernetesClusterConnectionResponse, error)

CheckKubernetesClusterConnection checks connection with kubernetes cluster.

func (*Client) Connect

func (c *Client) Connect(ctx context.Context) error

Connect connects the client to dbaas-controller API.

func (*Client) CreatePSMDBCluster

func (c *Client) CreatePSMDBCluster(ctx context.Context, in *controllerv1beta1.CreatePSMDBClusterRequest, opts ...grpc.CallOption) (*controllerv1beta1.CreatePSMDBClusterResponse, error)

CreatePSMDBCluster creates a new PSMDB cluster.

func (*Client) CreateXtraDBCluster

func (c *Client) CreateXtraDBCluster(ctx context.Context, in *controllerv1beta1.CreateXtraDBClusterRequest, opts ...grpc.CallOption) (*controllerv1beta1.CreateXtraDBClusterResponse, error)

CreateXtraDBCluster creates a new XtraDB cluster.

func (*Client) DeletePSMDBCluster

func (c *Client) DeletePSMDBCluster(ctx context.Context, in *controllerv1beta1.DeletePSMDBClusterRequest, opts ...grpc.CallOption) (*controllerv1beta1.DeletePSMDBClusterResponse, error)

DeletePSMDBCluster deletes PSMDB cluster.

func (*Client) DeleteXtraDBCluster

func (c *Client) DeleteXtraDBCluster(ctx context.Context, in *controllerv1beta1.DeleteXtraDBClusterRequest, opts ...grpc.CallOption) (*controllerv1beta1.DeleteXtraDBClusterResponse, error)

DeleteXtraDBCluster deletes XtraDB cluster.

func (*Client) Disconnect

func (c *Client) Disconnect() error

Disconnect disconnects the client from dbaas-controller API.

func (*Client) GetLogs

func (c *Client) GetLogs(ctx context.Context, in *controllerv1beta1.GetLogsRequest, opts ...grpc.CallOption) (*controllerv1beta1.GetLogsResponse, error)

GetLogs gets logs out of cluster containers and events out of pods.

func (*Client) GetPSMDBClusterCredentials

func (c *Client) GetPSMDBClusterCredentials(ctx context.Context, in *controllerv1beta1.GetPSMDBClusterCredentialsRequest, opts ...grpc.CallOption) (*controllerv1beta1.GetPSMDBClusterCredentialsResponse, error)

GetPSMDBClusterCredentials gets PSMDB cluster credentials.

func (*Client) GetResources

func (c *Client) GetResources(ctx context.Context, in *controllerv1beta1.GetResourcesRequest, opts ...grpc.CallOption) (*controllerv1beta1.GetResourcesResponse, error)

GetResources returns all and available resources of a Kubernetes cluster.

func (*Client) GetXtraDBClusterCredentials

func (c *Client) GetXtraDBClusterCredentials(ctx context.Context, in *controllerv1beta1.GetXtraDBClusterCredentialsRequest, opts ...grpc.CallOption) (*controllerv1beta1.GetXtraDBClusterCredentialsResponse, error)

GetXtraDBClusterCredentials gets XtraDB cluster credentials.

func (*Client) ListPSMDBClusters

func (c *Client) ListPSMDBClusters(ctx context.Context, in *controllerv1beta1.ListPSMDBClustersRequest, opts ...grpc.CallOption) (*controllerv1beta1.ListPSMDBClustersResponse, error)

ListPSMDBClusters returns a list of PSMDB clusters.

func (*Client) ListXtraDBClusters

func (c *Client) ListXtraDBClusters(ctx context.Context, in *controllerv1beta1.ListXtraDBClustersRequest, opts ...grpc.CallOption) (*controllerv1beta1.ListXtraDBClustersResponse, error)

func (*Client) RestartPSMDBCluster

func (c *Client) RestartPSMDBCluster(ctx context.Context, in *controllerv1beta1.RestartPSMDBClusterRequest, opts ...grpc.CallOption) (*controllerv1beta1.RestartPSMDBClusterResponse, error)

RestartPSMDBCluster restarts PSMDB cluster.

func (*Client) RestartXtraDBCluster

func (c *Client) RestartXtraDBCluster(ctx context.Context, in *controllerv1beta1.RestartXtraDBClusterRequest, opts ...grpc.CallOption) (*controllerv1beta1.RestartXtraDBClusterResponse, error)

RestartXtraDBCluster restarts XtraDB cluster.

func (*Client) UpdatePSMDBCluster

func (c *Client) UpdatePSMDBCluster(ctx context.Context, in *controllerv1beta1.UpdatePSMDBClusterRequest, opts ...grpc.CallOption) (*controllerv1beta1.UpdatePSMDBClusterResponse, error)

UpdatePSMDBCluster updates existing PSMDB cluster.

func (*Client) UpdateXtraDBCluster

func (c *Client) UpdateXtraDBCluster(ctx context.Context, in *controllerv1beta1.UpdateXtraDBClusterRequest, opts ...grpc.CallOption) (*controllerv1beta1.UpdateXtraDBClusterResponse, error)

UpdateXtraDBCluster updates existing XtraDB cluster.