e2e

Documentation

Index

• func NewLogger(opts ...LoggerOption) logr.Logger
• func SanitizeForAWSName(input string) string
• func Truncate(name string, limit int) string
• type Cluster
• type CredsOS
• type EksResolverV2
  • func (r *EksResolverV2) ResolveEndpoint(ctx context.Context, params eks.EndpointParameters) (smithyendpoints.Endpoint, error)
• type File
• type HybridEC2Node
• type LoggerConfig
  • func (c LoggerConfig) Apply(opts *LoggerConfig)
• type LoggerOption
• type LogsUploadUrl
• type NodeSpec
• type NodeadmCredentialsProvider
• type NodeadmOS
• type NodeadmURLs
• type PausableLogger
  • func NewPausableLogger(opts ...LoggerOption) PausableLogger
  • func (l PausableLogger) Pause()
  • func (l PausableLogger) Resume() error
• type SwitchWriter
  • func NewSwitchWriter(active io.Writer) *SwitchWriter
  • func (s *SwitchWriter) Pause()
  • func (s *SwitchWriter) Resume() error
  • func (s *SwitchWriter) Write(p []byte) (int, error)
• type UserDataInput

Functions

func NewLogger

func NewLogger(opts ...LoggerOption) logr.Logger

func SanitizeForAWSName

func SanitizeForAWSName(input string) string

SanitizeForAWSName removes everything except alphanumeric characters and hyphens from a string.

func Truncate

func Truncate(name string, limit int) string

Truncate drops characters from the end of a string if it exceeds the limit.

Types

type Cluster

type Cluster struct {
	Name   string
	Region string
}

type CredsOS

type CredsOS interface {
	Name() string
}

CredsOS is the Node OS.

type EksResolverV2

type EksResolverV2 struct {
	Endpoint string
}

EksResolverV2 is used to resolve custom endpoints for EKS clients.

func (*EksResolverV2) ResolveEndpoint

func (r *EksResolverV2) ResolveEndpoint(ctx context.Context, params eks.EndpointParameters) (
	smithyendpoints.Endpoint, error,
)

ResolveEndpoint resolves to a custom endpoint if not empty or default otherwise.

type File

type File struct {
	Content     string
	Path        string
	Permissions string
}

File represents a file in disk.

type HybridEC2Node

type HybridEC2Node struct {
	Node corev1.Node
}

HybridEC2Node represents a Hybrid Node backed by an EC2 instance.

type LoggerConfig

type LoggerConfig struct {
	NoColor bool
	// contains filtered or unexported fields
}

func (LoggerConfig) Apply

func (c LoggerConfig) Apply(opts *LoggerConfig)

type LoggerOption

type LoggerOption interface {
	Apply(*LoggerConfig)
}

type LogsUploadUrl

type LogsUploadUrl struct {
	Name string
	Url  string
}

type NodeSpec

type NodeSpec struct {
	Cluster    *Cluster
	NamePrefix string
	OS         CredsOS
	Provider   NodeadmCredentialsProvider
}

NodeSpec is a specification for a node.

type NodeadmCredentialsProvider

type NodeadmCredentialsProvider interface {
	Name() creds.CredentialProvider
	NodeadmConfig(ctx context.Context, node NodeSpec) (*api.NodeConfig, error)
	VerifyUninstall(ctx context.Context, instanceId string) error
	FilesForNode(spec NodeSpec) ([]File, error)
}

type NodeadmOS

type NodeadmOS interface {
	Name() string
	AMIName(ctx context.Context, awsConfig aws.Config) (string, error)
	BuildUserData(UserDataInput UserDataInput) ([]byte, error)
	InstanceType(region string) string
}

NodeadmOS defines an interface for operating system-specific behavior.

type NodeadmURLs

type NodeadmURLs struct {
	AMD string
	ARM string
}

type PausableLogger

type PausableLogger struct {
	logr.Logger
	// contains filtered or unexported fields
}

PausableLogger can be paused and resumed. It wraps a logr.Logger. When paused, writes go to a buffer; when resumed, writes go to stdout. After it's resumed, the buffer is flushed to stdout.

func NewPausableLogger

func NewPausableLogger(opts ...LoggerOption) PausableLogger

NewPausableLogger returns a logger that can be paused and resumed.

func (PausableLogger) Pause

func (l PausableLogger) Pause()

func (PausableLogger) Resume

func (l PausableLogger) Resume() error

type SwitchWriter

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

SwitchWriter implements io.Writer. When paused, writes go to a buffer; when resumed, writes go to the active writer.

func NewSwitchWriter

func NewSwitchWriter(active io.Writer) *SwitchWriter

func (*SwitchWriter) Pause

func (s *SwitchWriter) Pause()

Pause causes subsequent writes to be buffered.

func (*SwitchWriter) Resume

func (s *SwitchWriter) Resume() error

Resume flushes the buffer to the active writer and resumes normal output.

func (*SwitchWriter) Write

func (s *SwitchWriter) Write(p []byte) (int, error)

type UserDataInput

type UserDataInput struct {
	CredsProviderName string
	KubernetesVersion string
	NodeadmUrls       NodeadmURLs
	NodeadmConfigYaml string
	Provider          string
	PublicKey         string
	RootPasswordHash  string
	Files             []File
}