dbaasv1beta1

package
v2.18.0+incompatible Latest Latest
Warning

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

Go to latest
Published: May 17, 2021 License: AGPL-3.0 Imports: 21 Imported by: 0

Documentation

Overview

Package dbaasv1beta1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package dbaasv1beta1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package dbaasv1beta1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package dbaasv1beta1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package dbaasv1beta1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	OperatorsStatus_name = map[int32]string{
		0: "OPERATORS_STATUS_INVALID",
		1: "OPERATORS_STATUS_OK",
		2: "OPERATORS_STATUS_UNSUPPORTED",
		3: "OPERATORS_STATUS_NOT_INSTALLED",
	}
	OperatorsStatus_value = map[string]int32{
		"OPERATORS_STATUS_INVALID":       0,
		"OPERATORS_STATUS_OK":            1,
		"OPERATORS_STATUS_UNSUPPORTED":   2,
		"OPERATORS_STATUS_NOT_INSTALLED": 3,
	}
)

Enum value maps for OperatorsStatus.

View Source
var (
	KubernetesClusterStatus_name = map[int32]string{
		0: "KUBERNETES_CLUSTER_STATUS_INVALID",
		1: "KUBERNETES_CLUSTER_STATUS_OK",
		2: "KUBERNETES_CLUSTER_STATUS_UNAVAILABLE",
	}
	KubernetesClusterStatus_value = map[string]int32{
		"KUBERNETES_CLUSTER_STATUS_INVALID":     0,
		"KUBERNETES_CLUSTER_STATUS_OK":          1,
		"KUBERNETES_CLUSTER_STATUS_UNAVAILABLE": 2,
	}
)

Enum value maps for KubernetesClusterStatus.

View Source
var (
	PSMDBClusterState_name = map[int32]string{
		0: "PSMDB_CLUSTER_STATE_INVALID",
		1: "PSMDB_CLUSTER_STATE_CHANGING",
		2: "PSMDB_CLUSTER_STATE_READY",
		3: "PSMDB_CLUSTER_STATE_FAILED",
		4: "PSMDB_CLUSTER_STATE_DELETING",
		5: "PSMDB_CLUSTER_STATE_PAUSED",
	}
	PSMDBClusterState_value = map[string]int32{
		"PSMDB_CLUSTER_STATE_INVALID":  0,
		"PSMDB_CLUSTER_STATE_CHANGING": 1,
		"PSMDB_CLUSTER_STATE_READY":    2,
		"PSMDB_CLUSTER_STATE_FAILED":   3,
		"PSMDB_CLUSTER_STATE_DELETING": 4,
		"PSMDB_CLUSTER_STATE_PAUSED":   5,
	}
)

Enum value maps for PSMDBClusterState.

View Source
var (
	XtraDBClusterState_name = map[int32]string{
		0: "XTRA_DB_CLUSTER_STATE_INVALID",
		1: "XTRA_DB_CLUSTER_STATE_CHANGING",
		2: "XTRA_DB_CLUSTER_STATE_READY",
		3: "XTRA_DB_CLUSTER_STATE_FAILED",
		4: "XTRA_DB_CLUSTER_STATE_DELETING",
		5: "XTRA_DB_CLUSTER_STATE_PAUSED",
	}
	XtraDBClusterState_value = map[string]int32{
		"XTRA_DB_CLUSTER_STATE_INVALID":  0,
		"XTRA_DB_CLUSTER_STATE_CHANGING": 1,
		"XTRA_DB_CLUSTER_STATE_READY":    2,
		"XTRA_DB_CLUSTER_STATE_FAILED":   3,
		"XTRA_DB_CLUSTER_STATE_DELETING": 4,
		"XTRA_DB_CLUSTER_STATE_PAUSED":   5,
	}
)

Enum value maps for XtraDBClusterState.

View Source
var (
	XtraDBBackupState_name = map[int32]string{
		0: "XTRA_DB_BACKUP_STATE_INVALID",
		1: "XTRA_DB_BACKUP_STATE_RUNNING",
		2: "XTRA_DB_BACKUP_STATE_SUCCEEDED",
		3: "XTRA_DB_BACKUP_STATE_FAILED",
	}
	XtraDBBackupState_value = map[string]int32{
		"XTRA_DB_BACKUP_STATE_INVALID":   0,
		"XTRA_DB_BACKUP_STATE_RUNNING":   1,
		"XTRA_DB_BACKUP_STATE_SUCCEEDED": 2,
		"XTRA_DB_BACKUP_STATE_FAILED":    3,
	}
)

Enum value maps for XtraDBBackupState.

View Source
var File_managementpb_dbaas_components_proto protoreflect.FileDescriptor
View Source
var File_managementpb_dbaas_dbaas_proto protoreflect.FileDescriptor
View Source
var File_managementpb_dbaas_kubernetes_proto protoreflect.FileDescriptor
View Source
var File_managementpb_dbaas_logs_proto protoreflect.FileDescriptor
View Source
var File_managementpb_dbaas_psmdb_cluster_proto protoreflect.FileDescriptor
View Source
var File_managementpb_dbaas_xtradb_cluster_proto protoreflect.FileDescriptor

Functions

func RegisterComponentsHandler

func RegisterComponentsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterComponentsHandler registers the http handlers for service Components to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterComponentsHandlerClient

func RegisterComponentsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ComponentsClient) error

RegisterComponentsHandlerClient registers the http handlers for service Components to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ComponentsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ComponentsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ComponentsClient" to call the correct interceptors.

func RegisterComponentsHandlerFromEndpoint

func RegisterComponentsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterComponentsHandlerFromEndpoint is same as RegisterComponentsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterComponentsHandlerServer

func RegisterComponentsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ComponentsServer) error

RegisterComponentsHandlerServer registers the http handlers for service Components to "mux". UnaryRPC :call ComponentsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterComponentsHandlerFromEndpoint instead.

func RegisterComponentsServer

func RegisterComponentsServer(s *grpc.Server, srv ComponentsServer)

func RegisterKubernetesHandler

func RegisterKubernetesHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterKubernetesHandler registers the http handlers for service Kubernetes to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterKubernetesHandlerClient

func RegisterKubernetesHandlerClient(ctx context.Context, mux *runtime.ServeMux, client KubernetesClient) error

RegisterKubernetesHandlerClient registers the http handlers for service Kubernetes to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "KubernetesClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "KubernetesClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "KubernetesClient" to call the correct interceptors.

func RegisterKubernetesHandlerFromEndpoint

func RegisterKubernetesHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterKubernetesHandlerFromEndpoint is same as RegisterKubernetesHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterKubernetesHandlerServer

func RegisterKubernetesHandlerServer(ctx context.Context, mux *runtime.ServeMux, server KubernetesServer) error

RegisterKubernetesHandlerServer registers the http handlers for service Kubernetes to "mux". UnaryRPC :call KubernetesServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterKubernetesHandlerFromEndpoint instead.

func RegisterKubernetesServer

func RegisterKubernetesServer(s *grpc.Server, srv KubernetesServer)

func RegisterLogsAPIHandler

func RegisterLogsAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterLogsAPIHandler registers the http handlers for service LogsAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterLogsAPIHandlerClient

func RegisterLogsAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LogsAPIClient) error

RegisterLogsAPIHandlerClient registers the http handlers for service LogsAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "LogsAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LogsAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "LogsAPIClient" to call the correct interceptors.

func RegisterLogsAPIHandlerFromEndpoint

func RegisterLogsAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterLogsAPIHandlerFromEndpoint is same as RegisterLogsAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterLogsAPIHandlerServer

func RegisterLogsAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LogsAPIServer) error

RegisterLogsAPIHandlerServer registers the http handlers for service LogsAPI to "mux". UnaryRPC :call LogsAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterLogsAPIHandlerFromEndpoint instead.

func RegisterLogsAPIServer

func RegisterLogsAPIServer(s *grpc.Server, srv LogsAPIServer)

func RegisterPSMDBClusterHandler

func RegisterPSMDBClusterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPSMDBClusterHandler registers the http handlers for service PSMDBCluster to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPSMDBClusterHandlerClient

func RegisterPSMDBClusterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PSMDBClusterClient) error

RegisterPSMDBClusterHandlerClient registers the http handlers for service PSMDBCluster to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PSMDBClusterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PSMDBClusterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PSMDBClusterClient" to call the correct interceptors.

func RegisterPSMDBClusterHandlerFromEndpoint

func RegisterPSMDBClusterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPSMDBClusterHandlerFromEndpoint is same as RegisterPSMDBClusterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPSMDBClusterHandlerServer

func RegisterPSMDBClusterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PSMDBClusterServer) error

RegisterPSMDBClusterHandlerServer registers the http handlers for service PSMDBCluster to "mux". UnaryRPC :call PSMDBClusterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPSMDBClusterHandlerFromEndpoint instead.

func RegisterPSMDBClusterServer

func RegisterPSMDBClusterServer(s *grpc.Server, srv PSMDBClusterServer)

func RegisterXtraDBClusterHandler

func RegisterXtraDBClusterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterXtraDBClusterHandler registers the http handlers for service XtraDBCluster to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterXtraDBClusterHandlerClient

func RegisterXtraDBClusterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client XtraDBClusterClient) error

RegisterXtraDBClusterHandlerClient registers the http handlers for service XtraDBCluster to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "XtraDBClusterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "XtraDBClusterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "XtraDBClusterClient" to call the correct interceptors.

func RegisterXtraDBClusterHandlerFromEndpoint

func RegisterXtraDBClusterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterXtraDBClusterHandlerFromEndpoint is same as RegisterXtraDBClusterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterXtraDBClusterHandlerServer

func RegisterXtraDBClusterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server XtraDBClusterServer) error

RegisterXtraDBClusterHandlerServer registers the http handlers for service XtraDBCluster to "mux". UnaryRPC :call XtraDBClusterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterXtraDBClusterHandlerFromEndpoint instead.

func RegisterXtraDBClusterServer

func RegisterXtraDBClusterServer(s *grpc.Server, srv XtraDBClusterServer)

Types

type ChangeComponent

