helpers

Documentation

Index

• Constants
• func AddModeFlags(mode *Mode, command *cobra.Command)
• func AppendErrors(err error, errs ...error) error
• func CheckErrors[T interface{ ... }](messages ...T) error
• func ClientVersionCheck(ctx context.Context, c *client.Client) error
• func ExtractFileFromTarGz(filename string, r io.ReadCloser) ([]byte, error)
• func ExtractTarGz(localPath string, r io.ReadCloser) error
• func FailIfMultiNodes(ctx context.Context, command string) error
• func ForEachResource(ctx context.Context, c *client.Client, ...) error
• func NonFatalError(err error) error
• func PrintApplyResults(resp *machine.ApplyConfigurationResponse)
• func ReadGRPCStream[S Stream[T], T Message](stream S, handler func(T, string, bool) error) error
• type ErrNonFatalError
  • func (e *ErrNonFatalError) Error() string
• type Message
• type Mode
  • func (m *Mode) Set(value string) error
  • func (m Mode) String() string
  • func (m *Mode) Type() string
• type Stream

Constants

const InteractiveMode machine.ApplyConfigurationRequest_Mode = -1

InteractiveMode fake mode value for the interactive config mode. Should be never passed to the API.

Functions

func AddModeFlags

func AddModeFlags(mode *Mode, command *cobra.Command)

AddModeFlags adds deprecated flags to the command and registers mode flag with it's parser.

func AppendErrors

func AppendErrors(err error, errs ...error) error

AppendErrors adds errors to the multierr wrapper.

func CheckErrors

func CheckErrors[T interface{ GetMetadata() *common.Metadata }](messages ...T) error

CheckErrors goes through the returned message list and checks if any messages have errors set.

func ClientVersionCheck

func ClientVersionCheck(ctx context.Context, c *client.Client) error

ClientVersionCheck verifies that client is not outdated vs. Talos version.

func ExtractFileFromTarGz

func ExtractFileFromTarGz(filename string, r io.ReadCloser) ([]byte, error)

ExtractFileFromTarGz reads a single file data from an archive.

func ExtractTarGz

func ExtractTarGz(localPath string, r io.ReadCloser) error

ExtractTarGz extracts .tar.gz archive from r into filesystem under localPath.

func FailIfMultiNodes

func FailIfMultiNodes(ctx context.Context, command string) error

FailIfMultiNodes checks if ctx contains multi-node request metadata.

func ForEachResource

func ForEachResource(ctx context.Context,
	c *client.Client,
	callbackRD func(rd *meta.ResourceDefinition) error,
	callback func(ctx context.Context, hostname string, r resource.Resource, callError error) error,
	namespace string,
	args ...string,
) error

ForEachResource gets resources from the controller runtime and runs a callback for each resource.

func NonFatalError

func NonFatalError(err error) error

NonFatalError wraps another error into a ErrNonFatal.

func PrintApplyResults

func PrintApplyResults(resp *machine.ApplyConfigurationResponse)

PrintApplyResults prints out all warnings and auto apply results.

func ReadGRPCStream

func ReadGRPCStream[S Stream[T], T Message](stream S, handler func(T, string, bool) error) error

ReadGRPCStream consumes all messages from the gRPC stream, handles errors, calls the passed handler for each message.

Types

type ErrNonFatalError

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

ErrNonFatalError represents the error that can be returned from the handler in the gRPC stream reader which doesn't mean that we should stop iterating over the messages in the stream, but log this error and continue the process.

func (*ErrNonFatalError) Error

func (e *ErrNonFatalError) Error() string

Error implements error interface.

type Message

type Message interface {
	GetMetadata() *common.Metadata
	proto.Message
}

Message defines the contract for the grpc message.

type Mode

type Mode struct {
	Mode        machine.ApplyConfigurationRequest_Mode
	Immediate   bool
	Interactive bool
	OnReboot    bool
	// contains filtered or unexported fields
}

Mode apply, patch, edit config config update mode.

func (*Mode) Set

func (m *Mode) Set(value string) error

Set implements Flag interface.

func (Mode) String

func (m Mode) String() string

func (*Mode) Type

func (m *Mode) Type() string

Type implements Flag interface.

type Stream

type Stream[T proto.Message] interface {
	Recv() (T, error)
	grpc.ClientStream
}

Stream implements the contract for the grpc stream of a specific type.