opnictl

Documentation

Overview

Package opnictl contains various utility and helper functions that are used by the Opnictl CLI.

Index

• func CheckBarFiller(waitCtx context.Context, success func(context.Context) bool) func(mpb.BarFiller) mpb.BarFiller
• func CreateClientOrDie(opts ...ClientOption) (*rest.Config, client.Client)
• func CreateScheme() *runtime.Scheme
• func ForEachStagingResource(clientConfig *rest.Config, ...) (errors []string)
• func LoadClientConfig(opts ...ClientOption) *rest.Config
• type ClientOption
  • func WithConfigOverrides(overrides *clientcmd.ConfigOverrides) ClientOption
• type ClientOptions
  • func (o *ClientOptions) Apply(opts ...ClientOption)

Functions

func CheckBarFiller

func CheckBarFiller(
	waitCtx context.Context,
	success func(context.Context) bool,
) func(mpb.BarFiller) mpb.BarFiller

CheckBarFiller creates a mpb.BarFiller which can be used to replace a bar or spinner with a ✓ or ✗ status indicator based on the return value of the provided success function. The success function will be called once when the bar is completed or when waitCtx is canceled, whichever happens first.

func CreateClientOrDie

func CreateClientOrDie(opts ...ClientOption) (*rest.Config, client.Client)

CreateClientOrDie constructs a new controller-runtime client, or exit with a fatal error if an error occurs.

func CreateScheme

func CreateScheme() *runtime.Scheme

CreateScheme creates a new scheme with the types necessary for opnictl.

func ForEachStagingResource

func ForEachStagingResource(
	clientConfig *rest.Config,
	callback func(dynamic.ResourceInterface, *unstructured.Unstructured) error,
) (errors []string)

ForEachStagingResource will call the given callback function for each Kubernetes resource embedded in the binary. See the staging package for more details. This function will not abort if the callback returns an error, rather it will collect all errors that have been returned and return them all at once.

func LoadClientConfig

func LoadClientConfig(opts ...ClientOption) *rest.Config

LoadClientConfig loads the user's kubeconfig using the same logic as kubectl.

Types

type ClientOption

type ClientOption func(*ClientOptions)

func WithConfigOverrides

func WithConfigOverrides(overrides *clientcmd.ConfigOverrides) ClientOption

WithConfigOverrides allows overriding specific kubeconfig fields from the user's loaded kubeconfig.

type ClientOptions

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

ClientOptions can be passed to some of the functions in this package when creating clients and/or client configurations.

func (*ClientOptions) Apply

func (o *ClientOptions) Apply(opts ...ClientOption)