kubernetes

package
v0.1.0-beta.10 Latest Latest
Warning

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

Go to latest
Published: May 22, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AliCloudRegistry = "greptime-registry.cn-hangzhou.cr.aliyuncs.com"
)

Variables

This section is empty.

Functions

func EtcdClusterName

func EtcdClusterName(clusterName string) string

func NewCluster

func NewCluster(l logger.Logger, opts ...Option) (cluster.Operations, error)

func OperatorName

func OperatorName() string

Types

type Cluster

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

func (*Cluster) Connect

func (c *Cluster) Connect(ctx context.Context, options *opt.ConnectOptions) error

func (*Cluster) Create

func (c *Cluster) Create(ctx context.Context, options *opt.CreateOptions) error

func (*Cluster) Delete

func (c *Cluster) Delete(ctx context.Context, options *opt.DeleteOptions) error

func (*Cluster) Get

func (c *Cluster) Get(ctx context.Context, options *opt.GetOptions) error

func (*Cluster) List

func (c *Cluster) List(ctx context.Context, options *opt.ListOptions) error

func (*Cluster) Scale

func (c *Cluster) Scale(ctx context.Context, options *opt.ScaleOptions) error

type Option

type Option func(cluster *Cluster)

func WithDryRun

func WithDryRun(dryRun bool) Option

WithDryRun enables Cluster to dry run.

func WithTimeout

func WithTimeout(timeout time.Duration) Option

WithTimeout enables Cluster to have a timeout.

Jump to

Keyboard shortcuts

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