Documentation
¶
Index ¶
- Constants
- func CleanEtcdData(ctx context.Context, namespace, name string) error
- func GetFrontendServiceIngressIP(ctx context.Context, k8sClient client.Client, namespace, name string) (string, error)
- func GetPVCs(ctx context.Context, k8sClient client.Client, namespace, name string, ...) ([]corev1.PersistentVolumeClaim, error)
- func GetPhase(ctx context.Context, k8sClient client.Client, namespace, name string, ...) (greptimev1alpha1.Phase, error)
- func KillPortForwardProcess()
- func LoadGreptimeCRDFromFile(inputFile string, obj client.Object) error
- func PortForward(ctx context.Context, namespace, serviceName string, sourcePort int) (string, error)
- func RunFlowTest(ctx context.Context, frontendAddr string) error
- func RunSQLTest(ctx context.Context, frontendAddr string, isDistributed bool) error
Constants ¶
View Source
const (
DefaultTimeout = 5 * time.Minute
)
Variables ¶
This section is empty.
Functions ¶
func CleanEtcdData ¶
CleanEtcdData use kubectl to clean up all data in etcd.
func GetFrontendServiceIngressIP ¶
func GetFrontendServiceIngressIP(ctx context.Context, k8sClient client.Client, namespace, name string) (string, error)
GetFrontendServiceIngressIP returns the ingress IP of the frontend service. It is assumed that the service is of type LoadBalancer.
func GetPVCs ¶
func GetPVCs(ctx context.Context, k8sClient client.Client, namespace, name string, kind greptimev1alpha1.ComponentKind) ([]corev1.PersistentVolumeClaim, error)
GetPVCs returns the PVCs of the datanodes.
func GetPhase ¶
func GetPhase(ctx context.Context, k8sClient client.Client, namespace, name string, obj client.Object) (greptimev1alpha1.Phase, error)
GetPhase returns the phase of the GreptimeDBCluster or GreptimeDBStandalone.
func KillPortForwardProcess ¶
func KillPortForwardProcess()
KillPortForwardProcess kills the port forwarding process.
func LoadGreptimeCRDFromFile ¶
LoadGreptimeCRDFromFile loads GreptimeCRD from the input yaml file.
func PortForward ¶
func PortForward(ctx context.Context, namespace, serviceName string, sourcePort int) (string, error)
PortForward uses kubectl to port forward the service to a local random available port.
func RunFlowTest ¶
RunFlowTest runs the greptimedb flow tests on the frontend ingress IP.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.