type ChangeComponent struct {
	DefaultVersion string                              `protobuf:"bytes,1,opt,name=default_version,json=defaultVersion,proto3" json:"default_version,omitempty"`
	Versions       []*ChangeComponent_ComponentVersion `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

ChangeComponent contains fields to manage components.

func (*ChangeComponent) Descriptor deprecated

func (*ChangeComponent) Descriptor() ([]byte, []int)

Deprecated: Use ChangeComponent.ProtoReflect.Descriptor instead.

func (*ChangeComponent) GetDefaultVersion

func (x *ChangeComponent) GetDefaultVersion() string

func (*ChangeComponent) GetVersions

func (*ChangeComponent) ProtoMessage

func (*ChangeComponent) ProtoMessage()

func (*ChangeComponent) ProtoReflect

func (x *ChangeComponent) ProtoReflect() protoreflect.Message

func (*ChangeComponent) Reset

func (x *ChangeComponent) Reset()

func (*ChangeComponent) String

func (x *ChangeComponent) String() string

func (*ChangeComponent) Validate

func (this *ChangeComponent) Validate() error

type ChangeComponent_ComponentVersion

type ChangeComponent_ComponentVersion struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Disable bool   `protobuf:"varint,2,opt,name=disable,proto3" json:"disable,omitempty"`
	Enable  bool   `protobuf:"varint,3,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

ComponentVersion contains operations which should be done with component version.

func (*ChangeComponent_ComponentVersion) Descriptor deprecated

func (*ChangeComponent_ComponentVersion) Descriptor() ([]byte, []int)

Deprecated: Use ChangeComponent_ComponentVersion.ProtoReflect.Descriptor instead.

func (*ChangeComponent_ComponentVersion) GetDisable

func (x *ChangeComponent_ComponentVersion) GetDisable() bool

func (*ChangeComponent_ComponentVersion) GetEnable

func (x *ChangeComponent_ComponentVersion) GetEnable() bool

func (*ChangeComponent_ComponentVersion) GetVersion

func (x *ChangeComponent_ComponentVersion) GetVersion() string

func (*ChangeComponent_ComponentVersion) ProtoMessage

func (*ChangeComponent_ComponentVersion) ProtoMessage()

func (*ChangeComponent_ComponentVersion) ProtoReflect

func (*ChangeComponent_ComponentVersion) Reset

func (*ChangeComponent_ComponentVersion) String

func (*ChangeComponent_ComponentVersion) Validate

func (this *ChangeComponent_ComponentVersion) Validate() error

type ChangePSMDBComponentsRequest

type ChangePSMDBComponentsRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string           `` /* 126-byte string literal not displayed */
	Mongod                *ChangeComponent `protobuf:"bytes,2,opt,name=mongod,proto3" json:"mongod,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangePSMDBComponentsRequest) Descriptor deprecated

func (*ChangePSMDBComponentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChangePSMDBComponentsRequest.ProtoReflect.Descriptor instead.

func (*ChangePSMDBComponentsRequest) GetKubernetesClusterName

func (x *ChangePSMDBComponentsRequest) GetKubernetesClusterName() string

func (*ChangePSMDBComponentsRequest) GetMongod

func (*ChangePSMDBComponentsRequest) ProtoMessage

func (*ChangePSMDBComponentsRequest) ProtoMessage()

func (*ChangePSMDBComponentsRequest) ProtoReflect

func (*ChangePSMDBComponentsRequest) Reset

func (x *ChangePSMDBComponentsRequest) Reset()

func (*ChangePSMDBComponentsRequest) String

func (*ChangePSMDBComponentsRequest) Validate

func (this *ChangePSMDBComponentsRequest) Validate() error

type ChangePSMDBComponentsResponse

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

func (*ChangePSMDBComponentsResponse) Descriptor deprecated

func (*ChangePSMDBComponentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChangePSMDBComponentsResponse.ProtoReflect.Descriptor instead.

func (*ChangePSMDBComponentsResponse) ProtoMessage

func (*ChangePSMDBComponentsResponse) ProtoMessage()

func (*ChangePSMDBComponentsResponse) ProtoReflect

func (*ChangePSMDBComponentsResponse) Reset

func (x *ChangePSMDBComponentsResponse) Reset()

func (*ChangePSMDBComponentsResponse) String

func (*ChangePSMDBComponentsResponse) Validate

func (this *ChangePSMDBComponentsResponse) Validate() error

type ChangePXCComponentsRequest

type ChangePXCComponentsRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string           `` /* 126-byte string literal not displayed */
	Pxc                   *ChangeComponent `protobuf:"bytes,2,opt,name=pxc,proto3" json:"pxc,omitempty"`
	Proxysql              *ChangeComponent `protobuf:"bytes,3,opt,name=proxysql,proto3" json:"proxysql,omitempty"`
	Haproxy               *ChangeComponent `protobuf:"bytes,4,opt,name=haproxy,proto3" json:"haproxy,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangePXCComponentsRequest) Descriptor deprecated

func (*ChangePXCComponentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChangePXCComponentsRequest.ProtoReflect.Descriptor instead.

func (*ChangePXCComponentsRequest) GetHaproxy

func (*ChangePXCComponentsRequest) GetKubernetesClusterName

func (x *ChangePXCComponentsRequest) GetKubernetesClusterName() string

func (*ChangePXCComponentsRequest) GetProxysql

func (x *ChangePXCComponentsRequest) GetProxysql() *ChangeComponent

func (*ChangePXCComponentsRequest) GetPxc

func (*ChangePXCComponentsRequest) ProtoMessage

func (*ChangePXCComponentsRequest) ProtoMessage()

func (*ChangePXCComponentsRequest) ProtoReflect

func (*ChangePXCComponentsRequest) Reset

func (x *ChangePXCComponentsRequest) Reset()

func (*ChangePXCComponentsRequest) String

func (x *ChangePXCComponentsRequest) String() string

func (*ChangePXCComponentsRequest) Validate

func (this *ChangePXCComponentsRequest) Validate() error

type ChangePXCComponentsResponse

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

func (*ChangePXCComponentsResponse) Descriptor deprecated

func (*ChangePXCComponentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChangePXCComponentsResponse.ProtoReflect.Descriptor instead.

func (*ChangePXCComponentsResponse) ProtoMessage

func (*ChangePXCComponentsResponse) ProtoMessage()

func (*ChangePXCComponentsResponse) ProtoReflect

func (*ChangePXCComponentsResponse) Reset

func (x *ChangePXCComponentsResponse) Reset()

func (*ChangePXCComponentsResponse) String

func (x *ChangePXCComponentsResponse) String() string

func (*ChangePXCComponentsResponse) Validate

func (this *ChangePXCComponentsResponse) Validate() error

type Component

type Component struct {
	ImagePath string `protobuf:"bytes,1,opt,name=image_path,json=imagePath,proto3" json:"image_path,omitempty"`
	ImageHash string `protobuf:"bytes,2,opt,name=image_hash,json=imageHash,proto3" json:"image_hash,omitempty"`
	Status    string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Critical  bool   `protobuf:"varint,4,opt,name=critical,proto3" json:"critical,omitempty"`
	Default   bool   `protobuf:"varint,5,opt,name=default,proto3" json:"default,omitempty"`
	Disabled  bool   `protobuf:"varint,6,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// contains filtered or unexported fields
}

Component contains information about component.

func (*Component) Descriptor deprecated

func (*Component) Descriptor() ([]byte, []int)

Deprecated: Use Component.ProtoReflect.Descriptor instead.

func (*Component) GetCritical

func (x *Component) GetCritical() bool

func (*Component) GetDefault

func (x *Component) GetDefault() bool

func (*Component) GetDisabled

func (x *Component) GetDisabled() bool

func (*Component) GetImageHash

func (x *Component) GetImageHash() string

func (*Component) GetImagePath

func (x *Component) GetImagePath() string

func (*Component) GetStatus

func (x *Component) GetStatus() string

func (*Component) ProtoMessage

func (*Component) ProtoMessage()

func (*Component) ProtoReflect

func (x *Component) ProtoReflect() protoreflect.Message

func (*Component) Reset

func (x *Component) Reset()

func (*Component) String

func (x *Component) String() string

func (*Component) Validate

func (this *Component) Validate() error

type ComponentsClient

type ComponentsClient interface {
	// GetPSMDBComponents returns list of available components for PSMDB Clusters.
	GetPSMDBComponents(ctx context.Context, in *GetPSMDBComponentsRequest, opts ...grpc.CallOption) (*GetPSMDBComponentsResponse, error)
	// GetPXCComponents returns list of available components for PXC Clusters.
	GetPXCComponents(ctx context.Context, in *GetPXCComponentsRequest, opts ...grpc.CallOption) (*GetPXCComponentsResponse, error)
	// ChangePSMDBComponents manages PSMDB related components.
	ChangePSMDBComponents(ctx context.Context, in *ChangePSMDBComponentsRequest, opts ...grpc.CallOption) (*ChangePSMDBComponentsResponse, error)
	// ChangePXCComponents manages PXC related components.
	ChangePXCComponents(ctx context.Context, in *ChangePXCComponentsRequest, opts ...grpc.CallOption) (*ChangePXCComponentsResponse, error)
}

ComponentsClient is the client API for Components service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewComponentsClient

func NewComponentsClient(cc grpc.ClientConnInterface) ComponentsClient

type ComponentsServer

type ComponentsServer interface {
	// GetPSMDBComponents returns list of available components for PSMDB Clusters.
	GetPSMDBComponents(context.Context, *GetPSMDBComponentsRequest) (*GetPSMDBComponentsResponse, error)
	// GetPXCComponents returns list of available components for PXC Clusters.
	GetPXCComponents(context.Context, *GetPXCComponentsRequest) (*GetPXCComponentsResponse, error)
	// ChangePSMDBComponents manages PSMDB related components.
	ChangePSMDBComponents(context.Context, *ChangePSMDBComponentsRequest) (*ChangePSMDBComponentsResponse, error)
	// ChangePXCComponents manages PXC related components.
	ChangePXCComponents(context.Context, *ChangePXCComponentsRequest) (*ChangePXCComponentsResponse, error)
}

ComponentsServer is the server API for Components service.

type ComputeResources

type ComputeResources struct {

	// CPUs in milliCPUs; 1000m = 1 vCPU.
	CpuM int32 `protobuf:"varint,1,opt,name=cpu_m,json=cpuM,proto3" json:"cpu_m,omitempty"`
	// Memory in bytes.
	MemoryBytes int64 `protobuf:"varint,2,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	// contains filtered or unexported fields
}

ComputeResources represents container computer resources requests or limits.

func (*ComputeResources) Descriptor deprecated

func (*ComputeResources) Descriptor() ([]byte, []int)

Deprecated: Use ComputeResources.ProtoReflect.Descriptor instead.

func (*ComputeResources) GetCpuM

func (x *ComputeResources) GetCpuM() int32

func (*ComputeResources) GetMemoryBytes

func (x *ComputeResources) GetMemoryBytes() int64

func (*ComputeResources) ProtoMessage

func (*ComputeResources) ProtoMessage()

func (*ComputeResources) ProtoReflect

func (x *ComputeResources) ProtoReflect() protoreflect.Message

func (*ComputeResources) Reset

func (x *ComputeResources) Reset()

func (*ComputeResources) String

func (x *ComputeResources) String() string

func (*ComputeResources) Validate

func (this *ComputeResources) Validate() error

type CreatePSMDBClusterRequest

type CreatePSMDBClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// PSMDB cluster name.
	// a DNS-1035 label must consist of lower case alphanumeric characters or '-',
	// start with an alphabetic character, and end with an alphanumeric character
	// (e.g. 'my-name',  or 'abc-123', regex used for validation is '[a-z]([-a-z0-9]*[a-z0-9])?')
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster parameters.
	Params *PSMDBClusterParams `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePSMDBClusterRequest) Descriptor deprecated

func (*CreatePSMDBClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreatePSMDBClusterRequest.ProtoReflect.Descriptor instead.

func (*CreatePSMDBClusterRequest) GetKubernetesClusterName

func (x *CreatePSMDBClusterRequest) GetKubernetesClusterName() string

func (*CreatePSMDBClusterRequest) GetName

func (x *CreatePSMDBClusterRequest) GetName() string

func (*CreatePSMDBClusterRequest) GetParams

func (*CreatePSMDBClusterRequest) ProtoMessage

func (*CreatePSMDBClusterRequest) ProtoMessage()

func (*CreatePSMDBClusterRequest) ProtoReflect

func (*CreatePSMDBClusterRequest) Reset

func (x *CreatePSMDBClusterRequest) Reset()

func (*CreatePSMDBClusterRequest) String

func (x *CreatePSMDBClusterRequest) String() string

func (*CreatePSMDBClusterRequest) Validate

func (this *CreatePSMDBClusterRequest) Validate() error

type CreatePSMDBClusterResponse

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

func (*CreatePSMDBClusterResponse) Descriptor deprecated

func (*CreatePSMDBClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreatePSMDBClusterResponse.ProtoReflect.Descriptor instead.

func (*CreatePSMDBClusterResponse) ProtoMessage

func (*CreatePSMDBClusterResponse) ProtoMessage()

func (*CreatePSMDBClusterResponse) ProtoReflect

func (*CreatePSMDBClusterResponse) Reset

func (x *CreatePSMDBClusterResponse) Reset()

func (*CreatePSMDBClusterResponse) String

func (x *CreatePSMDBClusterResponse) String() string

func (*CreatePSMDBClusterResponse) Validate

func (this *CreatePSMDBClusterResponse) Validate() error

type CreateXtraDBClusterRequest

type CreateXtraDBClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// XtraDB cluster name.
	// a DNS-1035 label must consist of lower case alphanumeric characters or '-',
	// start with an alphabetic character, and end with an alphanumeric character
	// (e.g. 'my-name',  or 'abc-123', regex used for validation is '[a-z]([-a-z0-9]*[a-z0-9])?')
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster parameters.
	Params *XtraDBClusterParams `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateXtraDBClusterRequest) Descriptor deprecated

func (*CreateXtraDBClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateXtraDBClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateXtraDBClusterRequest) GetKubernetesClusterName

func (x *CreateXtraDBClusterRequest) GetKubernetesClusterName() string

func (*CreateXtraDBClusterRequest) GetName

func (x *CreateXtraDBClusterRequest) GetName() string

func (*CreateXtraDBClusterRequest) GetParams

func (*CreateXtraDBClusterRequest) ProtoMessage

func (*CreateXtraDBClusterRequest) ProtoMessage()

func (*CreateXtraDBClusterRequest) ProtoReflect

func (*CreateXtraDBClusterRequest) Reset

func (x *CreateXtraDBClusterRequest) Reset()

func (*CreateXtraDBClusterRequest) String

func (x *CreateXtraDBClusterRequest) String() string

func (*CreateXtraDBClusterRequest) Validate

func (this *CreateXtraDBClusterRequest) Validate() error

type CreateXtraDBClusterResponse

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

func (*CreateXtraDBClusterResponse) Descriptor deprecated

func (*CreateXtraDBClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateXtraDBClusterResponse.ProtoReflect.Descriptor instead.

func (*CreateXtraDBClusterResponse) ProtoMessage

func (*CreateXtraDBClusterResponse) ProtoMessage()

func (*CreateXtraDBClusterResponse) ProtoReflect

func (*CreateXtraDBClusterResponse) Reset

func (x *CreateXtraDBClusterResponse) Reset()

func (*CreateXtraDBClusterResponse) String

func (x *CreateXtraDBClusterResponse) String() string

func (*CreateXtraDBClusterResponse) Validate

func (this *CreateXtraDBClusterResponse) Validate() error

type DeletePSMDBClusterRequest

type DeletePSMDBClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// PSMDB cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePSMDBClusterRequest) Descriptor deprecated

func (*DeletePSMDBClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeletePSMDBClusterRequest.ProtoReflect.Descriptor instead.

func (*DeletePSMDBClusterRequest) GetKubernetesClusterName

func (x *DeletePSMDBClusterRequest) GetKubernetesClusterName() string

func (*DeletePSMDBClusterRequest) GetName

func (x *DeletePSMDBClusterRequest) GetName() string

func (*DeletePSMDBClusterRequest) ProtoMessage

func (*DeletePSMDBClusterRequest) ProtoMessage()

func (*DeletePSMDBClusterRequest) ProtoReflect

func (*DeletePSMDBClusterRequest) Reset

func (x *DeletePSMDBClusterRequest) Reset()

func (*DeletePSMDBClusterRequest) String

func (x *DeletePSMDBClusterRequest) String() string

func (*DeletePSMDBClusterRequest) Validate

func (this *DeletePSMDBClusterRequest) Validate() error

type DeletePSMDBClusterResponse

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

func (*DeletePSMDBClusterResponse) Descriptor deprecated

func (*DeletePSMDBClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeletePSMDBClusterResponse.ProtoReflect.Descriptor instead.

func (*DeletePSMDBClusterResponse) ProtoMessage

func (*DeletePSMDBClusterResponse) ProtoMessage()

func (*DeletePSMDBClusterResponse) ProtoReflect

func (*DeletePSMDBClusterResponse) Reset

func (x *DeletePSMDBClusterResponse) Reset()

func (*DeletePSMDBClusterResponse) String

func (x *DeletePSMDBClusterResponse) String() string

func (*DeletePSMDBClusterResponse) Validate

func (this *DeletePSMDBClusterResponse) Validate() error

type DeleteXtraDBClusterRequest

type DeleteXtraDBClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// XtraDB cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteXtraDBClusterRequest) Descriptor deprecated

func (*DeleteXtraDBClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteXtraDBClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteXtraDBClusterRequest) GetKubernetesClusterName

func (x *DeleteXtraDBClusterRequest) GetKubernetesClusterName() string

func (*DeleteXtraDBClusterRequest) GetName

func (x *DeleteXtraDBClusterRequest) GetName() string

func (*DeleteXtraDBClusterRequest) ProtoMessage

func (*DeleteXtraDBClusterRequest) ProtoMessage()

func (*DeleteXtraDBClusterRequest) ProtoReflect

func (*DeleteXtraDBClusterRequest) Reset

func (x *DeleteXtraDBClusterRequest) Reset()

func (*DeleteXtraDBClusterRequest) String

func (x *DeleteXtraDBClusterRequest) String() string

func (*DeleteXtraDBClusterRequest) Validate

func (this *DeleteXtraDBClusterRequest) Validate() error

type DeleteXtraDBClusterResponse

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

func (*DeleteXtraDBClusterResponse) Descriptor deprecated

func (*DeleteXtraDBClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteXtraDBClusterResponse.ProtoReflect.Descriptor instead.

func (*DeleteXtraDBClusterResponse) ProtoMessage

func (*DeleteXtraDBClusterResponse) ProtoMessage()

func (*DeleteXtraDBClusterResponse) ProtoReflect

func (*DeleteXtraDBClusterResponse) Reset

func (x *DeleteXtraDBClusterResponse) Reset()

func (*DeleteXtraDBClusterResponse) String

func (x *DeleteXtraDBClusterResponse) String() string

func (*DeleteXtraDBClusterResponse) Validate

func (this *DeleteXtraDBClusterResponse) Validate() error

type GetKubernetesClusterRequest

type GetKubernetesClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetKubernetesClusterRequest) Descriptor deprecated

func (*GetKubernetesClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetKubernetesClusterRequest.ProtoReflect.Descriptor instead.

func (*GetKubernetesClusterRequest) GetKubernetesClusterName

func (x *GetKubernetesClusterRequest) GetKubernetesClusterName() string

func (*GetKubernetesClusterRequest) ProtoMessage

func (*GetKubernetesClusterRequest) ProtoMessage()

func (*GetKubernetesClusterRequest) ProtoReflect

func (*GetKubernetesClusterRequest) Reset

func (x *GetKubernetesClusterRequest) Reset()

func (*GetKubernetesClusterRequest) String

func (x *GetKubernetesClusterRequest) String() string

func (*GetKubernetesClusterRequest) Validate

func (this *GetKubernetesClusterRequest) Validate() error

type GetKubernetesClusterResponse

type GetKubernetesClusterResponse struct {

	// Kubernetes auth.
	KubeAuth *KubeAuth `protobuf:"bytes,1,opt,name=kube_auth,json=kubeAuth,proto3" json:"kube_auth,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKubernetesClusterResponse) Descriptor deprecated

func (*GetKubernetesClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetKubernetesClusterResponse.ProtoReflect.Descriptor instead.

func (*GetKubernetesClusterResponse) GetKubeAuth

func (x *GetKubernetesClusterResponse) GetKubeAuth() *KubeAuth

func (*GetKubernetesClusterResponse) ProtoMessage

func (*GetKubernetesClusterResponse) ProtoMessage()

func (*GetKubernetesClusterResponse) ProtoReflect

func (*GetKubernetesClusterResponse) Reset

func (x *GetKubernetesClusterResponse) Reset()

func (*GetKubernetesClusterResponse) String

func (*GetKubernetesClusterResponse) Validate

func (this *GetKubernetesClusterResponse) Validate() error

type GetLogsRequest

type GetLogsRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// DB cluster name.
	ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogsRequest) Descriptor deprecated

func (*GetLogsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.

func (*GetLogsRequest) GetClusterName

func (x *GetLogsRequest) GetClusterName() string

func (*GetLogsRequest) GetKubernetesClusterName

func (x *GetLogsRequest) GetKubernetesClusterName() string

func (*GetLogsRequest) ProtoMessage

func (*GetLogsRequest) ProtoMessage()

func (*GetLogsRequest) ProtoReflect

func (x *GetLogsRequest) ProtoReflect() protoreflect.Message

func (*GetLogsRequest) Reset

func (x *GetLogsRequest) Reset()

func (*GetLogsRequest) String

func (x *GetLogsRequest) String() string

func (*GetLogsRequest) Validate

func (this *GetLogsRequest) Validate() error

type GetLogsResponse

type GetLogsResponse struct {

	// Log represents list of logs. Each entry contains either container's logs or,
	// when container field is empty, pod's events.
	Logs []*Logs `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogsResponse) Descriptor deprecated

func (*GetLogsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetLogsResponse.ProtoReflect.Descriptor instead.

func (*GetLogsResponse) GetLogs

func (x *GetLogsResponse) GetLogs() []*Logs

func (*GetLogsResponse) ProtoMessage

func (*GetLogsResponse) ProtoMessage()

func (*GetLogsResponse) ProtoReflect

func (x *GetLogsResponse) ProtoReflect() protoreflect.Message

func (*GetLogsResponse) Reset

func (x *GetLogsResponse) Reset()

func (*GetLogsResponse) String

func (x *GetLogsResponse) String() string

func (*GetLogsResponse) Validate

func (this *GetLogsResponse) Validate() error

type GetPSMDBClusterCredentialsRequest

type GetPSMDBClusterCredentialsRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// PSMDB cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPSMDBClusterCredentialsRequest) Descriptor deprecated

func (*GetPSMDBClusterCredentialsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPSMDBClusterCredentialsRequest.ProtoReflect.Descriptor instead.

func (*GetPSMDBClusterCredentialsRequest) GetKubernetesClusterName

func (x *GetPSMDBClusterCredentialsRequest) GetKubernetesClusterName() string

func (*GetPSMDBClusterCredentialsRequest) GetName

func (*GetPSMDBClusterCredentialsRequest) ProtoMessage

func (*GetPSMDBClusterCredentialsRequest) ProtoMessage()

func (*GetPSMDBClusterCredentialsRequest) ProtoReflect

func (*GetPSMDBClusterCredentialsRequest) Reset

func (*GetPSMDBClusterCredentialsRequest) String

func (*GetPSMDBClusterCredentialsRequest) Validate

func (this *GetPSMDBClusterCredentialsRequest) Validate() error

type GetPSMDBClusterCredentialsResponse

type GetPSMDBClusterCredentialsResponse struct {
	ConnectionCredentials *GetPSMDBClusterCredentialsResponse_PSMDBCredentials `protobuf:"bytes,1,opt,name=connection_credentials,json=connectionCredentials,proto3" json:"connection_credentials,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPSMDBClusterCredentialsResponse) Descriptor deprecated

func (*GetPSMDBClusterCredentialsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPSMDBClusterCredentialsResponse.ProtoReflect.Descriptor instead.

func (*GetPSMDBClusterCredentialsResponse) GetConnectionCredentials

func (*GetPSMDBClusterCredentialsResponse) ProtoMessage

func (*GetPSMDBClusterCredentialsResponse) ProtoMessage()

func (*GetPSMDBClusterCredentialsResponse) ProtoReflect

func (*GetPSMDBClusterCredentialsResponse) Reset

func (*GetPSMDBClusterCredentialsResponse) String

func (*GetPSMDBClusterCredentialsResponse) Validate

func (this *GetPSMDBClusterCredentialsResponse) Validate() error

type GetPSMDBClusterCredentialsResponse_PSMDBCredentials

type GetPSMDBClusterCredentialsResponse_PSMDBCredentials struct {

	// MongoDB username.
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// MongoDB password.
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// MongoDB host.
	Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// MongoDB port.
	Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// Replicaset name.
	Replicaset string `protobuf:"bytes,5,opt,name=replicaset,proto3" json:"replicaset,omitempty"`
	// contains filtered or unexported fields
}

PSMDBCredentials is a credentials to connect to PSMDB. TODO Do not use inner messages in all public APIs (for consistency).

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) Descriptor deprecated

Deprecated: Use GetPSMDBClusterCredentialsResponse_PSMDBCredentials.ProtoReflect.Descriptor instead.

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) GetHost

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) GetPassword

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) GetPort

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) GetReplicaset

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) GetUsername

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) ProtoMessage

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) ProtoReflect

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) Reset

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) String

func (*GetPSMDBClusterCredentialsResponse_PSMDBCredentials) Validate

type GetPSMDBClusterResourcesRequest

type GetPSMDBClusterResourcesRequest struct {

	// Cluster parameters.
	Params *PSMDBClusterParams `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPSMDBClusterResourcesRequest) Descriptor deprecated

func (*GetPSMDBClusterResourcesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPSMDBClusterResourcesRequest.ProtoReflect.Descriptor instead.

func (*GetPSMDBClusterResourcesRequest) GetParams

func (*GetPSMDBClusterResourcesRequest) ProtoMessage

func (*GetPSMDBClusterResourcesRequest) ProtoMessage()

func (*GetPSMDBClusterResourcesRequest) ProtoReflect

func (*GetPSMDBClusterResourcesRequest) Reset

func (*GetPSMDBClusterResourcesRequest) String

func (*GetPSMDBClusterResourcesRequest) Validate

func (this *GetPSMDBClusterResourcesRequest) Validate() error

type GetPSMDBClusterResourcesResponse

type GetPSMDBClusterResourcesResponse struct {

	// Expected resources to be consumed by the cluster.
	Expected *Resources `protobuf:"bytes,1,opt,name=expected,proto3" json:"expected,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPSMDBClusterResourcesResponse) Descriptor deprecated

func (*GetPSMDBClusterResourcesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPSMDBClusterResourcesResponse.ProtoReflect.Descriptor instead.

func (*GetPSMDBClusterResourcesResponse) GetExpected

func (x *GetPSMDBClusterResourcesResponse) GetExpected() *Resources

func (*GetPSMDBClusterResourcesResponse) ProtoMessage

func (*GetPSMDBClusterResourcesResponse) ProtoMessage()

func (*GetPSMDBClusterResourcesResponse) ProtoReflect

func (*GetPSMDBClusterResourcesResponse) Reset

func (*GetPSMDBClusterResourcesResponse) String

func (*GetPSMDBClusterResourcesResponse) Validate

func (this *GetPSMDBClusterResourcesResponse) Validate() error

type GetPSMDBComponentsRequest

type GetPSMDBComponentsRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// Version of DB.
	DbVersion string `protobuf:"bytes,2,opt,name=db_version,json=dbVersion,proto3" json:"db_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPSMDBComponentsRequest) Descriptor deprecated

func (*GetPSMDBComponentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPSMDBComponentsRequest.ProtoReflect.Descriptor instead.

func (*GetPSMDBComponentsRequest) GetDbVersion

func (x *GetPSMDBComponentsRequest) GetDbVersion() string

func (*GetPSMDBComponentsRequest) GetKubernetesClusterName

func (x *GetPSMDBComponentsRequest) GetKubernetesClusterName() string

func (*GetPSMDBComponentsRequest) ProtoMessage

func (*GetPSMDBComponentsRequest) ProtoMessage()

func (*GetPSMDBComponentsRequest) ProtoReflect

func (*GetPSMDBComponentsRequest) Reset

func (x *GetPSMDBComponentsRequest) Reset()

func (*GetPSMDBComponentsRequest) String

func (x *GetPSMDBComponentsRequest) String() string

func (*GetPSMDBComponentsRequest) Validate

func (this *GetPSMDBComponentsRequest) Validate() error

type GetPSMDBComponentsResponse

type GetPSMDBComponentsResponse struct {
	Versions []*OperatorVersion `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPSMDBComponentsResponse) Descriptor deprecated

func (*GetPSMDBComponentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPSMDBComponentsResponse.ProtoReflect.Descriptor instead.

func (*GetPSMDBComponentsResponse) GetVersions

func (x *GetPSMDBComponentsResponse) GetVersions() []*OperatorVersion

func (*GetPSMDBComponentsResponse) ProtoMessage

func (*GetPSMDBComponentsResponse) ProtoMessage()

func (*GetPSMDBComponentsResponse) ProtoReflect

func (*GetPSMDBComponentsResponse) Reset

func (x *GetPSMDBComponentsResponse) Reset()

func (*GetPSMDBComponentsResponse) String

func (x *GetPSMDBComponentsResponse) String() string

func (*GetPSMDBComponentsResponse) Validate

func (this *GetPSMDBComponentsResponse) Validate() error

type GetPXCComponentsRequest

type GetPXCComponentsRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// Version of DB.
	DbVersion string `protobuf:"bytes,2,opt,name=db_version,json=dbVersion,proto3" json:"db_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPXCComponentsRequest) Descriptor deprecated

func (*GetPXCComponentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPXCComponentsRequest.ProtoReflect.Descriptor instead.

func (*GetPXCComponentsRequest) GetDbVersion

func (x *GetPXCComponentsRequest) GetDbVersion() string

func (*GetPXCComponentsRequest) GetKubernetesClusterName

func (x *GetPXCComponentsRequest) GetKubernetesClusterName() string

func (*GetPXCComponentsRequest) ProtoMessage

func (*GetPXCComponentsRequest) ProtoMessage()

func (*GetPXCComponentsRequest) ProtoReflect

func (x *GetPXCComponentsRequest) ProtoReflect() protoreflect.Message

func (*GetPXCComponentsRequest) Reset

func (x *GetPXCComponentsRequest) Reset()

func (*GetPXCComponentsRequest) String

func (x *GetPXCComponentsRequest) String() string

func (*GetPXCComponentsRequest) Validate

func (this *GetPXCComponentsRequest) Validate() error

type GetPXCComponentsResponse

type GetPXCComponentsResponse struct {
	Versions []*OperatorVersion `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPXCComponentsResponse) Descriptor deprecated

func (*GetPXCComponentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPXCComponentsResponse.ProtoReflect.Descriptor instead.

func (*GetPXCComponentsResponse) GetVersions

func (x *GetPXCComponentsResponse) GetVersions() []*OperatorVersion

func (*GetPXCComponentsResponse) ProtoMessage

func (*GetPXCComponentsResponse) ProtoMessage()

func (*GetPXCComponentsResponse) ProtoReflect

func (x *GetPXCComponentsResponse) ProtoReflect() protoreflect.Message

func (*GetPXCComponentsResponse) Reset

func (x *GetPXCComponentsResponse) Reset()

func (*GetPXCComponentsResponse) String

func (x *GetPXCComponentsResponse) String() string

func (*GetPXCComponentsResponse) Validate

func (this *GetPXCComponentsResponse) Validate() error

type GetResourcesRequest

type GetResourcesRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetResourcesRequest) Descriptor deprecated

func (*GetResourcesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetResourcesRequest.ProtoReflect.Descriptor instead.

func (*GetResourcesRequest) GetKubernetesClusterName

func (x *GetResourcesRequest) GetKubernetesClusterName() string

func (*GetResourcesRequest) ProtoMessage

func (*GetResourcesRequest) ProtoMessage()

func (*GetResourcesRequest) ProtoReflect

func (x *GetResourcesRequest) ProtoReflect() protoreflect.Message

func (*GetResourcesRequest) Reset

func (x *GetResourcesRequest) Reset()

func (*GetResourcesRequest) String

func (x *GetResourcesRequest) String() string

func (*GetResourcesRequest) Validate

func (this *GetResourcesRequest) Validate() error

type GetResourcesResponse

type GetResourcesResponse struct {

	// The total amount of resources of the Kubernetes cluster.
	All *Resources `protobuf:"bytes,1,opt,name=all,proto3" json:"all,omitempty"`
	// The amount of resources that is available for consumption by future Kubernetes workloads.
	Available *Resources `protobuf:"bytes,2,opt,name=available,proto3" json:"available,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResourcesResponse) Descriptor deprecated

func (*GetResourcesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetResourcesResponse.ProtoReflect.Descriptor instead.

func (*GetResourcesResponse) GetAll

func (x *GetResourcesResponse) GetAll() *Resources

func (*GetResourcesResponse) GetAvailable

func (x *GetResourcesResponse) GetAvailable() *Resources

func (*GetResourcesResponse) ProtoMessage

func (*GetResourcesResponse) ProtoMessage()

func (*GetResourcesResponse) ProtoReflect

func (x *GetResourcesResponse) ProtoReflect() protoreflect.Message

func (*GetResourcesResponse) Reset

func (x *GetResourcesResponse) Reset()

func (*GetResourcesResponse) String

func (x *GetResourcesResponse) String() string

func (*GetResourcesResponse) Validate

func (this *GetResourcesResponse) Validate() error

type GetXtraDBClusterCredentialsRequest

type GetXtraDBClusterCredentialsRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// XtraDB cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetXtraDBClusterCredentialsRequest) Descriptor deprecated

func (*GetXtraDBClusterCredentialsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetXtraDBClusterCredentialsRequest.ProtoReflect.Descriptor instead.

func (*GetXtraDBClusterCredentialsRequest) GetKubernetesClusterName

func (x *GetXtraDBClusterCredentialsRequest) GetKubernetesClusterName() string

func (*GetXtraDBClusterCredentialsRequest) GetName

func (*GetXtraDBClusterCredentialsRequest) ProtoMessage

func (*GetXtraDBClusterCredentialsRequest) ProtoMessage()

func (*GetXtraDBClusterCredentialsRequest) ProtoReflect

func (*GetXtraDBClusterCredentialsRequest) Reset

func (*GetXtraDBClusterCredentialsRequest) String

func (*GetXtraDBClusterCredentialsRequest) Validate

func (this *GetXtraDBClusterCredentialsRequest) Validate() error

type GetXtraDBClusterCredentialsResponse

type GetXtraDBClusterCredentialsResponse struct {

	// Cluster connection credentials.
	ConnectionCredentials *XtraDBClusterConnectionCredentials `protobuf:"bytes,1,opt,name=connection_credentials,json=connectionCredentials,proto3" json:"connection_credentials,omitempty"`
	// contains filtered or unexported fields
}

func (*GetXtraDBClusterCredentialsResponse) Descriptor deprecated

func (*GetXtraDBClusterCredentialsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetXtraDBClusterCredentialsResponse.ProtoReflect.Descriptor instead.

func (*GetXtraDBClusterCredentialsResponse) GetConnectionCredentials

func (*GetXtraDBClusterCredentialsResponse) ProtoMessage

func (*GetXtraDBClusterCredentialsResponse) ProtoMessage()

func (*GetXtraDBClusterCredentialsResponse) ProtoReflect

func (*GetXtraDBClusterCredentialsResponse) Reset

func (*GetXtraDBClusterCredentialsResponse) String

func (*GetXtraDBClusterCredentialsResponse) Validate

func (this *GetXtraDBClusterCredentialsResponse) Validate() error

type GetXtraDBClusterResourcesRequest

type GetXtraDBClusterResourcesRequest struct {

	// Cluster parameters.
	Params *XtraDBClusterParams `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*GetXtraDBClusterResourcesRequest) Descriptor deprecated

func (*GetXtraDBClusterResourcesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetXtraDBClusterResourcesRequest.ProtoReflect.Descriptor instead.

func (*GetXtraDBClusterResourcesRequest) GetParams

func (*GetXtraDBClusterResourcesRequest) ProtoMessage

func (*GetXtraDBClusterResourcesRequest) ProtoMessage()

func (*GetXtraDBClusterResourcesRequest) ProtoReflect

func (*GetXtraDBClusterResourcesRequest) Reset

func (*GetXtraDBClusterResourcesRequest) String

func (*GetXtraDBClusterResourcesRequest) Validate

func (this *GetXtraDBClusterResourcesRequest) Validate() error

type GetXtraDBClusterResourcesResponse

type GetXtraDBClusterResourcesResponse struct {

	// Expected resources to be consumed by the cluster.
	Expected *Resources `protobuf:"bytes,1,opt,name=expected,proto3" json:"expected,omitempty"`
	// contains filtered or unexported fields
}

func (*GetXtraDBClusterResourcesResponse) Descriptor deprecated

func (*GetXtraDBClusterResourcesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetXtraDBClusterResourcesResponse.ProtoReflect.Descriptor instead.

func (*GetXtraDBClusterResourcesResponse) GetExpected

func (x *GetXtraDBClusterResourcesResponse) GetExpected() *Resources

func (*GetXtraDBClusterResourcesResponse) ProtoMessage

func (*GetXtraDBClusterResourcesResponse) ProtoMessage()

func (*GetXtraDBClusterResourcesResponse) ProtoReflect

func (*GetXtraDBClusterResourcesResponse) Reset

func (*GetXtraDBClusterResourcesResponse) String

func (*GetXtraDBClusterResourcesResponse) Validate

func (this *GetXtraDBClusterResourcesResponse) Validate() error

type KubeAuth

type KubeAuth struct {

	// Kubeconfig file content.
	Kubeconfig string `protobuf:"bytes,1,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
	// contains filtered or unexported fields
}

KubeAuth represents Kubernetes / kubectl authentication and authorization information.

func (*KubeAuth) Descriptor deprecated

func (*KubeAuth) Descriptor() ([]byte, []int)

Deprecated: Use KubeAuth.ProtoReflect.Descriptor instead.

func (*KubeAuth) GetKubeconfig

func (x *KubeAuth) GetKubeconfig() string

func (*KubeAuth) ProtoMessage

func (*KubeAuth) ProtoMessage()

func (*KubeAuth) ProtoReflect

func (x *KubeAuth) ProtoReflect() protoreflect.Message

func (*KubeAuth) Reset

func (x *KubeAuth) Reset()

func (*KubeAuth) String

func (x *KubeAuth) String() string

func (*KubeAuth) Validate

func (this *KubeAuth) Validate() error

type KubernetesClient

type KubernetesClient interface {
	// ListKubernetesClusters returns a list of all registered Kubernetes clusters.
	ListKubernetesClusters(ctx context.Context, in *ListKubernetesClustersRequest, opts ...grpc.CallOption) (*ListKubernetesClustersResponse, error)
	// RegisterKubernetesCluster registers an existing Kubernetes cluster in PMM.
	RegisterKubernetesCluster(ctx context.Context, in *RegisterKubernetesClusterRequest, opts ...grpc.CallOption) (*RegisterKubernetesClusterResponse, error)
	// UnregisterKubernetesCluster removes a registered Kubernetes cluster from PMM.
	UnregisterKubernetesCluster(ctx context.Context, in *UnregisterKubernetesClusterRequest, opts ...grpc.CallOption) (*UnregisterKubernetesClusterResponse, error)
	// GetKubernetesCluster return KubeAuth with Kubernetes config.
	GetKubernetesCluster(ctx context.Context, in *GetKubernetesClusterRequest, opts ...grpc.CallOption) (*GetKubernetesClusterResponse, error)
	// GetResources returns all and available resources of a Kubernetes cluster.
	// NOTE: The user defined in kubeconfig for the cluster has to have rights to
	//       list and get Pods from all Namespaces. Also getting and listing Nodes
	//       has to be allowed.
	GetResources(ctx context.Context, in *GetResourcesRequest, opts ...grpc.CallOption) (*GetResourcesResponse, error)
}

KubernetesClient is the client API for Kubernetes service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewKubernetesClient

func NewKubernetesClient(cc grpc.ClientConnInterface) KubernetesClient

type KubernetesClusterStatus

type KubernetesClusterStatus int32

KubernetesClusterStatus defines status of Kubernetes cluster.

const (
	// KUBERNETES_CLUSTER_STATUS_INVALID represents unknown state.
	KubernetesClusterStatus_KUBERNETES_CLUSTER_STATUS_INVALID KubernetesClusterStatus = 0
	// KUBERNETES_CLUSTER_STATUS_OK represents that Kubernetes cluster is accessible.
	KubernetesClusterStatus_KUBERNETES_CLUSTER_STATUS_OK KubernetesClusterStatus = 1
	// KUBERNETES_CLUSTER_STATUS_UNAVAILABLE represents that Kubernetes cluster is not accessible.
	KubernetesClusterStatus_KUBERNETES_CLUSTER_STATUS_UNAVAILABLE KubernetesClusterStatus = 2
)

func (KubernetesClusterStatus) Descriptor

func (KubernetesClusterStatus) Enum

func (KubernetesClusterStatus) EnumDescriptor deprecated

func (KubernetesClusterStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use KubernetesClusterStatus.Descriptor instead.

func (KubernetesClusterStatus) Number

func (KubernetesClusterStatus) String

func (x KubernetesClusterStatus) String() string

func (KubernetesClusterStatus) Type

type KubernetesServer

type KubernetesServer interface {
	// ListKubernetesClusters returns a list of all registered Kubernetes clusters.
	ListKubernetesClusters(context.Context, *ListKubernetesClustersRequest) (*ListKubernetesClustersResponse, error)
	// RegisterKubernetesCluster registers an existing Kubernetes cluster in PMM.
	RegisterKubernetesCluster(context.Context, *RegisterKubernetesClusterRequest) (*RegisterKubernetesClusterResponse, error)
	// UnregisterKubernetesCluster removes a registered Kubernetes cluster from PMM.
	UnregisterKubernetesCluster(context.Context, *UnregisterKubernetesClusterRequest) (*UnregisterKubernetesClusterResponse, error)
	// GetKubernetesCluster return KubeAuth with Kubernetes config.
	GetKubernetesCluster(context.Context, *GetKubernetesClusterRequest) (*GetKubernetesClusterResponse, error)
	// GetResources returns all and available resources of a Kubernetes cluster.
	// NOTE: The user defined in kubeconfig for the cluster has to have rights to
	//       list and get Pods from all Namespaces. Also getting and listing Nodes
	//       has to be allowed.
	GetResources(context.Context, *GetResourcesRequest) (*GetResourcesResponse, error)
}

KubernetesServer is the server API for Kubernetes service.

type ListKubernetesClustersRequest

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

func (*ListKubernetesClustersRequest) Descriptor deprecated

func (*ListKubernetesClustersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListKubernetesClustersRequest.ProtoReflect.Descriptor instead.

func (*ListKubernetesClustersRequest) ProtoMessage

func (*ListKubernetesClustersRequest) ProtoMessage()

func (*ListKubernetesClustersRequest) ProtoReflect

func (*ListKubernetesClustersRequest) Reset

func (x *ListKubernetesClustersRequest) Reset()

func (*ListKubernetesClustersRequest) String

func (*ListKubernetesClustersRequest) Validate

func (this *ListKubernetesClustersRequest) Validate() error

type ListKubernetesClustersResponse

type ListKubernetesClustersResponse struct {

	// Kubernetes clusters.
	KubernetesClusters []*ListKubernetesClustersResponse_Cluster `protobuf:"bytes,1,rep,name=kubernetes_clusters,json=kubernetesClusters,proto3" json:"kubernetes_clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKubernetesClustersResponse) Descriptor deprecated

func (*ListKubernetesClustersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListKubernetesClustersResponse.ProtoReflect.Descriptor instead.

func (*ListKubernetesClustersResponse) GetKubernetesClusters

func (*ListKubernetesClustersResponse) ProtoMessage

func (*ListKubernetesClustersResponse) ProtoMessage()

func (*ListKubernetesClustersResponse) ProtoReflect

func (*ListKubernetesClustersResponse) Reset

func (x *ListKubernetesClustersResponse) Reset()

func (*ListKubernetesClustersResponse) String

func (*ListKubernetesClustersResponse) Validate

func (this *ListKubernetesClustersResponse) Validate() error

type ListKubernetesClustersResponse_Cluster

type ListKubernetesClustersResponse_Cluster struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// Installed operators.
	Operators *Operators `protobuf:"bytes,2,opt,name=operators,proto3" json:"operators,omitempty"`
	// Status of Kubernetes cluster.
	Status KubernetesClusterStatus `protobuf:"varint,3,opt,name=status,proto3,enum=dbaas.v1beta1.KubernetesClusterStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Cluster contains public info about Kubernetes cluster. TODO Do not use inner messages in all public APIs (for consistency).

func (*ListKubernetesClustersResponse_Cluster) Descriptor deprecated

func (*ListKubernetesClustersResponse_Cluster) Descriptor() ([]byte, []int)

Deprecated: Use ListKubernetesClustersResponse_Cluster.ProtoReflect.Descriptor instead.

func (*ListKubernetesClustersResponse_Cluster) GetKubernetesClusterName

func (x *ListKubernetesClustersResponse_Cluster) GetKubernetesClusterName() string

func (*ListKubernetesClustersResponse_Cluster) GetOperators

func (*ListKubernetesClustersResponse_Cluster) GetStatus

func (*ListKubernetesClustersResponse_Cluster) ProtoMessage

func (*ListKubernetesClustersResponse_Cluster) ProtoReflect

func (*ListKubernetesClustersResponse_Cluster) Reset

func (*ListKubernetesClustersResponse_Cluster) String

func (*ListKubernetesClustersResponse_Cluster) Validate

type ListPSMDBClustersRequest

type ListPSMDBClustersRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListPSMDBClustersRequest) Descriptor deprecated

func (*ListPSMDBClustersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListPSMDBClustersRequest.ProtoReflect.Descriptor instead.

func (*ListPSMDBClustersRequest) GetKubernetesClusterName

func (x *ListPSMDBClustersRequest) GetKubernetesClusterName() string

func (*ListPSMDBClustersRequest) ProtoMessage

func (*ListPSMDBClustersRequest) ProtoMessage()

func (*ListPSMDBClustersRequest) ProtoReflect

func (x *ListPSMDBClustersRequest) ProtoReflect() protoreflect.Message

func (*ListPSMDBClustersRequest) Reset

func (x *ListPSMDBClustersRequest) Reset()

func (*ListPSMDBClustersRequest) String

func (x *ListPSMDBClustersRequest) String() string

func (*ListPSMDBClustersRequest) Validate

func (this *ListPSMDBClustersRequest) Validate() error

type ListPSMDBClustersResponse

type ListPSMDBClustersResponse struct {

	// PSMDB clusters information.
	Clusters []*ListPSMDBClustersResponse_Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPSMDBClustersResponse) Descriptor deprecated

func (*ListPSMDBClustersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListPSMDBClustersResponse.ProtoReflect.Descriptor instead.

func (*ListPSMDBClustersResponse) GetClusters

func (*ListPSMDBClustersResponse) ProtoMessage

func (*ListPSMDBClustersResponse) ProtoMessage()

func (*ListPSMDBClustersResponse) ProtoReflect

func (*ListPSMDBClustersResponse) Reset

func (x *ListPSMDBClustersResponse) Reset()

func (*ListPSMDBClustersResponse) String

func (x *ListPSMDBClustersResponse) String() string

func (*ListPSMDBClustersResponse) Validate

func (this *ListPSMDBClustersResponse) Validate() error

type ListPSMDBClustersResponse_Cluster

type ListPSMDBClustersResponse_Cluster struct {

	// Cluster name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster state.
	State PSMDBClusterState `protobuf:"varint,2,opt,name=state,proto3,enum=dbaas.v1beta1.PSMDBClusterState" json:"state,omitempty"`
	// Currently running operation, if any.
	Operation *RunningOperation `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	// Cluster parameters.
	Params *PSMDBClusterParams `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

Cluster represents PSMDB cluster information. TODO Do not use inner messages in all public APIs (for consistency).

func (*ListPSMDBClustersResponse_Cluster) Descriptor deprecated

func (*ListPSMDBClustersResponse_Cluster) Descriptor() ([]byte, []int)

Deprecated: Use ListPSMDBClustersResponse_Cluster.ProtoReflect.Descriptor instead.

func (*ListPSMDBClustersResponse_Cluster) GetName

func (*ListPSMDBClustersResponse_Cluster) GetOperation

func (*ListPSMDBClustersResponse_Cluster) GetParams

func (*ListPSMDBClustersResponse_Cluster) GetState

func (*ListPSMDBClustersResponse_Cluster) ProtoMessage

func (*ListPSMDBClustersResponse_Cluster) ProtoMessage()

func (*ListPSMDBClustersResponse_Cluster) ProtoReflect

func (*ListPSMDBClustersResponse_Cluster) Reset

func (*ListPSMDBClustersResponse_Cluster) String

func (*ListPSMDBClustersResponse_Cluster) Validate

func (this *ListPSMDBClustersResponse_Cluster) Validate() error

type ListXtraDBClustersRequest

type ListXtraDBClustersRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListXtraDBClustersRequest) Descriptor deprecated

func (*ListXtraDBClustersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListXtraDBClustersRequest.ProtoReflect.Descriptor instead.

func (*ListXtraDBClustersRequest) GetKubernetesClusterName

func (x *ListXtraDBClustersRequest) GetKubernetesClusterName() string

func (*ListXtraDBClustersRequest) ProtoMessage

func (*ListXtraDBClustersRequest) ProtoMessage()

func (*ListXtraDBClustersRequest) ProtoReflect

func (*ListXtraDBClustersRequest) Reset

func (x *ListXtraDBClustersRequest) Reset()

func (*ListXtraDBClustersRequest) String

func (x *ListXtraDBClustersRequest) String() string

func (*ListXtraDBClustersRequest) Validate

func (this *ListXtraDBClustersRequest) Validate() error

type ListXtraDBClustersResponse

type ListXtraDBClustersResponse struct {

	// XtraDB clusters information.
	Clusters []*ListXtraDBClustersResponse_Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListXtraDBClustersResponse) Descriptor deprecated

func (*ListXtraDBClustersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListXtraDBClustersResponse.ProtoReflect.Descriptor instead.

func (*ListXtraDBClustersResponse) GetClusters

func (*ListXtraDBClustersResponse) ProtoMessage

func (*ListXtraDBClustersResponse) ProtoMessage()

func (*ListXtraDBClustersResponse) ProtoReflect

func (*ListXtraDBClustersResponse) Reset

func (x *ListXtraDBClustersResponse) Reset()

func (*ListXtraDBClustersResponse) String

func (x *ListXtraDBClustersResponse) String() string

func (*ListXtraDBClustersResponse) Validate

func (this *ListXtraDBClustersResponse) Validate() error

type ListXtraDBClustersResponse_Cluster

type ListXtraDBClustersResponse_Cluster struct {

	// Cluster name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster state.
	State XtraDBClusterState `protobuf:"varint,2,opt,name=state,proto3,enum=dbaas.v1beta1.XtraDBClusterState" json:"state,omitempty"`
	// Currently running operation, if any.
	Operation *RunningOperation `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	// Cluster parameters.
	Params *XtraDBClusterParams `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

Cluster represents XtraDB cluster information. TODO Do not use inner messages in all public APIs (for consistency).

func (*ListXtraDBClustersResponse_Cluster) Descriptor deprecated

func (*ListXtraDBClustersResponse_Cluster) Descriptor() ([]byte, []int)

Deprecated: Use ListXtraDBClustersResponse_Cluster.ProtoReflect.Descriptor instead.

func (*ListXtraDBClustersResponse_Cluster) GetName

func (*ListXtraDBClustersResponse_Cluster) GetOperation

func (*ListXtraDBClustersResponse_Cluster) GetParams

func (*ListXtraDBClustersResponse_Cluster) GetState

func (*ListXtraDBClustersResponse_Cluster) ProtoMessage

func (*ListXtraDBClustersResponse_Cluster) ProtoMessage()

func (*ListXtraDBClustersResponse_Cluster) ProtoReflect

func (*ListXtraDBClustersResponse_Cluster) Reset

func (*ListXtraDBClustersResponse_Cluster) String

func (*ListXtraDBClustersResponse_Cluster) Validate

func (this *ListXtraDBClustersResponse_Cluster) Validate() error

type Logs

type Logs struct {

	// Pod name.
	Pod string `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"`
	// Container name.
	Container string `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	// Content of container's log or pod's events.
	Logs []string `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

Logs contain logs for certain pod's container. If container is an empty string, logs contain pod's events.

func (*Logs) Descriptor deprecated

func (*Logs) Descriptor() ([]byte, []int)

Deprecated: Use Logs.ProtoReflect.Descriptor instead.

func (*Logs) GetContainer

func (x *Logs) GetContainer() string

func (*Logs) GetLogs

func (x *Logs) GetLogs() []string

func (*Logs) GetPod

func (x *Logs) GetPod() string

func (*Logs) ProtoMessage

func (*Logs) ProtoMessage()

func (*Logs) ProtoReflect

func (x *Logs) ProtoReflect() protoreflect.Message

func (*Logs) Reset

func (x *Logs) Reset()

func (*Logs) String

func (x *Logs) String() string

func (*Logs) Validate

func (this *Logs) Validate() error

type LogsAPIClient

type LogsAPIClient interface {
	// GetLogs gets all logs from db cluster.
	GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*GetLogsResponse, error)
}

LogsAPIClient is the client API for LogsAPI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLogsAPIClient

func NewLogsAPIClient(cc grpc.ClientConnInterface) LogsAPIClient

type LogsAPIServer

type LogsAPIServer interface {
	// GetLogs gets all logs from db cluster.
	GetLogs(context.Context, *GetLogsRequest) (*GetLogsResponse, error)
}

LogsAPIServer is the server API for LogsAPI service.

type Matrix

type Matrix struct {
	Mongod       map[string]*Component `` /* 153-byte string literal not displayed */
	Pxc          map[string]*Component `` /* 147-byte string literal not displayed */
	Pmm          map[string]*Component `` /* 147-byte string literal not displayed */
	Proxysql     map[string]*Component `` /* 157-byte string literal not displayed */
	Haproxy      map[string]*Component `` /* 155-byte string literal not displayed */
	Backup       map[string]*Component `` /* 153-byte string literal not displayed */
	Operator     map[string]*Component `` /* 157-byte string literal not displayed */
	LogCollector map[string]*Component `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

Matrix contains all available components.

func (*Matrix) Descriptor deprecated

func (*Matrix) Descriptor() ([]byte, []int)

Deprecated: Use Matrix.ProtoReflect.Descriptor instead.

func (*Matrix) GetBackup

func (x *Matrix) GetBackup() map[string]*Component

func (*Matrix) GetHaproxy

func (x *Matrix) GetHaproxy() map[string]*Component

func (*Matrix) GetLogCollector

func (x *Matrix) GetLogCollector() map[string]*Component

func (*Matrix) GetMongod

func (x *Matrix) GetMongod() map[string]*Component

func (*Matrix) GetOperator

func (x *Matrix) GetOperator() map[string]*Component

func (*Matrix) GetPmm

func (x *Matrix) GetPmm() map[string]*Component

func (*Matrix) GetProxysql

func (x *Matrix) GetProxysql() map[string]*Component

func (*Matrix) GetPxc

func (x *Matrix) GetPxc() map[string]*Component

func (*Matrix) ProtoMessage

func (*Matrix) ProtoMessage()

func (*Matrix) ProtoReflect

func (x *Matrix) ProtoReflect() protoreflect.Message

func (*Matrix) Reset

func (x *Matrix) Reset()

func (*Matrix) String

func (x *Matrix) String() string

func (*Matrix) Validate

func (this *Matrix) Validate() error

type Operator

type Operator struct {
	Status OperatorsStatus `protobuf:"varint,1,opt,name=status,proto3,enum=dbaas.v1beta1.OperatorsStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Operator contains all information about operator installed in Kubernetes cluster.

func (*Operator) Descriptor deprecated

func (*Operator) Descriptor() ([]byte, []int)

Deprecated: Use Operator.ProtoReflect.Descriptor instead.

func (*Operator) GetStatus

func (x *Operator) GetStatus() OperatorsStatus

func (*Operator) ProtoMessage

func (*Operator) ProtoMessage()

func (*Operator) ProtoReflect

func (x *Operator) ProtoReflect() protoreflect.Message

func (*Operator) Reset

func (x *Operator) Reset()

func (*Operator) String

func (x *Operator) String() string

func (*Operator) Validate

func (this *Operator) Validate() error

type OperatorVersion

type OperatorVersion struct {
	Product  string  `protobuf:"bytes,1,opt,name=product,proto3" json:"product,omitempty"`
	Operator string  `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	Matrix   *Matrix `protobuf:"bytes,3,opt,name=matrix,proto3" json:"matrix,omitempty"`
	// contains filtered or unexported fields
}

OperatorVersion contains information about operator and components matrix.

func (*OperatorVersion) Descriptor deprecated

func (*OperatorVersion) Descriptor() ([]byte, []int)

Deprecated: Use OperatorVersion.ProtoReflect.Descriptor instead.

func (*OperatorVersion) GetMatrix

func (x *OperatorVersion) GetMatrix() *Matrix

func (*OperatorVersion) GetOperator

func (x *OperatorVersion) GetOperator() string

func (*OperatorVersion) GetProduct

func (x *OperatorVersion) GetProduct() string

func (*OperatorVersion) ProtoMessage

func (*OperatorVersion) ProtoMessage()

func (*OperatorVersion) ProtoReflect

func (x *OperatorVersion) ProtoReflect() protoreflect.Message

func (*OperatorVersion) Reset

func (x *OperatorVersion) Reset()

func (*OperatorVersion) String

func (x *OperatorVersion) String() string

func (*OperatorVersion) Validate

func (this *OperatorVersion) Validate() error

type Operators

type Operators struct {

	// Percona XtraDB Cluster Operator.
	Xtradb *Operator `protobuf:"bytes,1,opt,name=xtradb,proto3" json:"xtradb,omitempty"`
	// Percona Server for MongoDB Operator.
	Psmdb *Operator `protobuf:"bytes,2,opt,name=psmdb,proto3" json:"psmdb,omitempty"`
	// contains filtered or unexported fields
}

Operators contains list of operators installed in Kubernetes cluster.

func (*Operators) Descriptor deprecated

func (*Operators) Descriptor() ([]byte, []int)

Deprecated: Use Operators.ProtoReflect.Descriptor instead.

func (*Operators) GetPsmdb

func (x *Operators) GetPsmdb() *Operator

func (*Operators) GetXtradb

func (x *Operators) GetXtradb() *Operator

func (*Operators) ProtoMessage

func (*Operators) ProtoMessage()

func (*Operators) ProtoReflect

func (x *Operators) ProtoReflect() protoreflect.Message

func (*Operators) Reset

func (x *Operators) Reset()

func (*Operators) String

func (x *Operators) String() string

func (*Operators) Validate

func (this *Operators) Validate() error

type OperatorsStatus

type OperatorsStatus int32

OperatorsStatus defines status of operators installed in Kubernetes cluster.

const (
	// OPERATORS_STATUS_INVALID represents unknown state.
	OperatorsStatus_OPERATORS_STATUS_INVALID OperatorsStatus = 0
	// OPERATORS_STATUS_OK represents that operators are installed and have supported API version.
	OperatorsStatus_OPERATORS_STATUS_OK OperatorsStatus = 1
	// OPERATORS_STATUS_UNSUPPORTED represents that operators are installed, but doesn't have supported API version.
	OperatorsStatus_OPERATORS_STATUS_UNSUPPORTED OperatorsStatus = 2
	// OPERATORS_STATUS_NOT_INSTALLED represents that operators are not installed.
	OperatorsStatus_OPERATORS_STATUS_NOT_INSTALLED OperatorsStatus = 3
)

func (OperatorsStatus) Descriptor

func (OperatorsStatus) Enum

func (x OperatorsStatus) Enum() *OperatorsStatus

func (OperatorsStatus) EnumDescriptor deprecated

func (OperatorsStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use OperatorsStatus.Descriptor instead.

func (OperatorsStatus) Number

func (OperatorsStatus) String

func (x OperatorsStatus) String() string

func (OperatorsStatus) Type

type PSMDBClusterClient

type PSMDBClusterClient interface {
	// ListPSMDBClusters returns a list of PSMDB clusters.
	ListPSMDBClusters(ctx context.Context, in *ListPSMDBClustersRequest, opts ...grpc.CallOption) (*ListPSMDBClustersResponse, error)
	// GetPSMDBClusterCredentials returns a PSMDB cluster credentials by cluster name.
	GetPSMDBClusterCredentials(ctx context.Context, in *GetPSMDBClusterCredentialsRequest, opts ...grpc.CallOption) (*GetPSMDBClusterCredentialsResponse, error)
	// CreatePSMDBCluster creates a new PSMDB cluster.
	CreatePSMDBCluster(ctx context.Context, in *CreatePSMDBClusterRequest, opts ...grpc.CallOption) (*CreatePSMDBClusterResponse, error)
	// UpdatePSMDBCluster updates existing PSMDB cluster.
	UpdatePSMDBCluster(ctx context.Context, in *UpdatePSMDBClusterRequest, opts ...grpc.CallOption) (*UpdatePSMDBClusterResponse, error)
	// DeletePSMDBCluster deletes PSMDB cluster.
	DeletePSMDBCluster(ctx context.Context, in *DeletePSMDBClusterRequest, opts ...grpc.CallOption) (*DeletePSMDBClusterResponse, error)
	// RestartPSMDBCluster restarts PSMDB cluster.
	RestartPSMDBCluster(ctx context.Context, in *RestartPSMDBClusterRequest, opts ...grpc.CallOption) (*RestartPSMDBClusterResponse, error)
	// GetPSMDBClusterResources returns expected resources to be consumed by the cluster.
	GetPSMDBClusterResources(ctx context.Context, in *GetPSMDBClusterResourcesRequest, opts ...grpc.CallOption) (*GetPSMDBClusterResourcesResponse, error)
}

PSMDBClusterClient is the client API for PSMDBCluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type PSMDBClusterParams

type PSMDBClusterParams struct {

	// Cluster size.
	ClusterSize int32 `protobuf:"varint,1,opt,name=cluster_size,json=clusterSize,proto3" json:"cluster_size,omitempty"`
	// ReplicaSet container parameters.
	Replicaset *PSMDBClusterParams_ReplicaSet `protobuf:"bytes,2,opt,name=replicaset,proto3" json:"replicaset,omitempty"`
	// Docker image used for PSMDB.
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// contains filtered or unexported fields
}

PSMDBClusterParams represents PSMDB cluster parameters that can be updated.

func (*PSMDBClusterParams) Descriptor deprecated

func (*PSMDBClusterParams) Descriptor() ([]byte, []int)

Deprecated: Use PSMDBClusterParams.ProtoReflect.Descriptor instead.

func (*PSMDBClusterParams) GetClusterSize

func (x *PSMDBClusterParams) GetClusterSize() int32

func (*PSMDBClusterParams) GetImage

func (x *PSMDBClusterParams) GetImage() string

func (*PSMDBClusterParams) GetReplicaset

func (*PSMDBClusterParams) ProtoMessage

func (*PSMDBClusterParams) ProtoMessage()

func (*PSMDBClusterParams) ProtoReflect

func (x *PSMDBClusterParams) ProtoReflect() protoreflect.Message

func (*PSMDBClusterParams) Reset

func (x *PSMDBClusterParams) Reset()

func (*PSMDBClusterParams) String

func (x *PSMDBClusterParams) String() string

func (*PSMDBClusterParams) Validate

func (this *PSMDBClusterParams) Validate() error

type PSMDBClusterParams_ReplicaSet

type PSMDBClusterParams_ReplicaSet struct {

	// Requested compute resources.
	ComputeResources *ComputeResources `protobuf:"bytes,1,opt,name=compute_resources,json=computeResources,proto3" json:"compute_resources,omitempty"`
	// Disk size in bytes.
	DiskSize int64 `protobuf:"varint,2,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"`
	// contains filtered or unexported fields
}

ReplicaSet container parameters. TODO Do not use inner messages in all public APIs (for consistency).

func (*PSMDBClusterParams_ReplicaSet) Descriptor deprecated

func (*PSMDBClusterParams_ReplicaSet) Descriptor() ([]byte, []int)

Deprecated: Use PSMDBClusterParams_ReplicaSet.ProtoReflect.Descriptor instead.

func (*PSMDBClusterParams_ReplicaSet) GetComputeResources

func (x *PSMDBClusterParams_ReplicaSet) GetComputeResources() *ComputeResources

func (*PSMDBClusterParams_ReplicaSet) GetDiskSize

func (x *PSMDBClusterParams_ReplicaSet) GetDiskSize() int64

func (*PSMDBClusterParams_ReplicaSet) ProtoMessage

func (*PSMDBClusterParams_ReplicaSet) ProtoMessage()

func (*PSMDBClusterParams_ReplicaSet) ProtoReflect

func (*PSMDBClusterParams_ReplicaSet) Reset

func (x *PSMDBClusterParams_ReplicaSet) Reset()

func (*PSMDBClusterParams_ReplicaSet) String

func (*PSMDBClusterParams_ReplicaSet) Validate

func (this *PSMDBClusterParams_ReplicaSet) Validate() error

type PSMDBClusterServer

type PSMDBClusterServer interface {
	// ListPSMDBClusters returns a list of PSMDB clusters.
	ListPSMDBClusters(context.Context, *ListPSMDBClustersRequest) (*ListPSMDBClustersResponse, error)
	// GetPSMDBClusterCredentials returns a PSMDB cluster credentials by cluster name.
	GetPSMDBClusterCredentials(context.Context, *GetPSMDBClusterCredentialsRequest) (*GetPSMDBClusterCredentialsResponse, error)
	// CreatePSMDBCluster creates a new PSMDB cluster.
	CreatePSMDBCluster(context.Context, *CreatePSMDBClusterRequest) (*CreatePSMDBClusterResponse, error)
	// UpdatePSMDBCluster updates existing PSMDB cluster.
	UpdatePSMDBCluster(context.Context, *UpdatePSMDBClusterRequest) (*UpdatePSMDBClusterResponse, error)
	// DeletePSMDBCluster deletes PSMDB cluster.
	DeletePSMDBCluster(context.Context, *DeletePSMDBClusterRequest) (*DeletePSMDBClusterResponse, error)
	// RestartPSMDBCluster restarts PSMDB cluster.
	RestartPSMDBCluster(context.Context, *RestartPSMDBClusterRequest) (*RestartPSMDBClusterResponse, error)
	// GetPSMDBClusterResources returns expected resources to be consumed by the cluster.
	GetPSMDBClusterResources(context.Context, *GetPSMDBClusterResourcesRequest) (*GetPSMDBClusterResourcesResponse, error)
}

PSMDBClusterServer is the server API for PSMDBCluster service.

type PSMDBClusterState

type PSMDBClusterState int32

PSMDBClusterState represents PSMDB cluster CR state.

const (
	// PSMDB_CLUSTER_STATE_INVALID represents unknown state.
	PSMDBClusterState_PSMDB_CLUSTER_STATE_INVALID PSMDBClusterState = 0
	// PSMDB_CLUSTER_STATE_CHANGING represents a cluster being changed.
	PSMDBClusterState_PSMDB_CLUSTER_STATE_CHANGING PSMDBClusterState = 1
	// PSMDB_CLUSTER_STATE_READY represents a cluster without pending changes.
	PSMDBClusterState_PSMDB_CLUSTER_STATE_READY PSMDBClusterState = 2
	// PSMDB_CLUSTER_STATE_FAILED represents a failed cluster.
	PSMDBClusterState_PSMDB_CLUSTER_STATE_FAILED PSMDBClusterState = 3
	// PSMDB_CLUSTER_STATE_DELETING represents a cluster being deleting.
	PSMDBClusterState_PSMDB_CLUSTER_STATE_DELETING PSMDBClusterState = 4
	// PSMDB_CLUSTER_STATE_PAUSED represents a cluster is paused.
	PSMDBClusterState_PSMDB_CLUSTER_STATE_PAUSED PSMDBClusterState = 5
)

func (PSMDBClusterState) Descriptor

func (PSMDBClusterState) Enum

func (PSMDBClusterState) EnumDescriptor deprecated

func (PSMDBClusterState) EnumDescriptor() ([]byte, []int)

Deprecated: Use PSMDBClusterState.Descriptor instead.

func (PSMDBClusterState) Number

func (PSMDBClusterState) String

func (x PSMDBClusterState) String() string

func (PSMDBClusterState) Type

type RegisterKubernetesClusterRequest

type RegisterKubernetesClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// Kubernetes auth.
	KubeAuth *KubeAuth `protobuf:"bytes,2,opt,name=kube_auth,json=kubeAuth,proto3" json:"kube_auth,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterKubernetesClusterRequest) Descriptor deprecated

func (*RegisterKubernetesClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterKubernetesClusterRequest.ProtoReflect.Descriptor instead.

func (*RegisterKubernetesClusterRequest) GetKubeAuth

func (x *RegisterKubernetesClusterRequest) GetKubeAuth() *KubeAuth

func (*RegisterKubernetesClusterRequest) GetKubernetesClusterName

func (x *RegisterKubernetesClusterRequest) GetKubernetesClusterName() string

func (*RegisterKubernetesClusterRequest) ProtoMessage

func (*RegisterKubernetesClusterRequest) ProtoMessage()

func (*RegisterKubernetesClusterRequest) ProtoReflect

func (*RegisterKubernetesClusterRequest) Reset

func (*RegisterKubernetesClusterRequest) String

func (*RegisterKubernetesClusterRequest) Validate

func (this *RegisterKubernetesClusterRequest) Validate() error

type RegisterKubernetesClusterResponse

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

func (*RegisterKubernetesClusterResponse) Descriptor deprecated

func (*RegisterKubernetesClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterKubernetesClusterResponse.ProtoReflect.Descriptor instead.

func (*RegisterKubernetesClusterResponse) ProtoMessage

func (*RegisterKubernetesClusterResponse) ProtoMessage()

func (*RegisterKubernetesClusterResponse) ProtoReflect

func (*RegisterKubernetesClusterResponse) Reset

func (*RegisterKubernetesClusterResponse) String

func (*RegisterKubernetesClusterResponse) Validate

func (this *RegisterKubernetesClusterResponse) Validate() error

type Resources

type Resources struct {

	// Memory in bytes.
	MemoryBytes uint64 `protobuf:"varint,1,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	// CPU in millicpus. For example 0.1 of CPU is equivalent to 100 millicpus.
	// See https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/#meaning-of-cpu.
	CpuM uint64 `protobuf:"varint,2,opt,name=cpu_m,json=cpuM,proto3" json:"cpu_m,omitempty"`
	// Disk size in bytes.
	DiskSize uint64 `protobuf:"varint,3,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"`
	// contains filtered or unexported fields
}

Resources contains Kubernetes cluster resources.

func (*Resources) Descriptor deprecated

func (*Resources) Descriptor() ([]byte, []int)

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetCpuM

func (x *Resources) GetCpuM() uint64

func (*Resources) GetDiskSize

func (x *Resources) GetDiskSize() uint64

func (*Resources) GetMemoryBytes

func (x *Resources) GetMemoryBytes() uint64

func (*Resources) ProtoMessage

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect

func (x *Resources) ProtoReflect() protoreflect.Message

func (*Resources) Reset

func (x *Resources) Reset()

func (*Resources) String

func (x *Resources) String() string

func (*Resources) Validate

func (this *Resources) Validate() error

type RestartPSMDBClusterRequest

type RestartPSMDBClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// PSMDB cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartPSMDBClusterRequest) Descriptor deprecated

func (*RestartPSMDBClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use RestartPSMDBClusterRequest.ProtoReflect.Descriptor instead.

func (*RestartPSMDBClusterRequest) GetKubernetesClusterName

func (x *RestartPSMDBClusterRequest) GetKubernetesClusterName() string

func (*RestartPSMDBClusterRequest) GetName

func (x *RestartPSMDBClusterRequest) GetName() string

func (*RestartPSMDBClusterRequest) ProtoMessage

func (*RestartPSMDBClusterRequest) ProtoMessage()

func (*RestartPSMDBClusterRequest) ProtoReflect

func (*RestartPSMDBClusterRequest) Reset

func (x *RestartPSMDBClusterRequest) Reset()

func (*RestartPSMDBClusterRequest) String

func (x *RestartPSMDBClusterRequest) String() string

func (*RestartPSMDBClusterRequest) Validate

func (this *RestartPSMDBClusterRequest) Validate() error

type RestartPSMDBClusterResponse

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

func (*RestartPSMDBClusterResponse) Descriptor deprecated

func (*RestartPSMDBClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use RestartPSMDBClusterResponse.ProtoReflect.Descriptor instead.

func (*RestartPSMDBClusterResponse) ProtoMessage

func (*RestartPSMDBClusterResponse) ProtoMessage()

func (*RestartPSMDBClusterResponse) ProtoReflect

func (*RestartPSMDBClusterResponse) Reset

func (x *RestartPSMDBClusterResponse) Reset()

func (*RestartPSMDBClusterResponse) String

func (x *RestartPSMDBClusterResponse) String() string

func (*RestartPSMDBClusterResponse) Validate

func (this *RestartPSMDBClusterResponse) Validate() error

type RestartXtraDBClusterRequest

type RestartXtraDBClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// XtraDB cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartXtraDBClusterRequest) Descriptor deprecated

func (*RestartXtraDBClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use RestartXtraDBClusterRequest.ProtoReflect.Descriptor instead.

func (*RestartXtraDBClusterRequest) GetKubernetesClusterName

func (x *RestartXtraDBClusterRequest) GetKubernetesClusterName() string

func (*RestartXtraDBClusterRequest) GetName

func (x *RestartXtraDBClusterRequest) GetName() string

func (*RestartXtraDBClusterRequest) ProtoMessage

func (*RestartXtraDBClusterRequest) ProtoMessage()

func (*RestartXtraDBClusterRequest) ProtoReflect

func (*RestartXtraDBClusterRequest) Reset

func (x *RestartXtraDBClusterRequest) Reset()

func (*RestartXtraDBClusterRequest) String

func (x *RestartXtraDBClusterRequest) String() string

func (*RestartXtraDBClusterRequest) Validate

func (this *RestartXtraDBClusterRequest) Validate() error

type RestartXtraDBClusterResponse

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

func (*RestartXtraDBClusterResponse) Descriptor deprecated

func (*RestartXtraDBClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use RestartXtraDBClusterResponse.ProtoReflect.Descriptor instead.

func (*RestartXtraDBClusterResponse) ProtoMessage

func (*RestartXtraDBClusterResponse) ProtoMessage()

func (*RestartXtraDBClusterResponse) ProtoReflect

func (*RestartXtraDBClusterResponse) Reset

func (x *RestartXtraDBClusterResponse) Reset()

func (*RestartXtraDBClusterResponse) String

func (*RestartXtraDBClusterResponse) Validate

func (this *RestartXtraDBClusterResponse) Validate() error

type RunningOperation

type RunningOperation struct {

	// Finished steps of the operaion; can decrease or increase compared to the previous value.
	FinishedSteps int32 `protobuf:"varint,1,opt,name=finished_steps,json=finishedSteps,proto3" json:"finished_steps,omitempty"`
	// Text describing the current operation progress step.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Total steps needed to finish the operation; can decrease or increase compared to the previous value.
	TotalSteps int32 `protobuf:"varint,3,opt,name=total_steps,json=totalSteps,proto3" json:"total_steps,omitempty"`
	// contains filtered or unexported fields
}

RunningOperation respresents a long-running operation.

func (*RunningOperation) Descriptor deprecated

func (*RunningOperation) Descriptor() ([]byte, []int)

Deprecated: Use RunningOperation.ProtoReflect.Descriptor instead.

func (*RunningOperation) GetFinishedSteps

func (x *RunningOperation) GetFinishedSteps() int32

func (*RunningOperation) GetMessage

func (x *RunningOperation) GetMessage() string

func (*RunningOperation) GetTotalSteps

func (x *RunningOperation) GetTotalSteps() int32

func (*RunningOperation) ProtoMessage

func (*RunningOperation) ProtoMessage()

func (*RunningOperation) ProtoReflect

func (x *RunningOperation) ProtoReflect() protoreflect.Message

func (*RunningOperation) Reset

func (x *RunningOperation) Reset()

func (*RunningOperation) String

func (x *RunningOperation) String() string

func (*RunningOperation) Validate

func (this *RunningOperation) Validate() error

type UnimplementedComponentsServer

type UnimplementedComponentsServer struct {
}

UnimplementedComponentsServer can be embedded to have forward compatible implementations.

func (*UnimplementedComponentsServer) ChangePXCComponents

func (*UnimplementedComponentsServer) GetPSMDBComponents

func (*UnimplementedComponentsServer) GetPXCComponents

type UnimplementedKubernetesServer

type UnimplementedKubernetesServer struct {
}

UnimplementedKubernetesServer can be embedded to have forward compatible implementations.

func (*UnimplementedKubernetesServer) GetResources

type UnimplementedLogsAPIServer

type UnimplementedLogsAPIServer struct {
}

UnimplementedLogsAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogsAPIServer) GetLogs

type UnimplementedPSMDBClusterServer

type UnimplementedPSMDBClusterServer struct {
}

UnimplementedPSMDBClusterServer can be embedded to have forward compatible implementations.

func (*UnimplementedPSMDBClusterServer) CreatePSMDBCluster

func (*UnimplementedPSMDBClusterServer) DeletePSMDBCluster

func (*UnimplementedPSMDBClusterServer) ListPSMDBClusters

func (*UnimplementedPSMDBClusterServer) RestartPSMDBCluster

func (*UnimplementedPSMDBClusterServer) UpdatePSMDBCluster

type UnimplementedXtraDBClusterServer

type UnimplementedXtraDBClusterServer struct {
}

UnimplementedXtraDBClusterServer can be embedded to have forward compatible implementations.

func (*UnimplementedXtraDBClusterServer) CreateXtraDBCluster

func (*UnimplementedXtraDBClusterServer) DeleteXtraDBCluster

func (*UnimplementedXtraDBClusterServer) ListXtraDBClusters

func (*UnimplementedXtraDBClusterServer) RestartXtraDBCluster

func (*UnimplementedXtraDBClusterServer) UpdateXtraDBCluster

type UnregisterKubernetesClusterRequest

type UnregisterKubernetesClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// If true then Kubernetes cluster will be deleted
	// even if it contains database clusters.
	Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterKubernetesClusterRequest) Descriptor deprecated

func (*UnregisterKubernetesClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnregisterKubernetesClusterRequest.ProtoReflect.Descriptor instead.

func (*UnregisterKubernetesClusterRequest) GetForce

func (*UnregisterKubernetesClusterRequest) GetKubernetesClusterName

func (x *UnregisterKubernetesClusterRequest) GetKubernetesClusterName() string

func (*UnregisterKubernetesClusterRequest) ProtoMessage

func (*UnregisterKubernetesClusterRequest) ProtoMessage()

func (*UnregisterKubernetesClusterRequest) ProtoReflect

func (*UnregisterKubernetesClusterRequest) Reset

func (*UnregisterKubernetesClusterRequest) String

func (*UnregisterKubernetesClusterRequest) Validate

func (this *UnregisterKubernetesClusterRequest) Validate() error

type UnregisterKubernetesClusterResponse

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

func (*UnregisterKubernetesClusterResponse) Descriptor deprecated

func (*UnregisterKubernetesClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use UnregisterKubernetesClusterResponse.ProtoReflect.Descriptor instead.

func (*UnregisterKubernetesClusterResponse) ProtoMessage

func (*UnregisterKubernetesClusterResponse) ProtoMessage()

func (*UnregisterKubernetesClusterResponse) ProtoReflect

func (*UnregisterKubernetesClusterResponse) Reset

func (*UnregisterKubernetesClusterResponse) String

func (*UnregisterKubernetesClusterResponse) Validate

func (this *UnregisterKubernetesClusterResponse) Validate() error

type UpdatePSMDBClusterRequest

type UpdatePSMDBClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// PSMDB cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster parameters.
	Params *UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdatePSMDBClusterRequest) Descriptor deprecated

func (*UpdatePSMDBClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdatePSMDBClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdatePSMDBClusterRequest) GetKubernetesClusterName

func (x *UpdatePSMDBClusterRequest) GetKubernetesClusterName() string

func (*UpdatePSMDBClusterRequest) GetName

func (x *UpdatePSMDBClusterRequest) GetName() string

func (*UpdatePSMDBClusterRequest) GetParams

func (*UpdatePSMDBClusterRequest) ProtoMessage

func (*UpdatePSMDBClusterRequest) ProtoMessage()

func (*UpdatePSMDBClusterRequest) ProtoReflect

func (*UpdatePSMDBClusterRequest) Reset

func (x *UpdatePSMDBClusterRequest) Reset()

func (*UpdatePSMDBClusterRequest) String

func (x *UpdatePSMDBClusterRequest) String() string

func (*UpdatePSMDBClusterRequest) Validate

func (this *UpdatePSMDBClusterRequest) Validate() error

type UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams

type UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams struct {

	// Cluster size.
	ClusterSize int32 `protobuf:"varint,1,opt,name=cluster_size,json=clusterSize,proto3" json:"cluster_size,omitempty"`
	// ReplicaSet container parameters.
	Replicaset *UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet `protobuf:"bytes,2,opt,name=replicaset,proto3" json:"replicaset,omitempty"`
	// Suspend cluster `pause: true`.
	Suspend bool `protobuf:"varint,3,opt,name=suspend,proto3" json:"suspend,omitempty"`
	// Resume cluster `pause: false`.
	Resume bool `protobuf:"varint,4,opt,name=resume,proto3" json:"resume,omitempty"`
	// contains filtered or unexported fields
}

UpdatePSMDBClusterParams represents PSMDB cluster parameters that can be updated.

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) Descriptor deprecated

Deprecated: Use UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams.ProtoReflect.Descriptor instead.

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) GetClusterSize

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) GetReplicaset

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) GetResume

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) GetSuspend

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) ProtoMessage

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) ProtoReflect

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) Reset

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) String

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams) Validate

type UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet

type UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet struct {

	// Requested compute resources.
	ComputeResources *ComputeResources `protobuf:"bytes,1,opt,name=compute_resources,json=computeResources,proto3" json:"compute_resources,omitempty"`
	// contains filtered or unexported fields
}

ReplicaSet container parameters.

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet) Descriptor deprecated

Deprecated: Use UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet.ProtoReflect.Descriptor instead.

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet) GetComputeResources

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet) ProtoMessage

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet) ProtoReflect

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet) Reset

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet) String

func (*UpdatePSMDBClusterRequest_UpdatePSMDBClusterParams_ReplicaSet) Validate

type UpdatePSMDBClusterResponse

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

func (*UpdatePSMDBClusterResponse) Descriptor deprecated

func (*UpdatePSMDBClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdatePSMDBClusterResponse.ProtoReflect.Descriptor instead.

func (*UpdatePSMDBClusterResponse) ProtoMessage

func (*UpdatePSMDBClusterResponse) ProtoMessage()

func (*UpdatePSMDBClusterResponse) ProtoReflect

func (*UpdatePSMDBClusterResponse) Reset

func (x *UpdatePSMDBClusterResponse) Reset()

func (*UpdatePSMDBClusterResponse) String

func (x *UpdatePSMDBClusterResponse) String() string

func (*UpdatePSMDBClusterResponse) Validate

func (this *UpdatePSMDBClusterResponse) Validate() error

type UpdateXtraDBClusterRequest

type UpdateXtraDBClusterRequest struct {

	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// XtraDB cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster parameters.
	Params *UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateXtraDBClusterRequest) Descriptor deprecated

func (*UpdateXtraDBClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateXtraDBClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateXtraDBClusterRequest) GetKubernetesClusterName

func (x *UpdateXtraDBClusterRequest) GetKubernetesClusterName() string

func (*UpdateXtraDBClusterRequest) GetName

func (x *UpdateXtraDBClusterRequest) GetName() string

func (*UpdateXtraDBClusterRequest) GetParams

func (*UpdateXtraDBClusterRequest) ProtoMessage

func (*UpdateXtraDBClusterRequest) ProtoMessage()

func (*UpdateXtraDBClusterRequest) ProtoReflect

func (*UpdateXtraDBClusterRequest) Reset

func (x *UpdateXtraDBClusterRequest) Reset()

func (*UpdateXtraDBClusterRequest) String

func (x *UpdateXtraDBClusterRequest) String() string

func (*UpdateXtraDBClusterRequest) Validate

func (this *UpdateXtraDBClusterRequest) Validate() error

type UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams

type UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams struct {

	// Cluster size.
	ClusterSize int32 `protobuf:"varint,1,opt,name=cluster_size,json=clusterSize,proto3" json:"cluster_size,omitempty"`
	// PXC container parameters.
	Pxc *UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC `protobuf:"bytes,2,opt,name=pxc,proto3" json:"pxc,omitempty"`
	// ProxySQL container parameters.
	Proxysql *UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL `protobuf:"bytes,3,opt,name=proxysql,proto3" json:"proxysql,omitempty"`
	// Suspend cluster `pause: true`.
	Suspend bool `protobuf:"varint,4,opt,name=suspend,proto3" json:"suspend,omitempty"`
	// Resume cluster `pause: false`.
	Resume bool `protobuf:"varint,5,opt,name=resume,proto3" json:"resume,omitempty"`
	// HAProxy container parameters.
	Haproxy *UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy `protobuf:"bytes,6,opt,name=haproxy,proto3" json:"haproxy,omitempty"`
	// contains filtered or unexported fields
}

UpdateXtraDBClusterParams represents XtraDB cluster parameters that can be updated.

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) Descriptor deprecated

Deprecated: Use UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams.ProtoReflect.Descriptor instead.

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) GetClusterSize

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) GetHaproxy

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) GetProxysql

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) GetPxc

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) GetResume

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) GetSuspend

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) ProtoMessage

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) ProtoReflect

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) Reset

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) String

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams) Validate

type UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy

type UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy struct {

	// Requested compute resources.
	ComputeResources *ComputeResources `protobuf:"bytes,1,opt,name=compute_resources,json=computeResources,proto3" json:"compute_resources,omitempty"`
	// contains filtered or unexported fields
}

HAProxy container parameters.

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy) Descriptor deprecated

Deprecated: Use UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy.ProtoReflect.Descriptor instead.

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy) GetComputeResources

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy) ProtoMessage

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy) ProtoReflect

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy) Reset

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy) String

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_HAProxy) Validate

type UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC

type UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC struct {

	// Requested compute resources.
	ComputeResources *ComputeResources `protobuf:"bytes,1,opt,name=compute_resources,json=computeResources,proto3" json:"compute_resources,omitempty"`
	// contains filtered or unexported fields
}

PXC container parameters.

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC) Descriptor deprecated

Deprecated: Use UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC.ProtoReflect.Descriptor instead.

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC) GetComputeResources

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC) ProtoMessage

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC) ProtoReflect

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC) Reset

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC) String

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_PXC) Validate

type UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL

type UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL struct {

	// Requested compute resources.
	ComputeResources *ComputeResources `protobuf:"bytes,1,opt,name=compute_resources,json=computeResources,proto3" json:"compute_resources,omitempty"`
	// contains filtered or unexported fields
}

ProxySQL container parameters.

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL) Descriptor deprecated

Deprecated: Use UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL.ProtoReflect.Descriptor instead.

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL) GetComputeResources

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL) ProtoMessage

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL) ProtoReflect

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL) Reset

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL) String

func (*UpdateXtraDBClusterRequest_UpdateXtraDBClusterParams_ProxySQL) Validate

type UpdateXtraDBClusterResponse

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

func (*UpdateXtraDBClusterResponse) Descriptor deprecated

func (*UpdateXtraDBClusterResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateXtraDBClusterResponse.ProtoReflect.Descriptor instead.

func (*UpdateXtraDBClusterResponse) ProtoMessage

func (*UpdateXtraDBClusterResponse) ProtoMessage()

func (*UpdateXtraDBClusterResponse) ProtoReflect

func (*UpdateXtraDBClusterResponse) Reset

func (x *UpdateXtraDBClusterResponse) Reset()

func (*UpdateXtraDBClusterResponse) String

func (x *UpdateXtraDBClusterResponse) String() string

func (*UpdateXtraDBClusterResponse) Validate

func (this *UpdateXtraDBClusterResponse) Validate() error

type XtraDBBackupState

type XtraDBBackupState int32

XtraDBBackupState represents XtraDB backup CR state.

const (
	// XTRA_DB_BACKUP_STATE_INVALID represents unknown state.
	XtraDBBackupState_XTRA_DB_BACKUP_STATE_INVALID XtraDBBackupState = 0
	// XTRA_DB_BACKUP_STATE_RUNNING represents running backup.
	XtraDBBackupState_XTRA_DB_BACKUP_STATE_RUNNING XtraDBBackupState = 1
	// XTRA_DB_BACKUP_STATE_SUCCEEDED represents succeeded backup.
	XtraDBBackupState_XTRA_DB_BACKUP_STATE_SUCCEEDED XtraDBBackupState = 2
	// XTRA_DB_BACKUP_STATE_FAILED represents failed backup.
	XtraDBBackupState_XTRA_DB_BACKUP_STATE_FAILED XtraDBBackupState = 3
)

func (XtraDBBackupState) Descriptor

func (XtraDBBackupState) Enum

func (XtraDBBackupState) EnumDescriptor deprecated

func (XtraDBBackupState) EnumDescriptor() ([]byte, []int)

Deprecated: Use XtraDBBackupState.Descriptor instead.

func (XtraDBBackupState) Number

func (XtraDBBackupState) String

func (x XtraDBBackupState) String() string

func (XtraDBBackupState) Type

type XtraDBClusterClient

type XtraDBClusterClient interface {
	// ListXtraDBClusters returns a list of XtraDB clusters.
	ListXtraDBClusters(ctx context.Context, in *ListXtraDBClustersRequest, opts ...grpc.CallOption) (*ListXtraDBClustersResponse, error)
	// GetXtraDBClusterCredentials returns a XtraDB cluster credentials by cluster name.
	GetXtraDBClusterCredentials(ctx context.Context, in *GetXtraDBClusterCredentialsRequest, opts ...grpc.CallOption) (*GetXtraDBClusterCredentialsResponse, error)
	// CreateXtraDBCluster creates a new XtraDB cluster.
	CreateXtraDBCluster(ctx context.Context, in *CreateXtraDBClusterRequest, opts ...grpc.CallOption) (*CreateXtraDBClusterResponse, error)
	// UpdateXtraDBCluster updates existing XtraDB cluster.
	UpdateXtraDBCluster(ctx context.Context, in *UpdateXtraDBClusterRequest, opts ...grpc.CallOption) (*UpdateXtraDBClusterResponse, error)
	// DeleteXtraDBCluster deletes XtraDB cluster.
	DeleteXtraDBCluster(ctx context.Context, in *DeleteXtraDBClusterRequest, opts ...grpc.CallOption) (*DeleteXtraDBClusterResponse, error)
	// RestartXtraDBCluster restarts XtraDB cluster.
	RestartXtraDBCluster(ctx context.Context, in *RestartXtraDBClusterRequest, opts ...grpc.CallOption) (*RestartXtraDBClusterResponse, error)
	// GetXtraDBClusterResources returns expected resources to be consumed by the cluster.
	GetXtraDBClusterResources(ctx context.Context, in *GetXtraDBClusterResourcesRequest, opts ...grpc.CallOption) (*GetXtraDBClusterResourcesResponse, error)
}

XtraDBClusterClient is the client API for XtraDBCluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type XtraDBClusterConnectionCredentials

type XtraDBClusterConnectionCredentials struct {

	// PXC username.
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// PXC password.
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// PXC host.
	Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// PXC port.
	Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

XtraDBClusterConnectionCredentials is cluster connection credentials.

func (*XtraDBClusterConnectionCredentials) Descriptor deprecated

func (*XtraDBClusterConnectionCredentials) Descriptor() ([]byte, []int)

Deprecated: Use XtraDBClusterConnectionCredentials.ProtoReflect.Descriptor instead.

func (*XtraDBClusterConnectionCredentials) GetHost

func (*XtraDBClusterConnectionCredentials) GetPassword

func (x *XtraDBClusterConnectionCredentials) GetPassword() string

func (*XtraDBClusterConnectionCredentials) GetPort

func (*XtraDBClusterConnectionCredentials) GetUsername

func (x *XtraDBClusterConnectionCredentials) GetUsername() string

func (*XtraDBClusterConnectionCredentials) ProtoMessage

func (*XtraDBClusterConnectionCredentials) ProtoMessage()

func (*XtraDBClusterConnectionCredentials) ProtoReflect

func (*XtraDBClusterConnectionCredentials) Reset

func (*XtraDBClusterConnectionCredentials) String

func (*XtraDBClusterConnectionCredentials) Validate

func (this *XtraDBClusterConnectionCredentials) Validate() error

type XtraDBClusterParams

type XtraDBClusterParams struct {

	// Cluster size.
	ClusterSize int32 `protobuf:"varint,1,opt,name=cluster_size,json=clusterSize,proto3" json:"cluster_size,omitempty"`
	// PXC container parameters.
	Pxc *XtraDBClusterParams_PXC `protobuf:"bytes,2,opt,name=pxc,proto3" json:"pxc,omitempty"`
	// NOTE: Only one of fields proxysql or haproxy has to be set, we check this in the code.
	// ProxySQL container parameters.
	Proxysql *XtraDBClusterParams_ProxySQL `protobuf:"bytes,3,opt,name=proxysql,proto3" json:"proxysql,omitempty"`
	// HAProxy container parameters.
	Haproxy *XtraDBClusterParams_HAProxy `protobuf:"bytes,4,opt,name=haproxy,proto3" json:"haproxy,omitempty"`
	// contains filtered or unexported fields
}

XtraDBClusterParams represents XtraDB cluster parameters that can be updated.

func (*XtraDBClusterParams) Descriptor deprecated

func (*XtraDBClusterParams) Descriptor() ([]byte, []int)

Deprecated: Use XtraDBClusterParams.ProtoReflect.Descriptor instead.

func (*XtraDBClusterParams) GetClusterSize

func (x *XtraDBClusterParams) GetClusterSize() int32

func (*XtraDBClusterParams) GetHaproxy

func (*XtraDBClusterParams) GetProxysql

func (*XtraDBClusterParams) GetPxc

func (*XtraDBClusterParams) ProtoMessage

func (*XtraDBClusterParams) ProtoMessage()

func (*XtraDBClusterParams) ProtoReflect

func (x *XtraDBClusterParams) ProtoReflect() protoreflect.Message

func (*XtraDBClusterParams) Reset

func (x *XtraDBClusterParams) Reset()

func (*XtraDBClusterParams) String

func (x *XtraDBClusterParams) String() string

func (*XtraDBClusterParams) Validate

func (this *XtraDBClusterParams) Validate() error

type XtraDBClusterParams_HAProxy

type XtraDBClusterParams_HAProxy struct {

	// Docker image used for HAProxy.
	Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	// Requested compute resources.
	ComputeResources *ComputeResources `protobuf:"bytes,2,opt,name=compute_resources,json=computeResources,proto3" json:"compute_resources,omitempty"`
	// contains filtered or unexported fields
}

HAProxy container parameters. NOTE: HAProxy does not need disk size as ProxySQL does because the container does not require it.

func (*XtraDBClusterParams_HAProxy) Descriptor deprecated

func (*XtraDBClusterParams_HAProxy) Descriptor() ([]byte, []int)

Deprecated: Use XtraDBClusterParams_HAProxy.ProtoReflect.Descriptor instead.

func (*XtraDBClusterParams_HAProxy) GetComputeResources

func (x *XtraDBClusterParams_HAProxy) GetComputeResources() *ComputeResources

func (*XtraDBClusterParams_HAProxy) GetImage

func (x *XtraDBClusterParams_HAProxy) GetImage() string

func (*XtraDBClusterParams_HAProxy) ProtoMessage

func (*XtraDBClusterParams_HAProxy) ProtoMessage()

func (*XtraDBClusterParams_HAProxy) ProtoReflect

func (*XtraDBClusterParams_HAProxy) Reset

func (x *XtraDBClusterParams_HAProxy) Reset()

func (*XtraDBClusterParams_HAProxy) String

func (x *XtraDBClusterParams_HAProxy) String() string

func (*XtraDBClusterParams_HAProxy) Validate

func (this *XtraDBClusterParams_HAProxy) Validate() error

type XtraDBClusterParams_PXC

type XtraDBClusterParams_PXC struct {

	// Docker image used for PXC.
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// Requested compute resources.
	ComputeResources *ComputeResources `protobuf:"bytes,1,opt,name=compute_resources,json=computeResources,proto3" json:"compute_resources,omitempty"`
	// Disk size in bytes.
	DiskSize int64 `protobuf:"varint,2,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"`
	// contains filtered or unexported fields
}

PXC container parameters. TODO Do not use inner messages in all public APIs (for consistency).

func (*XtraDBClusterParams_PXC) Descriptor deprecated

func (*XtraDBClusterParams_PXC) Descriptor() ([]byte, []int)

Deprecated: Use XtraDBClusterParams_PXC.ProtoReflect.Descriptor instead.

func (*XtraDBClusterParams_PXC) GetComputeResources

func (x *XtraDBClusterParams_PXC) GetComputeResources() *ComputeResources

func (*XtraDBClusterParams_PXC) GetDiskSize

func (x *XtraDBClusterParams_PXC) GetDiskSize() int64

func (*XtraDBClusterParams_PXC) GetImage

func (x *XtraDBClusterParams_PXC) GetImage() string

func (*XtraDBClusterParams_PXC) ProtoMessage

func (*XtraDBClusterParams_PXC) ProtoMessage()

func (*XtraDBClusterParams_PXC) ProtoReflect

func (x *XtraDBClusterParams_PXC) ProtoReflect() protoreflect.Message

func (*XtraDBClusterParams_PXC) Reset

func (x *XtraDBClusterParams_PXC) Reset()

func (*XtraDBClusterParams_PXC) String

func (x *XtraDBClusterParams_PXC) String() string

func (*XtraDBClusterParams_PXC) Validate

func (this *XtraDBClusterParams_PXC) Validate() error

type XtraDBClusterParams_ProxySQL

type XtraDBClusterParams_ProxySQL struct {

	// Docker image used for ProxySQL.
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// Requested compute resources.
	ComputeResources *ComputeResources `protobuf:"bytes,1,opt,name=compute_resources,json=computeResources,proto3" json:"compute_resources,omitempty"`
	// Disk size in bytes.
	DiskSize int64 `protobuf:"varint,2,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"`
	// contains filtered or unexported fields
}

ProxySQL container parameters. TODO Do not use inner messages in all public APIs (for consistency).

func (*XtraDBClusterParams_ProxySQL) Descriptor deprecated

func (*XtraDBClusterParams_ProxySQL) Descriptor() ([]byte, []int)

Deprecated: Use XtraDBClusterParams_ProxySQL.ProtoReflect.Descriptor instead.

func (*XtraDBClusterParams_ProxySQL) GetComputeResources

func (x *XtraDBClusterParams_ProxySQL) GetComputeResources() *ComputeResources

func (*XtraDBClusterParams_ProxySQL) GetDiskSize

func (x *XtraDBClusterParams_ProxySQL) GetDiskSize() int64

func (*XtraDBClusterParams_ProxySQL) GetImage

func (x *XtraDBClusterParams_ProxySQL) GetImage() string

func (*XtraDBClusterParams_ProxySQL) ProtoMessage

func (*XtraDBClusterParams_ProxySQL) ProtoMessage()

func (*XtraDBClusterParams_ProxySQL) ProtoReflect

func (*XtraDBClusterParams_ProxySQL) Reset

func (x *XtraDBClusterParams_ProxySQL) Reset()

func (*XtraDBClusterParams_ProxySQL) String

func (*XtraDBClusterParams_ProxySQL) Validate

func (this *XtraDBClusterParams_ProxySQL) Validate() error

type XtraDBClusterServer

type XtraDBClusterServer interface {
	// ListXtraDBClusters returns a list of XtraDB clusters.
	ListXtraDBClusters(context.Context, *ListXtraDBClustersRequest) (*ListXtraDBClustersResponse, error)
	// GetXtraDBClusterCredentials returns a XtraDB cluster credentials by cluster name.
	GetXtraDBClusterCredentials(context.Context, *GetXtraDBClusterCredentialsRequest) (*GetXtraDBClusterCredentialsResponse, error)
	// CreateXtraDBCluster creates a new XtraDB cluster.
	CreateXtraDBCluster(context.Context, *CreateXtraDBClusterRequest) (*CreateXtraDBClusterResponse, error)
	// UpdateXtraDBCluster updates existing XtraDB cluster.
	UpdateXtraDBCluster(context.Context, *UpdateXtraDBClusterRequest) (*UpdateXtraDBClusterResponse, error)
	// DeleteXtraDBCluster deletes XtraDB cluster.
	DeleteXtraDBCluster(context.Context, *DeleteXtraDBClusterRequest) (*DeleteXtraDBClusterResponse, error)
	// RestartXtraDBCluster restarts XtraDB cluster.
	RestartXtraDBCluster(context.Context, *RestartXtraDBClusterRequest) (*RestartXtraDBClusterResponse, error)
	// GetXtraDBClusterResources returns expected resources to be consumed by the cluster.
	GetXtraDBClusterResources(context.Context, *GetXtraDBClusterResourcesRequest) (*GetXtraDBClusterResourcesResponse, error)
}

XtraDBClusterServer is the server API for XtraDBCluster service.

type XtraDBClusterState

type XtraDBClusterState int32

XtraDBClusterState represents XtraDB cluster CR state.

const (
	// XTRA_DB_CLUSTER_STATE_INVALID represents unknown state.
	XtraDBClusterState_XTRA_DB_CLUSTER_STATE_INVALID XtraDBClusterState = 0
	// XTRA_DB_CLUSTER_STATE_CHANGING represents a cluster being changed.
	XtraDBClusterState_XTRA_DB_CLUSTER_STATE_CHANGING XtraDBClusterState = 1
	// XTRA_DB_CLUSTER_STATE_READY represents a cluster without pending changes.
	XtraDBClusterState_XTRA_DB_CLUSTER_STATE_READY XtraDBClusterState = 2
	// XTRA_DB_CLUSTER_STATE_FAILED represents a failed cluster.
	XtraDBClusterState_XTRA_DB_CLUSTER_STATE_FAILED XtraDBClusterState = 3
	// XTRA_DB_CLUSTER_STATE_DELETING represents a cluster being deleting.
	XtraDBClusterState_XTRA_DB_CLUSTER_STATE_DELETING XtraDBClusterState = 4
	// XTRA_DB_CLUSTER_STATE_PAUSED represents a cluster is paused.
	XtraDBClusterState_XTRA_DB_CLUSTER_STATE_PAUSED XtraDBClusterState = 5
)

func (XtraDBClusterState) Descriptor

func (XtraDBClusterState) Enum

func (XtraDBClusterState) EnumDescriptor deprecated

func (XtraDBClusterState) EnumDescriptor() ([]byte, []int)

Deprecated: Use XtraDBClusterState.Descriptor instead.

func (XtraDBClusterState) Number

func (XtraDBClusterState) String

func (x XtraDBClusterState) String() string

func (XtraDBClusterState) Type

Jump to

Keyboard shortcuts

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