tasks

package

v0.6.0 Latest Latest Go to latest Published: Aug 29, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/k8ssandra/k8ssandra-client

Links

Open Source Insights

Documentation ¶

Index ¶

func CreateCleanupTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func CreateClusterCleanupTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateClusterCompactionTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateClusterFlushTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateClusterGCTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateClusterRebuildTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateClusterReplaceTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateClusterRestartTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateClusterScrubTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateClusterTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateClusterUpgradeSSTablesTask(ctx context.Context, kubeClient client.Client, ...) (*k8ssandrataskapi.K8ssandraTask, error)
func CreateCompactionTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func CreateFlushTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func CreateGCTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func CreateRebuildTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func CreateReplaceTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func CreateRestartTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func CreateScrubTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func CreateTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func CreateUpgradeSSTablesTask(ctx context.Context, kubeClient client.Client, ...) (*controlapi.CassandraTask, error)
func WaitForCompletion(ctx context.Context, kubeClient client.Client, task *controlapi.CassandraTask) error
func WaitForCompletionKey(ctx context.Context, kubeClient client.Client, taskKey types.NamespacedName) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateCleanupTask ¶ added in v0.3.0

func CreateCleanupTask(ctx context.Context, kubeClient client.Client, dc *cassdcapi.CassandraDatacenter, rackName string, podName string) (*controlapi.CassandraTask, error)

func CreateClusterCleanupTask ¶ added in v0.3.0

func CreateClusterCleanupTask(ctx context.Context, kubeClient client.Client, namespace, cluster, dcName, rackName, podName string) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateClusterCompactionTask ¶ added in v0.3.0

func CreateClusterCompactionTask(ctx context.Context, kubeClient client.Client, namespace, cluster, dcName, rackName, podName, keyspaceName string, tables []string) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateClusterFlushTask ¶ added in v0.3.0

func CreateClusterFlushTask(ctx context.Context, kubeClient client.Client, namespace, cluster, dcName, rackName, podName string) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateClusterGCTask ¶ added in v0.3.0

func CreateClusterGCTask(ctx context.Context, kubeClient client.Client, namespace, cluster, dcName, rackName, podName string) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateClusterRebuildTask ¶ added in v0.3.0

func CreateClusterRebuildTask(ctx context.Context, kubeClient client.Client, namespace, cluster, dcName, rackName, podName, sourceDatacenter string) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateClusterReplaceTask ¶ added in v0.3.0

func CreateClusterReplaceTask(ctx context.Context, kubeClient client.Client, namespace, cluster, dcName, podName string) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateClusterRestartTask ¶ added in v0.3.0

func CreateClusterRestartTask(ctx context.Context, kubeClient client.Client, namespace, cluster, dcName, rackName string) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateClusterScrubTask ¶ added in v0.3.0

func CreateClusterScrubTask(ctx context.Context, kubeClient client.Client, namespace, cluster, dcName, rackName, podName string) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateClusterTask ¶ added in v0.3.0

func CreateClusterTask(ctx context.Context, kubeClient client.Client, command controlapi.CassandraCommand, namespace, kcName string, datacenters []string, args *controlapi.JobArguments) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateClusterUpgradeSSTablesTask ¶ added in v0.3.0

func CreateClusterUpgradeSSTablesTask(ctx context.Context, kubeClient client.Client, namespace, cluster, dcName, rackName, podName string) (*k8ssandrataskapi.K8ssandraTask, error)

func CreateCompactionTask ¶ added in v0.3.0

func CreateCompactionTask(ctx context.Context, kubeClient client.Client, dc *cassdcapi.CassandraDatacenter, rackName string, podName, keyspaceName string, tables []string) (*controlapi.CassandraTask, error)

func CreateFlushTask ¶ added in v0.3.0

func CreateFlushTask(ctx context.Context, kubeClient client.Client, dc *cassdcapi.CassandraDatacenter, rackName string, podName string) (*controlapi.CassandraTask, error)

func CreateGCTask ¶ added in v0.3.0

func CreateGCTask(ctx context.Context, kubeClient client.Client, dc *cassdcapi.CassandraDatacenter, rackName string, podName string) (*controlapi.CassandraTask, error)

func CreateRebuildTask ¶ added in v0.3.0

func CreateRebuildTask(ctx context.Context, kubeClient client.Client, dc *cassdcapi.CassandraDatacenter, rackName string, podName, sourceDatacenter string) (*controlapi.CassandraTask, error)

func CreateReplaceTask ¶ added in v0.3.0

func CreateReplaceTask(ctx context.Context, kubeClient client.Client, dc *cassdcapi.CassandraDatacenter, podName string) (*controlapi.CassandraTask, error)

func CreateRestartTask ¶

func CreateRestartTask(ctx context.Context, kubeClient client.Client, dc *cassdcapi.CassandraDatacenter, rackName string) (*controlapi.CassandraTask, error)

func CreateScrubTask ¶ added in v0.3.0

func CreateScrubTask(ctx context.Context, kubeClient client.Client, dc *cassdcapi.CassandraDatacenter, rackName string, podName string) (*controlapi.CassandraTask, error)

func CreateTask ¶

func CreateTask(ctx context.Context, kubeClient client.Client, command controlapi.CassandraCommand, dc *cassdcapi.CassandraDatacenter, args *controlapi.JobArguments) (*controlapi.CassandraTask, error)

func CreateUpgradeSSTablesTask ¶ added in v0.3.0

func CreateUpgradeSSTablesTask(ctx context.Context, kubeClient client.Client, dc *cassdcapi.CassandraDatacenter, rackName string, podName string) (*controlapi.CassandraTask, error)

func WaitForCompletion ¶

func WaitForCompletion(ctx context.Context, kubeClient client.Client, task *controlapi.CassandraTask) error

func WaitForCompletionKey ¶

func WaitForCompletionKey(ctx context.Context, kubeClient client.Client, taskKey types.NamespacedName) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

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