k8s

Documentation

Index

• Constants
• func GetConfig(conn model.Connector, opts ...ConfigOption) (restConfig *rest.Config, err error)
• func GetPodLogs(ctx context.Context, cli *coreclient.CoreV1Client, namespace string, ...) error
• func LoadApiConfig(conn model.Connector) (apiConfig *api.Config, raw string, err error)
• func New(ctx context.Context, opts optypes.CreateOptions) (optypes.Operator, error)
• type ConfigOption
  • func WithRateLimit(qps float32, burst int) ConfigOption
  • func WithTimeout(t time.Duration) ConfigOption
  • func WithoutTimeout() ConfigOption
• type Operator
  • func (op Operator) Burst() int
  • func (op Operator) Exec(ctx context.Context, k string, opts optypes.ExecOptions) error
  • func (op Operator) GetComponents(ctx context.Context, res *model.ServiceResource) ([]*model.ServiceResource, error)
  • func (op Operator) GetEndpoints(ctx context.Context, res *model.ServiceResource) ([]types.ServiceResourceEndpoint, error)
  • func (op Operator) GetKeys(ctx context.Context, res *model.ServiceResource) (*types.ServiceResourceOperationKeys, error)
  • func (op Operator) GetStatus(ctx context.Context, res *model.ServiceResource) (*status.Status, error)
  • func (op Operator) ID() string
  • func (op Operator) IsConnected(ctx context.Context) error
  • func (op Operator) Label(ctx context.Context, res *model.ServiceResource, labels map[string]string) error
  • func (op Operator) Log(ctx context.Context, k string, opts optypes.LogOptions) error
  • func (Operator) Type() optypes.Type

Constants

const OperatorType = types.ConnectorTypeK8s

Functions

func GetConfig

func GetConfig(conn model.Connector, opts ...ConfigOption) (restConfig *rest.Config, err error)

GetConfig returns the rest.Config with the given model, by default, the rest.Config configures with 15s timeout/16 qps/64 burst, please modify the default configuration with ConfigOption as need.

func GetPodLogs

func GetPodLogs(
	ctx context.Context,
	cli *coreclient.CoreV1Client,
	namespace string,
	name string,
	w io.Writer,
	opts *core.PodLogOptions,
) error

GetPodLogs get the logs of a pod.

func LoadApiConfig

func LoadApiConfig(conn model.Connector) (apiConfig *api.Config, raw string, err error)

LoadApiConfig returns the client api.Config with the given model.

func New

func New(ctx context.Context, opts optypes.CreateOptions) (optypes.Operator, error)

New returns operator.Operator with the given options.

Types

type ConfigOption

type ConfigOption func(*rest.Config)

ConfigOption holds the modification to modify the return rest.Config.

func WithRateLimit

func WithRateLimit(qps float32, burst int) ConfigOption

WithRateLimit sets rate limitation.

func WithTimeout

func WithTimeout(t time.Duration) ConfigOption

WithTimeout sets the timeout.

func WithoutTimeout

func WithoutTimeout() ConfigOption

WithoutTimeout disables the timeout.

type Operator

type Operator struct {
	Logger        log.Logger
	RestConfig    *rest.Config
	Identifier    string
	CoreCli       *coreclient.CoreV1Client
	BatchCli      *batchclient.BatchV1Client
	NetworkingCli *networkingclient.NetworkingV1Client
	DynamicCli    *dynamicclient.DynamicClient
}

func (Operator) Burst

func (op Operator) Burst() int

Burst implements operator.Operator.

func (Operator) Exec

func (op Operator) Exec(ctx context.Context, k string, opts optypes.ExecOptions) error

Exec implements operator.Operator.

func (Operator) GetComponents

func (op Operator) GetComponents(
	ctx context.Context,
	res *model.ServiceResource,
) ([]*model.ServiceResource, error)

GetComponents implements operator.Operator.

func (Operator) GetEndpoints

func (op Operator) GetEndpoints(
	ctx context.Context,
	res *model.ServiceResource,
) ([]types.ServiceResourceEndpoint, error)

GetEndpoints implements operator.Operator.

func (Operator) GetKeys

func (op Operator) GetKeys(
	ctx context.Context,
	res *model.ServiceResource,
) (*types.ServiceResourceOperationKeys, error)

GetKeys implements operator.Operator.

func (Operator) GetStatus

func (op Operator) GetStatus(ctx context.Context, res *model.ServiceResource) (*status.Status, error)

GetStatus implements operator.Operator.

func (Operator) ID

func (op Operator) ID() string

ID implements operator.Operator.

func (Operator) IsConnected

func (op Operator) IsConnected(ctx context.Context) error

IsConnected implements operator.Operator.

func (Operator) Label

func (op Operator) Label(ctx context.Context, res *model.ServiceResource, labels map[string]string) error

Label implements operator.Operator.

func (Operator) Log

func (op Operator) Log(ctx context.Context, k string, opts optypes.LogOptions) error

Log implements operator.Operator.

func (Operator) Type

func (Operator) Type() optypes.Type

Type implements operator.Operator.