Versions in this module Expand all Collapse all v0 v0.2.0 Nov 26, 2020 Changes in this version + const PullPolicyAlways + const PullPolicyIfNotPresent + const ResourceDestroy + const ResourceFail + const ResourceFinish + const ResourcePending + const ResourceReady + const ResourceUninitialized + const SSHPort + const TestWorkloadStateFinish + const TestWorkloadStatePending + const TestWorkloadStateRunning + var AddToScheme = SchemeBuilder.AddToScheme + var GroupVersion = schema.GroupVersion + var SchemeBuilder = &scheme.Builder + type AvailableResource struct + Disks map[string]DiskResource + IdleCPUSet []int + Memory BytesSize + func (in *AvailableResource) DeepCopy() *AvailableResource + func (in *AvailableResource) DeepCopyInto(out *AvailableResource) + type BytesSize string + func Size(size float64) BytesSize + func (b BytesSize) Sub(other BytesSize) BytesSize + func (b BytesSize) ToSize() (int64, error) + func (b BytesSize) Unwrap() int64 + func (b BytesSize) Zero() BytesSize + type ClusterTopologyRef struct + AliasName string + Name string + func (in *ClusterTopologyRef) DeepCopy() *ClusterTopologyRef + func (in *ClusterTopologyRef) DeepCopyInto(out *ClusterTopologyRef) + type ClusterTopologyState string + const ClusterTopologyStatePending + const ClusterTopologyStateReady + type DiskBinding struct + Device string + Kind DiskKind + MountPath string + OriginPath string + Size BytesSize + func (in *DiskBinding) DeepCopy() *DiskBinding + func (in *DiskBinding) DeepCopyInto(out *DiskBinding) + type DiskKind string + const NVMEKind + const OtherKind + type DiskResource struct + Kind DiskKind + MountPath string + Size BytesSize + func (in *DiskResource) DeepCopy() *DiskResource + func (in *DiskResource) DeepCopyInto(out *DiskResource) + type DiskSpec struct + Kind DiskKind + MountPath string + Size BytesSize + func (in *DiskSpec) DeepCopy() *DiskSpec + func (in *DiskSpec) DeepCopyInto(out *DiskSpec) + type DockerContainerSpec struct + Command []string + Image string + ImagePullPolicy PullImagePolicy + ResourceRequest ResourceRequestRef + func (in *DockerContainerSpec) DeepCopy() *DockerContainerSpec + func (in *DockerContainerSpec) DeepCopyInto(out *DockerContainerSpec) + type Duration string + func HumanDuration(d time.Duration) Duration + func (r Duration) Parse() (time.Duration, error) + func (r Duration) Unwrap() time.Duration + type GrafanaSpec struct + DeployDir string + Host string + Port int + func (in *GrafanaSpec) DeepCopy() *GrafanaSpec + func (in *GrafanaSpec) DeepCopyInto(out *GrafanaSpec) + type Machine struct + Spec MachineSpec + Status MachineStatus + func (in *Machine) DeepCopy() *Machine + func (in *Machine) DeepCopyInto(out *Machine) + func (in *Machine) DeepCopyObject() runtime.Object + func (r *Machine) Available() *AvailableResource + func (r *Machine) Default() + func (r *Machine) DockerURL() string + func (r *Machine) Rest(resources ResourceRefList) (rest *AvailableResource) + func (r *Machine) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *Machine) ValidateCreate() error + func (r *Machine) ValidateDelete() error + func (r *Machine) ValidateUpdate(old runtime.Object) error + type MachineInfo struct + Architecture string + Hostname string + Memory BytesSize + StorageDevices map[string]StorageDevice + Threads int32 + func (in *MachineInfo) DeepCopy() *MachineInfo + func (in *MachineInfo) DeepCopyInto(out *MachineInfo) + type MachineList struct + Items []Machine + func (in *MachineList) DeepCopy() *MachineList + func (in *MachineList) DeepCopyInto(out *MachineList) + func (in *MachineList) DeepCopyObject() runtime.Object + type MachineRef struct + Binding ResourceBinding + func (in *MachineRef) DeepCopy() *MachineRef + func (in *MachineRef) DeepCopyInto(out *MachineRef) + type MachineSpec struct + DockerPort int + DockerTLS bool + DockerVersion string + ExclusiveDisks []string + Host string + Password string + Reserve *ReserveResources + SSHPort int + Timeout Duration + Username string + func (in *MachineSpec) DeepCopy() *MachineSpec + func (in *MachineSpec) DeepCopyInto(out *MachineSpec) + type MachineStatus struct + Info *MachineInfo + func (in *MachineStatus) DeepCopy() *MachineStatus + func (in *MachineStatus) DeepCopyInto(out *MachineStatus) + type PDSpec struct + ClientPort int + DataDir string + DeployDir string + Host string + LogDir string + PeerPort int + func (in *PDSpec) DeepCopy() *PDSpec + func (in *PDSpec) DeepCopyInto(out *PDSpec) + type PrometheusSpec struct + DataDir string + DeployDir string + Host string + LogDir string + Port int + func (in *PrometheusSpec) DeepCopy() *PrometheusSpec + func (in *PrometheusSpec) DeepCopyInto(out *PrometheusSpec) + type PullImagePolicy string + type Relationship struct + Spec RelationshipSpec + Status RelationshipStatus + func (in *Relationship) DeepCopy() *Relationship + func (in *Relationship) DeepCopyInto(out *Relationship) + func (in *Relationship) DeepCopyObject() runtime.Object + type RelationshipList struct + Items []Relationship + func (in *RelationshipList) DeepCopy() *RelationshipList + func (in *RelationshipList) DeepCopyInto(out *RelationshipList) + func (in *RelationshipList) DeepCopyObject() runtime.Object + type RelationshipSpec struct + func (in *RelationshipSpec) DeepCopy() *RelationshipSpec + func (in *RelationshipSpec) DeepCopyInto(out *RelationshipSpec) + type RelationshipStatus struct + MachineToResources map[string]ResourceRefList + ResourceToMachine map[string]MachineRef + func (in *RelationshipStatus) DeepCopy() *RelationshipStatus + func (in *RelationshipStatus) DeepCopyInto(out *RelationshipStatus) + type ReserveResources struct + Cores int32 + Memory BytesSize + func (in *ReserveResources) DeepCopy() *ReserveResources + func (in *ReserveResources) DeepCopyInto(out *ReserveResources) + type ResourceBinding struct + CPUSet []int + Disks map[string]DiskBinding + Memory BytesSize + func (in *ResourceBinding) DeepCopy() *ResourceBinding + func (in *ResourceBinding) DeepCopyInto(out *ResourceBinding) + type ResourceContainerSpec struct + Binds []string + CapAdd []string + ClusterIP string + Command []string + Envs []string + ExposedPorts []string + Image string + ImagePullPolicy PullImagePolicy + Mounts []TestResourceMount + PortBindings string + Privilege bool + func (in *ResourceContainerSpec) DeepCopy() *ResourceContainerSpec + func (in *ResourceContainerSpec) DeepCopyInto(out *ResourceContainerSpec) + type ResourceRef struct + Binding ResourceBinding + func (in *ResourceRef) DeepCopy() *ResourceRef + func (in *ResourceRef) DeepCopyInto(out *ResourceRef) + type ResourceRefList []ResourceRef + func (in ResourceRefList) DeepCopy() ResourceRefList + func (in ResourceRefList) DeepCopyInto(out *ResourceRefList) + type ResourceRequestItem struct + Name string + Spec TestResourceSpec + func (in *ResourceRequestItem) DeepCopy() *ResourceRequestItem + func (in *ResourceRequestItem) DeepCopyInto(out *ResourceRequestItem) + type ResourceRequestRef struct + Name string + Node string + func (in *ResourceRequestRef) DeepCopy() *ResourceRequestRef + func (in *ResourceRequestRef) DeepCopyInto(out *ResourceRequestRef) + type ResourceState string + func (r ResourceState) IsRequired() bool + func (r ResourceState) ShouldUninstall() bool + type ServerConfigs struct + PD string + TiDB string + TiKV string + func (in *ServerConfigs) DeepCopy() *ServerConfigs + func (in *ServerConfigs) DeepCopyInto(out *ServerConfigs) + type StorageDevice struct + Filesystem string + MountPoint string + Total BytesSize + Used BytesSize + func (in *StorageDevice) DeepCopy() *StorageDevice + func (in *StorageDevice) DeepCopyInto(out *StorageDevice) + type TestClusterTopology struct + Spec TestClusterTopologySpec + Status TestClusterTopologyStatus + func (in *TestClusterTopology) DeepCopy() *TestClusterTopology + func (in *TestClusterTopology) DeepCopyInto(out *TestClusterTopology) + func (in *TestClusterTopology) DeepCopyObject() runtime.Object + type TestClusterTopologyList struct + Items []TestClusterTopology + func (in *TestClusterTopologyList) DeepCopy() *TestClusterTopologyList + func (in *TestClusterTopologyList) DeepCopyInto(out *TestClusterTopologyList) + func (in *TestClusterTopologyList) DeepCopyObject() runtime.Object + type TestClusterTopologySpec struct + ResourceRequest string + TiDBCluster *TiDBCluster + func (in *TestClusterTopologySpec) DeepCopy() *TestClusterTopologySpec + func (in *TestClusterTopologySpec) DeepCopyInto(out *TestClusterTopologySpec) + type TestClusterTopologyStatus struct + State ClusterTopologyState + func (in *TestClusterTopologyStatus) DeepCopy() *TestClusterTopologyStatus + func (in *TestClusterTopologyStatus) DeepCopyInto(out *TestClusterTopologyStatus) + type TestResource struct + Spec TestResourceSpec + Status TestResourceStatus + func (in *TestResource) DeepCopy() *TestResource + func (in *TestResource) DeepCopyInto(out *TestResource) + func (in *TestResource) DeepCopyObject() runtime.Object + func (r *TestResource) ContainerCleanerConfig(binding *ResourceBinding) (*container.Config, *container.HostConfig) + func (r *TestResource) ContainerCleanerName() string + func (r *TestResource) ContainerConfig(binding *ResourceBinding) (*container.Config, *container.HostConfig) + func (r *TestResource) ContainerName() string + func (r *TestResource) Default() + func (r *TestResource) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *TestResource) ValidateCreate() error + func (r *TestResource) ValidateDelete() error + func (r *TestResource) ValidateUpdate(old runtime.Object) error + type TestResourceList struct + Items []TestResource + func (in *TestResourceList) DeepCopy() *TestResourceList + func (in *TestResourceList) DeepCopyInto(out *TestResourceList) + func (in *TestResourceList) DeepCopyObject() runtime.Object + type TestResourceMount struct + ReadOnly bool + Source string + Target string + Type mount.Type + func (in *TestResourceMount) DeepCopy() *TestResourceMount + func (in *TestResourceMount) DeepCopyInto(out *TestResourceMount) + type TestResourceRequest struct + Spec TestResourceRequestSpec + Status TestResourceRequestStatus + func (in *TestResourceRequest) DeepCopy() *TestResourceRequest + func (in *TestResourceRequest) DeepCopyInto(out *TestResourceRequest) + func (in *TestResourceRequest) DeepCopyObject() runtime.Object + func (r *TestResourceRequest) ConstructTestResource(idx int) *TestResource + func (r *TestResourceRequest) Default() + func (r *TestResourceRequest) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *TestResourceRequest) ValidateCreate() error + func (r *TestResourceRequest) ValidateDelete() error + func (r *TestResourceRequest) ValidateUpdate(old runtime.Object) error + type TestResourceRequestList struct + Items []TestResourceRequest + func (in *TestResourceRequestList) DeepCopy() *TestResourceRequestList + func (in *TestResourceRequestList) DeepCopyInto(out *TestResourceRequestList) + func (in *TestResourceRequestList) DeepCopyObject() runtime.Object + type TestResourceRequestSpec struct + Items []*ResourceRequestItem + func (in *TestResourceRequestSpec) DeepCopy() *TestResourceRequestSpec + func (in *TestResourceRequestSpec) DeepCopyInto(out *TestResourceRequestSpec) + type TestResourceRequestState string + const TestResourceRequestPending + const TestResourceRequestReady + type TestResourceRequestStatus struct + State TestResourceRequestState + func (in *TestResourceRequestStatus) DeepCopy() *TestResourceRequestStatus + func (in *TestResourceRequestStatus) DeepCopyInto(out *TestResourceRequestStatus) + type TestResourceSpec struct + Cores int32 + Disks map[string]DiskSpec + MachineSelector string + Memory BytesSize + TestMachineResource string + func (in *TestResourceSpec) DeepCopy() *TestResourceSpec + func (in *TestResourceSpec) DeepCopyInto(out *TestResourceSpec) + func (r *TestResourceSpec) ValidateCreate() error + type TestResourceStatus struct + HostIP string + Password string + PortBindings string + SSHPort int + State ResourceState + func (in *TestResourceStatus) DeepCopy() *TestResourceStatus + func (in *TestResourceStatus) DeepCopyInto(out *TestResourceStatus) + type TestWorkflow struct + Spec TestWorkflowSpec + Status TestWorkflowStatus + func (in *TestWorkflow) DeepCopy() *TestWorkflow + func (in *TestWorkflow) DeepCopyInto(out *TestWorkflow) + func (in *TestWorkflow) DeepCopyObject() runtime.Object + type TestWorkflowList struct + Items []TestWorkflow + func (in *TestWorkflowList) DeepCopy() *TestWorkflowList + func (in *TestWorkflowList) DeepCopyInto(out *TestWorkflowList) + func (in *TestWorkflowList) DeepCopyObject() runtime.Object + type TestWorkflowSpec struct + Steps []WorkflowStepItem + func (in *TestWorkflowSpec) DeepCopy() *TestWorkflowSpec + func (in *TestWorkflowSpec) DeepCopyInto(out *TestWorkflowSpec) + type TestWorkflowStatus struct + func (in *TestWorkflowStatus) DeepCopy() *TestWorkflowStatus + func (in *TestWorkflowStatus) DeepCopyInto(out *TestWorkflowStatus) + type TestWorkload struct + Spec TestWorkloadSpec + Status TestWorkloadStatus + func (in *TestWorkload) DeepCopy() *TestWorkload + func (in *TestWorkload) DeepCopyInto(out *TestWorkload) + func (in *TestWorkload) DeepCopyObject() runtime.Object + type TestWorkloadItemSpec struct + DockerContainer *DockerContainerSpec + Name string + func (in *TestWorkloadItemSpec) DeepCopy() *TestWorkloadItemSpec + func (in *TestWorkloadItemSpec) DeepCopyInto(out *TestWorkloadItemSpec) + type TestWorkloadList struct + Items []TestWorkload + func (in *TestWorkloadList) DeepCopy() *TestWorkloadList + func (in *TestWorkloadList) DeepCopyInto(out *TestWorkloadList) + func (in *TestWorkloadList) DeepCopyObject() runtime.Object + type TestWorkloadResult struct + PlainText string + func (in *TestWorkloadResult) DeepCopy() *TestWorkloadResult + func (in *TestWorkloadResult) DeepCopyInto(out *TestWorkloadResult) + type TestWorkloadSpec struct + ClusterTopologiesRefs []ClusterTopologyRef + TeardownTestClusterTopology []string + Workloads []TestWorkloadItemSpec + func (in *TestWorkloadSpec) DeepCopy() *TestWorkloadSpec + func (in *TestWorkloadSpec) DeepCopyInto(out *TestWorkloadSpec) + type TestWorkloadState string + type TestWorkloadStatus struct + Results map[string]TestWorkloadResult + State TestWorkloadState + func (in *TestWorkloadStatus) DeepCopy() *TestWorkloadStatus + func (in *TestWorkloadStatus) DeepCopyInto(out *TestWorkloadStatus) + type TiDBCluster struct + Control string + Grafana []GrafanaSpec + Monitor []PrometheusSpec + PD []PDSpec + ServerConfigs ServerConfigs + TiDB []TiDBSpec + TiKV []TiKVSpec + Version TiDBClusterVersion + func (c *TiDBCluster) AllHosts() map[string]struct{} + func (in *TiDBCluster) DeepCopy() *TiDBCluster + func (in *TiDBCluster) DeepCopyInto(out *TiDBCluster) + type TiDBClusterVersion struct + PDDownloadUrl string + TiDBDownloadURL string + TiKVDownloadURL string + Version string + func (in *TiDBClusterVersion) DeepCopy() *TiDBClusterVersion + func (in *TiDBClusterVersion) DeepCopyInto(out *TiDBClusterVersion) + type TiDBSpec struct + DataDir string + DeployDir string + Host string + LogDir string + Port int + StatusPort int + func (in *TiDBSpec) DeepCopy() *TiDBSpec + func (in *TiDBSpec) DeepCopyInto(out *TiDBSpec) + type TiKVSpec struct + DataDir string + DeployDir string + Host string + LogDir string + Port int + StatusPort int + func (in *TiKVSpec) DeepCopy() *TiKVSpec + func (in *TiKVSpec) DeepCopyInto(out *TiKVSpec) + type WorkflowStepItem struct + Name string + TestClusterTopology *TestClusterTopology + TestResourceRequest *TestResourceSpec + TestWorkload *TestWorkload + func (in *WorkflowStepItem) DeepCopy() *WorkflowStepItem + func (in *WorkflowStepItem) DeepCopyInto(out *WorkflowStepItem)