peered

type HybridCluster ¶

type HybridCluster struct {
	Name              string
	Arn               string
	Region            string
	KubernetesVersion string
	SubnetID          string
	SecurityGroupID   string
}

func GetHybridCluster(ctx context.Context, eksClient *eks.Client, ec2Client *ec2.Client, clusterName string) (*HybridCluster, error)

type Infrastructure ¶

type Infrastructure struct {
	Credentials       credentials.Infrastructure
	JumpboxInstanceId string
	NodesPublicSSHKey string
}

Infrastructure represents the necessary infrastructure for peered VPCs to be used by nodeadm.

func Setup(ctx context.Context, logger logr.Logger, config aws.Config, clusterName, endpoint string) (*Infrastructure, error)

func (p *Infrastructure) Teardown(ctx context.Context) error

type ItBlockCloser ¶ added in v1.0.3

type ItBlockCloser interface {
	It(description string, body func())
	Close()
}

func NewSerialOutputBlockBestEffort(ctx context.Context, config *SerialOutputConfig) ItBlockCloser

type K8s ¶ added in v1.0.5

type K8s struct {
	clientgo.Interface
	Dynamic dynamic.Interface
}

func (k K8s) Resource(resource schema.GroupVersionResource) dynamic.NamespaceableResourceInterface

type Network ¶ added in v1.0.5

type Network struct {
	EC2    *ec2sdk.Client
	Logger logr.Logger
	K8s    K8s

	Cluster *HybridCluster
}

func (n *Network) CreateRoutesForNode(ctx context.Context, peerdNode *PeerdNode) error

type Node ¶

type Node struct {
	NodeCreate
	NodeCleanup
}

Node represents is a Hybrid node running as an EC2 instance in a peered VPC.

func (c Node) S3LogsURL(instanceName string) string

type NodeCleanup ¶ added in v1.0.3

type NodeCleanup struct {
	SSM                 *ssm.Client
	S3                  *s3sdk.Client
	EC2                 *ec2sdk.Client
	K8s                 clientgo.Interface
	Logger              logr.Logger
	RemoteCommandRunner commands.RemoteCommandRunner

	LogsBucket string
	Cluster    *HybridCluster
	SkipDelete bool
	InstanceId string
}

func (c *NodeCleanup) Cleanup(ctx context.Context, node PeerdNode) error

func (c *NodeCleanup) CleanupSSMActivation(ctx context.Context, nodeName, clusterName string) error

func (c *NodeCleanup) NodeInfrastructureCleaner(node PeerdNode) *NodeInfrastructureCleaner

type NodeCreate ¶ added in v1.0.3

type NodeCreate struct {
	AWS     aws.Config
	Cluster *HybridCluster
	EC2     *ec2sdk.Client
	SSM     *ssm.Client
	Logger  logr.Logger

	SetRootPassword bool
	NodeadmURLs     e2e.NodeadmURLs
	PublicKey       string
}

func (c NodeCreate) Create(ctx context.Context, spec *NodeSpec) (PeerdNode, error)

func (c *NodeCreate) SerialConsole(ctx context.Context, instanceId string) (*ssh.SerialConsole, error)

type NodeInfrastructureCleaner ¶ added in v1.0.5

type NodeInfrastructureCleaner struct {
	EC2    *ec2sdk.Client
	Logger logr.Logger

	SubnetID   string
	InstanceId string
}

func (c *NodeInfrastructureCleaner) Cleanup(ctx context.Context) error

type NodeSpec ¶

type NodeSpec struct {
	EKSEndpoint        string
	InstanceName       string
	InstanceSize       e2e.InstanceSize
	InstanceType       string
	InstanceProfileARN string
	NodeK8sVersion     string
	NodeName           string
	OS                 e2e.NodeadmOS
	Provider           e2e.NodeadmCredentialsProvider
}

NodeSpec configures the Hybrid Node.

type PeerdNode ¶ added in v1.0.4

type PeerdNode struct {
	Instance ec2.Instance
	Name     string
}

PeerdNode represents a Hybrid node running as an EC2 instance in a peered VPC The Name is the name of the kubenretes node object The Instance is the underlying EC2 instance

type SerialOutputBlock ¶ added in v1.0.3

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

SerialOutputBlock is a helper to run sections of a ginkgo test while outputting the serial console output of an instance. It paused the main test logs while streaming the serial console output, and resumes them once the test "body" is done. The serial console output is also saved to a file until Close is called, no matter if you are running a test block or not. This is very useful to help debugging issues with the node joining the cluster, specially if the process runs as part of the node initialization.

func NewSerialOutputBlock(ctx context.Context, config *SerialOutputConfig) (*SerialOutputBlock, error)

func (b *SerialOutputBlock) Close()

func (b *SerialOutputBlock) It(description string, body func())

type SerialOutputConfig ¶ added in v1.0.3

type SerialOutputConfig struct {
	By         func(description string, callback ...func())
	PeeredNode *Node
	Instance   ec2.Instance
	TestLogger e2e.PausableLogger
	OutputFile string
	Output     io.Writer // Writer to output serial console to, defaults to os.Stdout if nil
}