workflow

package
v0.0.0-...-e7c744b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 21, 2023 License: Apache-2.0 Imports: 69 Imported by: 0

Documentation

Index

Constants

View Source 
const BootstrapActivityName = "eks-bootstrap"
View Source 
const BootstrapWorkflowName = "eks-bootstrap-flow"
View Source 
const CalculateNodePoolVersionActivityName = "eks-calculate-node-pool-version"
View Source 
const CreateAddonActivityName = "eks-create-addon"
View Source 
const CreateAsgActivityName = "eks-create-asg"
View Source 
const CreateClusterUserAccessKeyActivityName = "eks-create-cluster-user-access-key"
View Source 
const CreateEksControlPlaneActivityName = "eks-create-control-plane"
View Source 
const CreateIamRolesActivityName = "eks-create-iam-roles"
View Source 
const CreateInfraWorkflowName = "eks-create-infra"
View Source 
const CreateNodePoolWorkflowName = "eks-create-node-pool"

CreateNodePoolWorkflowName is the name of the EKS workflow creating a new node pool in a cluster.

View Source 
const CreateNodePoolsWorkflowName = "eks-create-node-pools"

CreateNodePoolsWorkflowName is the name of the EKS workflow creating new node pools in a cluster.

View Source 
const CreateStoredNodePoolActivityName = "eks-create-stored-node-pool"

CreateStoredNodePoolActivityName is the name of the stored node pool creation activity.

View Source 
const CreateSubnetActivityName = "eks-create-subnet"
View Source 
const CreateVpcActivityName = "eks-create-vpc"
View Source 
const DeleteClusterFromStoreActivityName = "eks-delete-cluster-from-store"
View Source 
const DeleteControlPlaneActivityName = "eks-delete-control-plane"
View Source 
const DeleteInfraWorkflowName = "eks-delete-infra"
View Source 
const DeleteNodePoolWorkflowName = "eks-delete-node-pool"

DeleteNodePoolWorkflowName is the name of the EKS node pool deletion workflow.

View Source 
const DeleteOrphanNICActivityName = "eks-delete-orphan-nic"
View Source 
const DeleteStoredNodePoolActivityName = "eks-delete-stored-node-pool"
View Source 
const ErrReasonStackFailed = "CLOUDFORMATION_STACK_FAILED"

ErrReasonStackFailed cadence custom error reason that denotes a stack operation that resulted a stack failure

View Source 
const (
	GetAMISizeActivityName = "eks-get-ami-size-activity"
)
View Source 
const (
	// GetCFStackActivityName defines the Cadence activity name for retrieving
	// CloudFormation stacks.
	GetCFStackActivityName = "eks-get-cf-stack-activity"
)
View Source 
const GetOrphanNICsActivityName = "eks-get-orphan-nics"
View Source 
const GetOwnedELBsActivityName = "eks-get-owned-elbs"
View Source 
const GetSubnetStacksActivityName = "eks-get-subnet-stacks"
View Source 
const GetSubnetsDetailsActivityName = "eks-get-subnets-details"
View Source 
const GetVpcConfigActivityName = "eks-get-vpc-cfg"
View Source 
const ListStoredEKSClustersActivityName = "eks-list-stored-eks-clusters"

ListStoredEKSClustersActivityName is the name of the activity which lists the stored EKS clusters.

View Source 
const ListStoredNodePoolsActivityName = "eks-list-stored-node-pools"
View Source 
const SaveClusterVersionActivityName = "eks-save-cluster-version"
View Source 
const SaveK8sConfigActivityName = "eks-save-k8s-config"
View Source 
const SaveNetworkDetailsActivityName = "eks-save-network-details"
View Source 
const SaveNodePoolsActivityName = "eks-save-node-pools"
View Source 
const (
	// SelectVolumeSizeActivityName is the unique name of the activity.
	SelectVolumeSizeActivityName = "eks-select-volume-size-activity"
)
View Source 
const SetClusterStatusActivityName = "eks-set-cluster-status"
View Source 
const SetNodePoolStatusActivityName = "eks-set-node-pool-status"

SetNodePoolStatusActivityName is the name of the activity which sets a node pool's status.

View Source 
const UpdateAsgActivityName = "eks-update-asg"
View Source 
const UploadSSHKeyActivityName = "eks-upload-ssh-key"
View Source 
const ValidateIAMRoleActivityName = "eks-validate-iam-role"
View Source 
const WaitELBsDeletionActivityName = "eks-wait-elbs-deletion"

Variables

This section is empty.

Functions

func GenerateNodePoolStackName 

func GenerateNodePoolStackName(clusterName string, poolName string) string

func GenerateSSHKeyNameForCluster 

func GenerateSSHKeyNameForCluster(clusterName string) string

func GenerateStackNameForCluster 

func GenerateStackNameForCluster(clusterName string) string

func GetIAMTemplate 

func GetIAMTemplate() (string, error)

GetIAMTemplate returns the CloudFormation template for creating IAM roles for the EKS cluster

func GetNodePoolTemplate 

func GetNodePoolTemplate() (string, error)

GetNodePoolTemplate returns the CloudFormation template for creating node pools for EKS cluster

func GetSubnetTemplate 

func GetSubnetTemplate() (string, error)

GetSubnetTemplate returns the CloudFormation template for creating a Subnet

func GetVPCTemplate 

func GetVPCTemplate() (string, error)

GetVPCTemplate returns the CloudFormation template for creating VPC for EKS cluster

func SetClusterErrorStatus 

func SetClusterErrorStatus(ctx workflow.Context, clusterID uint, err error) error

func SetClusterStatus 

func SetClusterStatus(ctx workflow.Context, clusterID uint, status, statusMessage string) error

func WaitForASGToBeFulfilled 

func WaitForASGToBeFulfilled(
	ctx context.Context,
	logger *zap.SugaredLogger,
	awsSession *session.Session,
	stackName string,
	nodePoolName string,
) error

WaitForASGToBeFulfilled waits until an ASG has the desired amount of healthy nodes

func WaitUntilStackCreateCompleteWithContext 

func WaitUntilStackCreateCompleteWithContext(cf *cloudformation.CloudFormation, ctx aws.Context, input *cloudformation.DescribeStacksInput, opts ...request.WaiterOption) error

func WaitUntilStackDeleteCompleteWithContext 

func WaitUntilStackDeleteCompleteWithContext(cf *cloudformation.CloudFormation, ctx aws.Context, input *cloudformation.DescribeStacksInput, opts ...request.WaiterOption) error

func WaitUntilStackUpdateCompleteWithContext 

func WaitUntilStackUpdateCompleteWithContext(cf *cloudformation.CloudFormation, ctx aws.Context, input *cloudformation.DescribeStacksInput, opts ...request.WaiterOption) error

Types

type AutoscaleGroup 

type AutoscaleGroup struct {
	Name                 string
	NodeSpotPrice        string
	Autoscaling          bool
	NodeMinCount         int
	NodeMaxCount         int
	Count                int
	NodeVolumeEncryption *eks.NodePoolVolumeEncryption
	NodeVolumeSize       int
	NodeVolumeType       string
	NodeImage            string
	NodeInstanceType     string

	// SecurityGroups collects the user specified custom node security group
	// IDs.
	SecurityGroups   []string
	UseInstanceStore *bool

	Labels    map[string]string
	Delete    bool
	Create    bool
	CreatedBy uint
}

TODO: remove when UpdateNodePoolWorkflow is refactored and this is not needed anymore.

type BootstrapActivity 

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

CreateEksControlPlaneActivity creates aws-auth map & default StorageClass on cluster

func NewBootstrapActivity 

func NewBootstrapActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *BootstrapActivity

BootstrapActivity instantiates a new BootstrapActivity

func (*BootstrapActivity) Execute 

func (a *BootstrapActivity) Execute(ctx context.Context, input BootstrapActivityInput) (*BootstrapActivityOutput, error)

type BootstrapActivityInput 

type BootstrapActivityInput struct {
	EKSActivityInput

	KubernetesVersion   string
	NodeInstanceRoleArn string
	ClusterUserArn      string
	AuthConfigMap       string
}

BootstrapActivityInput holds input data

type BootstrapActivityOutput 

type BootstrapActivityOutput struct{}

BootstrapActivityOutput holds the output data

type BootstrapWorkflow 

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

BootstrapWorkflow creates EKS addons and other EKS related configs

func NewBootstrapWorkflow 

func NewBootstrapWorkflow(awsSessionFactory *awsworkflow.AWSSessionFactory, enableAddons bool) *BootstrapWorkflow

NewBootstrapWorkflow instantiates a new BootstrapWorkflow

func (*BootstrapWorkflow) Execute 

func (a *BootstrapWorkflow) Execute(ctx workflow.Context, input BootstrapWorkflowInput) error

type BootstrapWorkflowInput 

type BootstrapWorkflowInput struct {
	EKSActivityInput

	KubernetesVersion   string
	NodeInstanceRoleArn string
	ClusterUserArn      string
	AuthConfigMap       string
}

BootstrapWorkflowInput holds input data

type CalculateNodePoolVersionActivity 

type CalculateNodePoolVersionActivity struct{}

CalculateNodePoolVersionActivity calculates the node pool version.

func NewCalculateNodePoolVersionActivity 

func NewCalculateNodePoolVersionActivity() CalculateNodePoolVersionActivity

NewCalculateNodePoolVersionActivity creates a new CalculateNodePoolVersionActivity instance.

func (CalculateNodePoolVersionActivity) Execute 

func (a CalculateNodePoolVersionActivity) Execute(
	_ context.Context,
	input CalculateNodePoolVersionActivityInput,
) (CalculateNodePoolVersionActivityOutput, error)

Execute is the main body of the activity.

func (CalculateNodePoolVersionActivity) Register 

func (a CalculateNodePoolVersionActivity) Register(worker worker.ActivityRegistry)

Register registers the activity in the worker.

type CalculateNodePoolVersionActivityInput 

type CalculateNodePoolVersionActivityInput struct {
	Image                string
	VolumeEncryption     *eks.NodePoolVolumeEncryption
	VolumeSize           int
	CustomSecurityGroups []string
	UseInstanceStore     *bool
}

type CalculateNodePoolVersionActivityOutput 

type CalculateNodePoolVersionActivityOutput struct {
	Version string
}

type Clusters 

type Clusters interface {
	GetCluster(ctx context.Context, id uint) (EksCluster, error)
}

type CreateAddonActivity 

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

CreateAddonActivity creates an EKS addon

func NewCreateAddonActivity 

func NewCreateAddonActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *CreateAddonActivity

NewCreateAddonActivity instantiates a new CreateAddonActivity

func (*CreateAddonActivity) Execute 

func (a *CreateAddonActivity) Execute(ctx context.Context, input CreateAddonActivityInput) (*CreateAddonActivityOutput, error)

type CreateAddonActivityInput 

type CreateAddonActivityInput struct {
	EKSActivityInput

	KubernetesVersion string
	AddonName         string
}

CreateAddonActivityInput holds input data

type CreateAddonActivityOutput 

type CreateAddonActivityOutput struct{}

CreateAddonActivityOutput holds the output data

type CreateAsgActivity 

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

CreateAsgActivity responsible for creating IAM roles

func NewCreateAsgActivity 

func NewCreateAsgActivity(
	awsSessionFactory awsworkflow.AWSFactory,
	cloudFormationTemplate string,
	defaultNodeVolumeEncryption *eks.NodePoolVolumeEncryption,
	nodePoolStore eks.NodePoolStore,
) *CreateAsgActivity

CreateAsgActivity instantiates a new CreateAsgActivity

func (*CreateAsgActivity) Execute 

func (a *CreateAsgActivity) Execute(ctx context.Context, input CreateAsgActivityInput) (*CreateAsgActivityOutput, error)

func (CreateAsgActivity) Register 

func (a CreateAsgActivity) Register(worker worker.Registry)

Register registers the stored node pool deletion activity.

type CreateAsgActivityInput 

type CreateAsgActivityInput struct {
	EKSActivityInput

	ClusterID uint

	// name of the cloud formation template stack
	StackName string

	SSHKeyName string

	Name                 string
	NodeSpotPrice        string
	Autoscaling          bool
	NodeMinCount         int
	NodeMaxCount         int
	Count                int
	NodeVolumeEncryption *eks.NodePoolVolumeEncryption
	NodeVolumeSize       int
	NodeVolumeType       string
	NodeImage            string
	NodeInstanceType     string
	Labels               map[string]string
	NodePoolVersion      string

	Subnets             []Subnet
	VpcID               string
	SecurityGroupID     string
	NodeSecurityGroupID string

	// SecurityGroups collects the user specified custom node security group
	// IDs.
	SecurityGroups   []string
	UseInstanceStore *bool

	NodeInstanceRoleID string
	Tags               map[string]string
}

CreateAsgActivityInput holds data needed for setting up IAM roles

type CreateAsgActivityOutput 

type CreateAsgActivityOutput struct{}

CreateAsgActivityOutput holds the output data of the CreateAsgActivityOutput

type CreateClusterUserAccessKeyActivity 

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

CreateClusterUserAccessKeyActivity responsible for creating IAM user access key for the cluster user and storing the access in secret store

func NewCreateClusterUserAccessKeyActivity 

func NewCreateClusterUserAccessKeyActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *CreateClusterUserAccessKeyActivity

NewCreateClusterUserAccessKeyActivity instantiates a CreateClusterUserAccessKeyActivity

func (*CreateClusterUserAccessKeyActivity) Execute 

func (a *CreateClusterUserAccessKeyActivity) Execute(ctx context.Context, input CreateClusterUserAccessKeyActivityInput) (*CreateClusterUserAccessKeyActivityOutput, error)

type CreateClusterUserAccessKeyActivityInput 

type CreateClusterUserAccessKeyActivityInput struct {
	EKSActivityInput

	UserName       string
	UseDefaultUser bool
	ClusterUID     string
}

CreateClusterUserAccessKeyActivityInput holds data needed for setting up IAM user access key for the cluster user

type CreateClusterUserAccessKeyActivityOutput 

type CreateClusterUserAccessKeyActivityOutput struct {
	SecretID string
}

type CreateEksControlPlaneActivity 

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

CreateEksControlPlaneActivity responsible for creating EKS control plane

func NewCreateEksClusterActivity 

func NewCreateEksClusterActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *CreateEksControlPlaneActivity

CreateEksControlPlaneActivity instantiates a new CreateEksControlPlaneActivity

func (*CreateEksControlPlaneActivity) Execute 

func (a *CreateEksControlPlaneActivity) Execute(ctx context.Context, input CreateEksControlPlaneActivityInput) (*CreateEksControlPlaneActivityOutput, error)

type CreateEksControlPlaneActivityInput 

type CreateEksControlPlaneActivityInput struct {
	EKSActivityInput

	KubernetesVersion     string
	EncryptionConfig      []EncryptionConfig
	EndpointPrivateAccess bool
	EndpointPublicAccess  bool
	ClusterRoleArn        string
	SecurityGroupID       string
	LogTypes              []string
	Subnets               []Subnet
	Tags                  map[string]string
}

CreateEksControlPlaneActivityInput holds data needed for setting up EKS control plane

type CreateEksControlPlaneActivityOutput 

type CreateEksControlPlaneActivityOutput struct{}

CreateEksControlPlaneActivityOutput holds the output data of the CreateEksControlPlaneActivityOutput

type CreateIamRolesActivity 

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

CreateIamRolesActivity responsible for creating IAM roles

func NewCreateIamRolesActivity 

func NewCreateIamRolesActivity(awsSessionFactory *awsworkflow.AWSSessionFactory, cloudFormationTemplate string) *CreateIamRolesActivity

CreateIamRolesActivity instantiates a new CreateIamRolesActivity

func (*CreateIamRolesActivity) Execute 

func (a *CreateIamRolesActivity) Execute(ctx context.Context, input CreateIamRolesActivityInput) (*CreateIamRolesActivityOutput, error)

type CreateIamRolesActivityInput 

type CreateIamRolesActivityInput struct {
	EKSActivityInput

	// name of the cloud formation template stack
	StackName string

	DefaultUser        bool
	ClusterRoleID      string
	NodeInstanceRoleID string
	Tags               map[string]string
}

CreateIamRolesActivityInput holds data needed for setting up IAM roles

type CreateIamRolesActivityOutput 

type CreateIamRolesActivityOutput struct {
	ClusterRoleArn      string
	ClusterUserArn      string
	NodeInstanceRoleID  string
	NodeInstanceRoleArn string
}

CreateIamRolesActivityOutput holds the output data of the CreateIamRolesActivityOutput

type CreateInfrastructureWorkflow 

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

func NewCreateInfrastructureWorkflow 

func NewCreateInfrastructureWorkflow(nodePoolStore eks.NodePoolStore) (createInfrastructureWorkflow *CreateInfrastructureWorkflow)

func (CreateInfrastructureWorkflow) Execute 

func (w CreateInfrastructureWorkflow) Execute(ctx workflow.Context, input CreateInfrastructureWorkflowInput) (*CreateInfrastructureWorkflowOutput, error)

Execute executes the Cadence workflow responsible for creating EKS cluster infrastructure such as VPC, subnets, EKS master nodes, worker nodes, etc

type CreateInfrastructureWorkflowInput 

type CreateInfrastructureWorkflowInput struct {
	Region         string
	OrganizationID uint
	SecretID       string
	SSHSecretID    string

	ClusterUID    string
	ClusterID     uint
	ClusterName   string
	CreatorUserID uint
	VpcID         string
	RouteTableID  string
	VpcCidr       string
	Tags          map[string]string

	Subnets []Subnet

	DefaultUser        bool
	ClusterRoleID      string
	NodeInstanceRoleID string

	KubernetesVersion     string
	EncryptionConfig      []EncryptionConfig
	EndpointPrivateAccess bool
	EndpointPublicAccess  bool

	LogTypes        []string
	NodePools       []eks.NewNodePool
	NodePoolSubnets map[string][]Subnet

	UseGeneratedSSHKey bool

	AuthConfigMap string
}

CreateInfrastructureWorkflowInput holds data needed by the create EKS cluster infrastructure workflow

type CreateInfrastructureWorkflowOutput 

type CreateInfrastructureWorkflowOutput struct {
	VpcID              string
	NodeInstanceRoleID string
	Subnets            []Subnet
	ConfigSecretID     string
}

type CreateNodePoolWorkflow 

type CreateNodePoolWorkflow struct{}

CreateNodePoolWorkflow defines a Cadence workflow encapsulating high level input-independent components required to create an EKS node pool.

func NewCreateNodePoolWorkflow 

func NewCreateNodePoolWorkflow() *CreateNodePoolWorkflow

NewCreateNodePoolWorkflow instantiates an EKS node pool creation workflow.

func (CreateNodePoolWorkflow) Execute 

func (w CreateNodePoolWorkflow) Execute(ctx workflow.Context, input CreateNodePoolWorkflowInput) (err error)

Execute runs the workflow.

func (CreateNodePoolWorkflow) Register 

func (w CreateNodePoolWorkflow) Register(worker worker.Registry)

Register registers the activity in the worker.

type CreateNodePoolWorkflowInput 

type CreateNodePoolWorkflowInput struct {
	ClusterID         uint
	CreatorUserID     uint
	NodePool          eks.NewNodePool
	NodePoolSubnetIDs []string // Note: temporary while eks.NewNodePool has singular Subnet and ASH has plural.

	// Note: LegacyClusterAPI.CreateCluster installs and initializes the node
	// pool label set operator later, so the the node pool label set cannot be
	// created now. Once the installation happens, the currently available node
	// pools's label sets are created automatically before the cluster creation
	// finishes, so no additional operation is required aside from not creating
	// the node pool label set as part of the node pool creation.
	ShouldCreateNodePoolLabelSet bool

	// Note: LegacyClusterAPI.CreateCluster node pool creations store the entire
	// cluster descriptor object with the node pools included in the database at
	// a higher level, thus it should not be stored here, only checked, while
	// ClusterAPI.UpdateCluster and NodePoolAPI.CreateNodePool creations should
	// also store the node pool as it is not done previously.
	ShouldStoreNodePool bool

	// Note: LegacyClusterAPI.CreateCluster, ClusterAPI.UpdateCluster node pool
	// creations should not change the cluster status (CREATING/UPDATING),
	// because success could not yet mean RUNNING status and errors should be
	// handled by the higher level workflow, but NodePoolAPI.CreateNodePool node
	// pool creations should update the cluster status.
	ShouldUpdateClusterStatus bool
}

CreateNodePoolWorkflowInput defines the input parameters of an EKS node pool creation.

type CreateNodePoolsWorkflow 

type CreateNodePoolsWorkflow struct{}

CreateNodePoolsWorkflow defines a Cadence workflow encapsulating high level input-independent components required to create multiple EKS node pools.

func NewCreateNodePoolsWorkflow 

func NewCreateNodePoolsWorkflow() *CreateNodePoolsWorkflow

NewCreateNodePoolsWorkflow instantiates an EKS node pools creation workflow.

func (CreateNodePoolsWorkflow) Execute 

func (w CreateNodePoolsWorkflow) Execute(ctx workflow.Context, input CreateNodePoolsWorkflowInput) (err error)

Execute runs the workflow.

func (CreateNodePoolsWorkflow) Register 

func (w CreateNodePoolsWorkflow) Register(worker worker.Registry)

Register registers the activity in the worker.

type CreateNodePoolsWorkflowInput 

type CreateNodePoolsWorkflowInput struct {
	ClusterID                    uint
	CreatorUserID                uint
	NodePools                    map[string]eks.NewNodePool
	NodePoolSubnetIDs            map[string][]string
	ShouldCreateNodePoolLabelSet bool
	ShouldStoreNodePool          bool
	ShouldUpdateClusterStatus    bool
}

CreateNodePoolsWorkflowInput defines the input parameters of an EKS node pool creation.

type CreateStoredNodePoolActivity 

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

CreateStoredNodePoolActivity collects the necessary component dependencies for executing a stored node pool deletion operation.

func NewCreateStoredNodePoolActivity 

func NewCreateStoredNodePoolActivity(nodePoolStore eks.NodePoolStore) *CreateStoredNodePoolActivity

NewCreateStoredNodePoolActivity instantiates an activity object for deleting stored node pools.

func (*CreateStoredNodePoolActivity) Execute 

func (a *CreateStoredNodePoolActivity) Execute(ctx context.Context, input CreateStoredNodePoolActivityInput) error

Execute executes a stored node pool deletion operation with the specified input parameters.

func (CreateStoredNodePoolActivity) Register 

func (a CreateStoredNodePoolActivity) Register(worker worker.Registry)

Register registers the stored node pool deletion activity.

type CreateStoredNodePoolActivityInput 

type CreateStoredNodePoolActivityInput struct {
	ClusterID      uint
	ClusterName    string
	NodePool       eks.NewNodePool
	OrganizationID uint
	UserID         uint
}

CreateStoredNodePoolActivityInput encapsulates the dynamic parameters of the stored node pool deletion operation.

type CreateSubnetActivity 

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

CreateSubnetActivity responsible for setting up a Subnet for an EKS cluster

func NewCreateSubnetActivity 

func NewCreateSubnetActivity(awsSessionFactory *awsworkflow.AWSSessionFactory, cloudFormationTemplate string) *CreateSubnetActivity

NewCreateSubnetActivity instantiates a new CreateSubnetActivity

func (*CreateSubnetActivity) Execute 

func (a *CreateSubnetActivity) Execute(ctx context.Context, input CreateSubnetActivityInput) (*CreateSubnetActivityOutput, error)

type CreateSubnetActivityInput 

type CreateSubnetActivityInput struct {
	EKSActivityInput

	// the ID of the VPC to create the subnet into
	VpcID string

	// the ID of the Route Table to associate the Subnet with
	RouteTableID string

	// The AWS ID of the subnet
	SubnetID string

	// The CIDR of the subnet
	Cidr string

	// The availability zone of the subnet
	AvailabilityZone string

	// name of the cloud formation template stack
	StackName string

	Tags map[string]string
}

CreateSubnetActivityInput holds data needed for setting up a Subnet for EKS cluster

type CreateSubnetActivityOutput 

type CreateSubnetActivityOutput struct {
	SubnetID         string
	Cidr             string
	AvailabilityZone string
}

CreateSubnetActivityOutput holds the output data of the CreateSubnetActivity

type CreateVpcActivity 

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

CreateVpcActivity responsible for setting up a VPC for an EKS cluster

func NewCreateVPCActivity 

func NewCreateVPCActivity(awsSessionFactory *awsworkflow.AWSSessionFactory, cloudFormationTemplate string) *CreateVpcActivity

NewCreateVPCActivity instantiates a new CreateVpcActivity

func (*CreateVpcActivity) Execute 

func (a *CreateVpcActivity) Execute(ctx context.Context, input CreateVpcActivityInput) (*CreateVpcActivityOutput, error)

type CreateVpcActivityInput 

type CreateVpcActivityInput struct {
	EKSActivityInput

	// name of the cloud formation template stack
	StackName string

	// the ID of the VPC to be used instead of creating a new one
	VpcID string

	// the ID of the Route Table to be used with the existing VPC
	RouteTableID string

	// the CIDR to create new VPC with
	VpcCidr string

	Tags map[string]string
}

CreateVpcActivityInput holds data needed for setting up VPC for EKS cluster

type CreateVpcActivityOutput 

type CreateVpcActivityOutput struct {
	VpcID               string
	RouteTableID        string
	SecurityGroupID     string
	NodeSecurityGroupID string
}

CreateVpcActivityOutput holds the output data of the CreateVpcActivity

type DeleteClusterFromStoreActivity 

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

func NewDeleteClusterFromStoreActivity 

func NewDeleteClusterFromStoreActivity(manager Clusters) DeleteClusterFromStoreActivity

func (DeleteClusterFromStoreActivity) Execute 

func (a DeleteClusterFromStoreActivity) Execute(ctx context.Context, input DeleteClusterFromStoreActivityInput) error

type DeleteClusterFromStoreActivityInput 

type DeleteClusterFromStoreActivityInput struct {
	ClusterID uint
}

type DeleteControlPlaneActivity 

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

DeleteControlPlaneActivity responsible for deleting asg

func NewDeleteControlPlaneActivity 

func NewDeleteControlPlaneActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *DeleteControlPlaneActivity

DeleteControlPlaneActivity instantiates a new DeleteControlPlaneActivity

func (*DeleteControlPlaneActivity) Execute 

func (a *DeleteControlPlaneActivity) Execute(ctx context.Context, input DeleteControlPlaneActivityInput) error

type DeleteControlPlaneActivityInput 

type DeleteControlPlaneActivityInput struct {
	EKSActivityInput
}

type DeleteControlPlaneActivityOutput 

type DeleteControlPlaneActivityOutput struct{}

DeleteControlPlaneActivityOutput holds the output data of the DeleteControlPlaneActivity

type DeleteInfrastructureWorkflow 

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

DeleteInfrastructureWorkflow executes the Cadence workflow responsible for deleting EKS cluster infrastructure such as VPC, subnets, EKS master nodes, worker nodes, etc

func NewDeleteInfrastructureWorkflow 

func NewDeleteInfrastructureWorkflow(ec2client ec2stub.Client) *DeleteInfrastructureWorkflow

NewDeleteNodePoolWorkflow returns a new DeleteInfrastructureWorkflow.

func (DeleteInfrastructureWorkflow) Execute 

func (w DeleteInfrastructureWorkflow) Execute(ctx workflow.Context, input DeleteInfrastructureWorkflowInput) error

func (DeleteInfrastructureWorkflow) Register 

func (w DeleteInfrastructureWorkflow) Register(worker worker.WorkflowRegistry)

type DeleteInfrastructureWorkflowInput 

type DeleteInfrastructureWorkflowInput struct {
	OrganizationID   uint
	SecretID         string
	Region           string
	ClusterName      string
	ClusterID        uint
	ClusterUID       string
	NodePoolNames    []string
	DefaultUser      bool
	GeneratedSSHUsed bool
}

DeleteInfrastructureWorkflowInput holds data needed by the delete EKS cluster infrastructure workflow

type DeleteNodePoolWorkflow 

type DeleteNodePoolWorkflow struct{}

DeleteNodePoolWorkflow defines a Cadence workflow encapsulating high level input-independent components required to delete an EKS node pool.

func NewDeleteNodePoolWorkflow 

func NewDeleteNodePoolWorkflow() *DeleteNodePoolWorkflow

NewDeleteNodePoolWorkflow instantiates an EKS node pool deletion workflow.

func (DeleteNodePoolWorkflow) Execute 

func (w DeleteNodePoolWorkflow) Execute(ctx workflow.Context, input DeleteNodePoolWorkflowInput) (err error)

Execute runs the workflow.

func (DeleteNodePoolWorkflow) Register 

func (w DeleteNodePoolWorkflow) Register(worker worker.Registry)

Register registers the activity in the worker.

type DeleteNodePoolWorkflowInput 

type DeleteNodePoolWorkflowInput struct {
	ClusterID      uint
	ClusterName    string
	NodePoolName   string
	OrganizationID uint
	Region         string
	SecretID       string

	// Note: ClusterAPI.DeleteCluster, ClusterAPI.UpdateCluster node pool
	// deletions should not change the cluster status (DELETING/UPDATING),
	// because success could not yet mean RUNNING status and errors should be
	// handled by the higher level workflow, but NodePoolAPI.DeleteNodePool node
	// pool deletions should update the cluster status.
	ShouldUpdateClusterStatus bool
}

DeleteNodePoolWorkflowInput defines the input parameters of an EKS node pool deletion.

type DeleteOrphanNICActivity 

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

DeleteOrphanNICActivity responsible for deleting asg

func NewDeleteOrphanNICActivity 

func NewDeleteOrphanNICActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *DeleteOrphanNICActivity

DeleteOrphanNICActivity instantiates a new DeleteOrphanNICActivity

func (*DeleteOrphanNICActivity) Execute 

func (a *DeleteOrphanNICActivity) Execute(ctx context.Context, input DeleteOrphanNICActivityInput) error

type DeleteOrphanNICActivityInput 

type DeleteOrphanNICActivityInput struct {
	EKSActivityInput
	NicID string
}

type DeleteOrphanNICActivityOutput 

type DeleteOrphanNICActivityOutput struct{}

type DeleteStoredNodePoolActivity 

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

DeleteStoredNodePoolActivity collects the necessary component dependencies for executing a stored node pool deletion operation.

func NewDeleteStoredNodePoolActivity 

func NewDeleteStoredNodePoolActivity(nodePoolStore eks.NodePoolStore) *DeleteStoredNodePoolActivity

NewDeleteStoredNodePoolActivity instantiates an activity object for deleting stored node pools.

func (*DeleteStoredNodePoolActivity) Execute 

func (a *DeleteStoredNodePoolActivity) Execute(ctx context.Context, input DeleteStoredNodePoolActivityInput) error

Execute executes a stored node pool deletion operation with the specified input parameters.

func (DeleteStoredNodePoolActivity) Register 

func (a DeleteStoredNodePoolActivity) Register(worker worker.Registry)

Register registers the stored node pool deletion activity.

type DeleteStoredNodePoolActivityInput 

type DeleteStoredNodePoolActivityInput struct {
	ClusterID      uint
	ClusterName    string
	NodePoolName   string
	OrganizationID uint
}

DeleteStoredNodePoolActivityInput encapsulates the dynamic parameters of the stored node pool deletion operation.

type EC2APIFactory 

type EC2APIFactory interface {
	// New instantiates an AWS CloudFormation API object based on the specified
	// configurations.
	New(configProvider client.ConfigProvider, configs ...*aws.Config) (ec2API ec2iface.EC2API)
}

EC2APIFactory provides an interface for instantiating AWS EC2 API objects.

type EC2Factory 

type EC2Factory struct{}

EC2Factory can instantiate am ec2.EC2 object.

Implements the pkeworkflow.EC2APIFactory interface.

func NewEC2Factory 

func NewEC2Factory() (factory *EC2Factory)

NewEC2Factory instantiates an EC2Factory object.

func (*EC2Factory) New 

func (factory *EC2Factory) New(
	configProvider client.ConfigProvider,
	configs ...*aws.Config,
) (ec2API ec2iface.EC2API)

New instantiates an AWS EC2 API object based on the specified configurations.

Implements the pkeworkflow.EC2APIFactory interface.

type EKSAPIFactory 

type EKSAPIFactory interface {
	// New instantiates an AWS EKS API object based on the specified
	// configurations.
	New(configProvider client.ConfigProvider, configs ...*aws.Config) (eksAPI eksi.EKSAPI)
}

EKSAPIFactory provides an interface for instantiating AWS EKS API objects.

func NewEKSFactory 

func NewEKSFactory() EKSAPIFactory

NewEKSFactory instantiates a EKSFactory object.

type EKSActivityInput 

type EKSActivityInput struct {
	OrganizationID uint
	SecretID       string

	Region string

	ClusterName string
}

EKSActivityInput holds common input data for all activities Deprecated! Use the AWSCommonActivityInput from "github.com/banzaicloud/pipeline/internal/cluster/infrastructure/aws/awsworkflow" instead

type EKSFactory 

type EKSFactory struct{}

EKSFactory can instantiate a eks.EKS object. Implements the workflow.EKSAPIFactory interface.

func (*EKSFactory) New 

func (factory *EKSFactory) New(
	configProvider client.ConfigProvider,
	configs ...*aws.Config,
) (eksAPI eksi.EKSAPI)

New instantiates an AWS EKS API object based on the specified configurations. Implements the workflow.EKSAPIFactory interface.

type EksCluster 

type EksCluster interface {
	GetModel() *eksmodel.EKSClusterModel
	Persist() error
	SetStatus(string, string) error
	DeleteFromDatabase() error
	GetConfigSecretId() string
	SaveConfigSecretId(secretID string) error
}

type EncryptionConfig 

type EncryptionConfig struct {
	Provider  Provider
	Resources []string
}

type GetAMISizeActivity 

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

func NewGetAMISizeActivity 

func NewGetAMISizeActivity(awsFactory awsworkflow.AWSFactory, ec2Factory EC2APIFactory) *GetAMISizeActivity

func (*GetAMISizeActivity) Execute 

func (a *GetAMISizeActivity) Execute(ctx context.Context, input GetAMISizeActivityInput) (*GetAMISizeActivityOutput, error)

func (GetAMISizeActivity) Register 

func (a GetAMISizeActivity) Register(worker worker.Registry)

Register registers the activity.

type GetAMISizeActivityInput 

type GetAMISizeActivityInput struct {
	EKSActivityInput
	ImageID string
}

type GetAMISizeActivityOutput 

type GetAMISizeActivityOutput struct {
	AMISize int
}

type GetCFStackActivity 

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

GetCFStackActivity defines the high level component dependencies of retrieving a CloudFormation stack.

func NewGetCFStackActivity 

func NewGetCFStackActivity(
	awsFactory awsworkflow.AWSFactory, cloudFormationFactory awsworkflow.CloudFormationAPIFactory,
) *GetCFStackActivity

NewGetCFStackActivity instantiates an activity for retrieving CloudFormation stacks.

func (*GetCFStackActivity) Execute 

func (a *GetCFStackActivity) Execute(ctx context.Context, input GetCFStackActivityInput) (output *GetCFStackActivityOutput, err error)

Execute executes the activity.

func (GetCFStackActivity) Register 

func (a GetCFStackActivity) Register()

Register registers the activity.

type GetCFStackActivityInput 

type GetCFStackActivityInput struct {
	EKSActivityInput
	StackName string
}

GetCFStackActivityInput defines the required parameters for retrieving a CloudFormation stack.

type GetCFStackActivityOutput 

type GetCFStackActivityOutput struct {
	Stack *cloudformation.Stack
}

GetCFStackActivityOutput encapsulates the returned stack information.

type GetOrphanNICsActivity 

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

func NewGetOrphanNICsActivity 

func NewGetOrphanNICsActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *GetOrphanNICsActivity

func (*GetOrphanNICsActivity) Execute 

func (a *GetOrphanNICsActivity) Execute(ctx context.Context, input GetOrphanNICsActivityInput) (*GetOrphanNICsActivityOutput, error)

type GetOrphanNICsActivityInput 

type GetOrphanNICsActivityInput struct {
	EKSActivityInput

	VpcID            string
	SecurityGroupIDs []string
}

type GetOrphanNICsActivityOutput 

type GetOrphanNICsActivityOutput struct {
	NicList []string
}

type GetOwnedELBsActivity 

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

GetOwnedELBsActivity collects all ELBs that were created by the EKS cluster

func NewGetOwnedELBsActivity 

func NewGetOwnedELBsActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *GetOwnedELBsActivity

NewGetOwnedELBsActivity instantiates a new GetOwnedELBsActivity

func (*GetOwnedELBsActivity) Execute 

func (a *GetOwnedELBsActivity) Execute(ctx context.Context, input GetOwnedELBsActivityInput) (*GetOwnedELBsActivityOutput, error)

type GetOwnedELBsActivityInput 

type GetOwnedELBsActivityInput struct {
	EKSActivityInput

	VpcID string
}

GetOwnedELBsActivityInput holds fields needed to retrieve all ELBs provisioned by an EKS cluster

type GetOwnedELBsActivityOutput 

type GetOwnedELBsActivityOutput struct {
	LoadBalancerNames []string
}

type GetSubnetStacksActivity 

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

GetSubnetStacksActivity collects all subnet stack names

func NewGetSubnetStacksActivity 

func NewGetSubnetStacksActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *GetSubnetStacksActivity

func (*GetSubnetStacksActivity) Execute 

func (a *GetSubnetStacksActivity) Execute(ctx context.Context, input GetSubnetStacksActivityInput) (*GetSubnetStacksActivityOutput, error)

type GetSubnetStacksActivityInput 

type GetSubnetStacksActivityInput struct {
	EKSActivityInput
}

type GetSubnetStacksActivityOutput 

type GetSubnetStacksActivityOutput struct {
	StackNames []string
}

type GetSubnetsDetailsActivity 

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

GetSubnetsDetailsActivity retrieves cidr and az for subnets given their ID

func NewGetSubnetsDetailsActivity 

func NewGetSubnetsDetailsActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *GetSubnetsDetailsActivity

NewGetSubnetsDetailsActivity instantiates a new NewGetSubnetsDetailsActivity

func (*GetSubnetsDetailsActivity) Execute 

func (a *GetSubnetsDetailsActivity) Execute(ctx context.Context, input GetSubnetsDetailsActivityInput) (*GetSubnetsDetailsActivityOutput, error)

type GetSubnetsDetailsActivityInput 

type GetSubnetsDetailsActivityInput struct {
	OrganizationID uint
	SecretID       string
	Region         string

	SubnetIDs []string
}

GetSubnetsDetailsActivityInput holds IDs that identifies subnets which to retrieve cidr and availability zone for

type GetSubnetsDetailsActivityOutput 

type GetSubnetsDetailsActivityOutput struct {
	Subnets []Subnet
}

type GetVpcConfigActivity 

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

GetVpcConfigActivity responsible for creating IAM roles

func NewGetVpcConfigActivity 

func NewGetVpcConfigActivity(awsSessionFactory awsworkflow.AWSFactory) *GetVpcConfigActivity

GetVpcConfigActivity instantiates a new GetVpcConfigActivity

func (*GetVpcConfigActivity) Execute 

func (a *GetVpcConfigActivity) Execute(ctx context.Context, input GetVpcConfigActivityInput) (*GetVpcConfigActivityOutput, error)

return with empty output fields in case VPC stack doesn't exists anymore

func (GetVpcConfigActivity) Register 

func (a GetVpcConfigActivity) Register(worker worker.Registry)

Register registers the activity.

type GetVpcConfigActivityInput 

type GetVpcConfigActivityInput struct {
	EKSActivityInput

	// name of the cloud formation template stack
	StackName string
}

GetVpcConfigActivityInput holds data needed for setting up IAM roles

type GetVpcConfigActivityOutput 

type GetVpcConfigActivityOutput struct {
	VpcID               string
	SecurityGroupID     string
	NodeSecurityGroupID string
}

GetVpcConfigActivityOutput holds the output data of the GetVpcConfigActivityOutput

type ListStoredEKSClustersActivity 

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

ListStoredEKSClustersActivity collects the static high level component objects required for retrieveing a stored EKS cluster.

func NewListStoredEKSClustersActivity 

func NewListStoredEKSClustersActivity(db *gorm.DB) (activity *ListStoredEKSClustersActivity)

NewListStoredEKSClustersActivity instantiates a stored EKS cluster retrieving activity.

func (ListStoredEKSClustersActivity) Execute 

func (a ListStoredEKSClustersActivity) Execute(
	ctx context.Context, input ListStoredEKSClustersActivityInput,
) (output *ListStoredEKSClustersActivityOutput, err error)

Execute executes the activity.

func (ListStoredEKSClustersActivity) Register 

func (a ListStoredEKSClustersActivity) Register(worker worker.Registry)

Register registers the activity.

type ListStoredEKSClustersActivityInput 

type ListStoredEKSClustersActivityInput struct {
	OptionalListedGenericClusterIDs []uint
}

ListStoredEKSClustersActivityInput collects the required parameters for setting a node pool\s status.

type ListStoredEKSClustersActivityOutput 

type ListStoredEKSClustersActivityOutput struct {
	// EKSClusters are a map of unique **generic cluster ID** keys and EKS
	// cluster model values.
	//
	// The reason for not keying them with their primary key EKS cluster IDs is
	// usability, EKS cluster ID is an internal detail and most of the
	// interfaces/operations work with generic cluster ID thus that is much
	// easier/straightforward to use as long as each EKS cluster has a unique
	// generic cluster ID which is the case currently.
	EKSClusters map[uint]eksmodel.EKSClusterModel
}

ListStoredEKSClustersActivityOutput collects the returned output of the EKS cluster retrieval activity.

type ListStoredNodePoolsActivity 

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

ListStoredNodePoolsActivity collects the necessary component dependencies for executing a stored node pool retrieval operation.

func NewListStoredNodePoolsActivity 

func NewListStoredNodePoolsActivity(nodePoolStore eks.NodePoolStore) *ListStoredNodePoolsActivity

NewListStoredNodePoolsActivity instantiates an activity object for deleting stored node pools.

func (*ListStoredNodePoolsActivity) Execute 

func (a *ListStoredNodePoolsActivity) Execute(
	ctx context.Context, input ListStoredNodePoolsActivityInput,
) (output *ListStoredNodePoolsActivityOutput, err error)

Execute executes a stored node pool deletion operation with the specified input parameters.

func (ListStoredNodePoolsActivity) Register 

func (a ListStoredNodePoolsActivity) Register(worker worker.Registry)

Register registers the stored node pool deletion activity.

type ListStoredNodePoolsActivityInput 

type ListStoredNodePoolsActivityInput struct {
	ClusterID                   uint
	ClusterName                 string
	OptionalListedNodePoolNames []string
	OrganizationID              uint
}

ListStoredNodePoolsActivityInput encapsulates the dynamic parameters of the stored node pool retrieval operation.

type ListStoredNodePoolsActivityOutput 

type ListStoredNodePoolsActivityOutput struct {
	NodePools map[string]eks.ExistingNodePool
}

type MockEKSAPIFactory 

type MockEKSAPIFactory struct {
	mock.Mock
}

MockEKSAPIFactory is an autogenerated mock for the EKSAPIFactory type.

func (*MockEKSAPIFactory) New 

func (_m *MockEKSAPIFactory) New(configProvider client.ConfigProvider, configs ...*aws.Config) (eksAPI eksiface.EKSAPI)

New provides a mock function.

type MockeksAPI 

type MockeksAPI struct {
	mock.Mock
}

MockeksAPI is an autogenerated mock for the eksAPI type.

func (*MockeksAPI) CreateAddon 

func (_m *MockeksAPI) CreateAddon(_parameter_0 *eks.CreateAddonInput) (_result_0 *eks.CreateAddonOutput, _result_1 error)

CreateAddon provides a mock function.

func (*MockeksAPI) CreateAddonRequest 

func (_m *MockeksAPI) CreateAddonRequest(_parameter_0 *eks.CreateAddonInput) (_result_0 *request.Request, _result_1 *eks.CreateAddonOutput)

CreateAddonRequest provides a mock function.

func (*MockeksAPI) CreateAddonWithContext 

func (_m *MockeksAPI) CreateAddonWithContext(_parameter_0 context.Context, _parameter_1 *eks.CreateAddonInput, _parameter_2 ...request.Option) (_result_0 *eks.CreateAddonOutput, _result_1 error)

CreateAddonWithContext provides a mock function.

func (*MockeksAPI) CreateCluster 

func (_m *MockeksAPI) CreateCluster(_parameter_0 *eks.CreateClusterInput) (_result_0 *eks.CreateClusterOutput, _result_1 error)

CreateCluster provides a mock function.

func (*MockeksAPI) CreateClusterRequest 

func (_m *MockeksAPI) CreateClusterRequest(_parameter_0 *eks.CreateClusterInput) (_result_0 *request.Request, _result_1 *eks.CreateClusterOutput)

CreateClusterRequest provides a mock function.

func (*MockeksAPI) CreateClusterWithContext 

func (_m *MockeksAPI) CreateClusterWithContext(_parameter_0 context.Context, _parameter_1 *eks.CreateClusterInput, _parameter_2 ...request.Option) (_result_0 *eks.CreateClusterOutput, _result_1 error)

CreateClusterWithContext provides a mock function.

func (*MockeksAPI) CreateFargateProfile 

func (_m *MockeksAPI) CreateFargateProfile(_parameter_0 *eks.CreateFargateProfileInput) (_result_0 *eks.CreateFargateProfileOutput, _result_1 error)

CreateFargateProfile provides a mock function.

func (*MockeksAPI) CreateFargateProfileRequest 

func (_m *MockeksAPI) CreateFargateProfileRequest(_parameter_0 *eks.CreateFargateProfileInput) (_result_0 *request.Request, _result_1 *eks.CreateFargateProfileOutput)

CreateFargateProfileRequest provides a mock function.

func (*MockeksAPI) CreateFargateProfileWithContext 

func (_m *MockeksAPI) CreateFargateProfileWithContext(_parameter_0 context.Context, _parameter_1 *eks.CreateFargateProfileInput, _parameter_2 ...request.Option) (_result_0 *eks.CreateFargateProfileOutput, _result_1 error)

CreateFargateProfileWithContext provides a mock function.

func (*MockeksAPI) CreateNodegroup 

func (_m *MockeksAPI) CreateNodegroup(_parameter_0 *eks.CreateNodegroupInput) (_result_0 *eks.CreateNodegroupOutput, _result_1 error)

CreateNodegroup provides a mock function.

func (*MockeksAPI) CreateNodegroupRequest 

func (_m *MockeksAPI) CreateNodegroupRequest(_parameter_0 *eks.CreateNodegroupInput) (_result_0 *request.Request, _result_1 *eks.CreateNodegroupOutput)

CreateNodegroupRequest provides a mock function.

func (*MockeksAPI) CreateNodegroupWithContext 

func (_m *MockeksAPI) CreateNodegroupWithContext(_parameter_0 context.Context, _parameter_1 *eks.CreateNodegroupInput, _parameter_2 ...request.Option) (_result_0 *eks.CreateNodegroupOutput, _result_1 error)

CreateNodegroupWithContext provides a mock function.

func (*MockeksAPI) DeleteAddon 

func (_m *MockeksAPI) DeleteAddon(_parameter_0 *eks.DeleteAddonInput) (_result_0 *eks.DeleteAddonOutput, _result_1 error)

DeleteAddon provides a mock function.

func (*MockeksAPI) DeleteAddonRequest 

func (_m *MockeksAPI) DeleteAddonRequest(_parameter_0 *eks.DeleteAddonInput) (_result_0 *request.Request, _result_1 *eks.DeleteAddonOutput)

DeleteAddonRequest provides a mock function.

func (*MockeksAPI) DeleteAddonWithContext 

func (_m *MockeksAPI) DeleteAddonWithContext(_parameter_0 context.Context, _parameter_1 *eks.DeleteAddonInput, _parameter_2 ...request.Option) (_result_0 *eks.DeleteAddonOutput, _result_1 error)

DeleteAddonWithContext provides a mock function.

func (*MockeksAPI) DeleteCluster 

func (_m *MockeksAPI) DeleteCluster(_parameter_0 *eks.DeleteClusterInput) (_result_0 *eks.DeleteClusterOutput, _result_1 error)

DeleteCluster provides a mock function.

func (*MockeksAPI) DeleteClusterRequest 

func (_m *MockeksAPI) DeleteClusterRequest(_parameter_0 *eks.DeleteClusterInput) (_result_0 *request.Request, _result_1 *eks.DeleteClusterOutput)

DeleteClusterRequest provides a mock function.

func (*MockeksAPI) DeleteClusterWithContext 

func (_m *MockeksAPI) DeleteClusterWithContext(_parameter_0 context.Context, _parameter_1 *eks.DeleteClusterInput, _parameter_2 ...request.Option) (_result_0 *eks.DeleteClusterOutput, _result_1 error)

DeleteClusterWithContext provides a mock function.

func (*MockeksAPI) DeleteFargateProfile 

func (_m *MockeksAPI) DeleteFargateProfile(_parameter_0 *eks.DeleteFargateProfileInput) (_result_0 *eks.DeleteFargateProfileOutput, _result_1 error)

DeleteFargateProfile provides a mock function.

func (*MockeksAPI) DeleteFargateProfileRequest 

func (_m *MockeksAPI) DeleteFargateProfileRequest(_parameter_0 *eks.DeleteFargateProfileInput) (_result_0 *request.Request, _result_1 *eks.DeleteFargateProfileOutput)

DeleteFargateProfileRequest provides a mock function.

func (*MockeksAPI) DeleteFargateProfileWithContext 

func (_m *MockeksAPI) DeleteFargateProfileWithContext(_parameter_0 context.Context, _parameter_1 *eks.DeleteFargateProfileInput, _parameter_2 ...request.Option) (_result_0 *eks.DeleteFargateProfileOutput, _result_1 error)

DeleteFargateProfileWithContext provides a mock function.

func (*MockeksAPI) DeleteNodegroup 

func (_m *MockeksAPI) DeleteNodegroup(_parameter_0 *eks.DeleteNodegroupInput) (_result_0 *eks.DeleteNodegroupOutput, _result_1 error)

DeleteNodegroup provides a mock function.

func (*MockeksAPI) DeleteNodegroupRequest 

func (_m *MockeksAPI) DeleteNodegroupRequest(_parameter_0 *eks.DeleteNodegroupInput) (_result_0 *request.Request, _result_1 *eks.DeleteNodegroupOutput)

DeleteNodegroupRequest provides a mock function.

func (*MockeksAPI) DeleteNodegroupWithContext 

func (_m *MockeksAPI) DeleteNodegroupWithContext(_parameter_0 context.Context, _parameter_1 *eks.DeleteNodegroupInput, _parameter_2 ...request.Option) (_result_0 *eks.DeleteNodegroupOutput, _result_1 error)

DeleteNodegroupWithContext provides a mock function.

func (*MockeksAPI) DescribeAddon 

func (_m *MockeksAPI) DescribeAddon(_parameter_0 *eks.DescribeAddonInput) (_result_0 *eks.DescribeAddonOutput, _result_1 error)

DescribeAddon provides a mock function.

func (*MockeksAPI) DescribeAddonRequest 

func (_m *MockeksAPI) DescribeAddonRequest(_parameter_0 *eks.DescribeAddonInput) (_result_0 *request.Request, _result_1 *eks.DescribeAddonOutput)

DescribeAddonRequest provides a mock function.

func (*MockeksAPI) DescribeAddonVersions 

func (_m *MockeksAPI) DescribeAddonVersions(_parameter_0 *eks.DescribeAddonVersionsInput) (_result_0 *eks.DescribeAddonVersionsOutput, _result_1 error)

DescribeAddonVersions provides a mock function.

func (*MockeksAPI) DescribeAddonVersionsPages 

func (_m *MockeksAPI) DescribeAddonVersionsPages(_parameter_0 *eks.DescribeAddonVersionsInput, _parameter_1 func(*eks.DescribeAddonVersionsOutput, bool) bool) (_result_0 error)

DescribeAddonVersionsPages provides a mock function.

func (*MockeksAPI) DescribeAddonVersionsPagesWithContext 

func (_m *MockeksAPI) DescribeAddonVersionsPagesWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeAddonVersionsInput, _parameter_2 func(*eks.DescribeAddonVersionsOutput, bool) bool, _parameter_3 ...request.Option) (_result_0 error)

DescribeAddonVersionsPagesWithContext provides a mock function.

func (*MockeksAPI) DescribeAddonVersionsRequest 

func (_m *MockeksAPI) DescribeAddonVersionsRequest(_parameter_0 *eks.DescribeAddonVersionsInput) (_result_0 *request.Request, _result_1 *eks.DescribeAddonVersionsOutput)

DescribeAddonVersionsRequest provides a mock function.

func (*MockeksAPI) DescribeAddonVersionsWithContext 

func (_m *MockeksAPI) DescribeAddonVersionsWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeAddonVersionsInput, _parameter_2 ...request.Option) (_result_0 *eks.DescribeAddonVersionsOutput, _result_1 error)

DescribeAddonVersionsWithContext provides a mock function.

func (*MockeksAPI) DescribeAddonWithContext 

func (_m *MockeksAPI) DescribeAddonWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeAddonInput, _parameter_2 ...request.Option) (_result_0 *eks.DescribeAddonOutput, _result_1 error)

DescribeAddonWithContext provides a mock function.

func (*MockeksAPI) DescribeCluster 

func (_m *MockeksAPI) DescribeCluster(_parameter_0 *eks.DescribeClusterInput) (_result_0 *eks.DescribeClusterOutput, _result_1 error)

DescribeCluster provides a mock function.

func (*MockeksAPI) DescribeClusterRequest 

func (_m *MockeksAPI) DescribeClusterRequest(_parameter_0 *eks.DescribeClusterInput) (_result_0 *request.Request, _result_1 *eks.DescribeClusterOutput)

DescribeClusterRequest provides a mock function.

func (*MockeksAPI) DescribeClusterWithContext 

func (_m *MockeksAPI) DescribeClusterWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeClusterInput, _parameter_2 ...request.Option) (_result_0 *eks.DescribeClusterOutput, _result_1 error)

DescribeClusterWithContext provides a mock function.

func (*MockeksAPI) DescribeFargateProfile 

func (_m *MockeksAPI) DescribeFargateProfile(_parameter_0 *eks.DescribeFargateProfileInput) (_result_0 *eks.DescribeFargateProfileOutput, _result_1 error)

DescribeFargateProfile provides a mock function.

func (*MockeksAPI) DescribeFargateProfileRequest 

func (_m *MockeksAPI) DescribeFargateProfileRequest(_parameter_0 *eks.DescribeFargateProfileInput) (_result_0 *request.Request, _result_1 *eks.DescribeFargateProfileOutput)

DescribeFargateProfileRequest provides a mock function.

func (*MockeksAPI) DescribeFargateProfileWithContext 

func (_m *MockeksAPI) DescribeFargateProfileWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeFargateProfileInput, _parameter_2 ...request.Option) (_result_0 *eks.DescribeFargateProfileOutput, _result_1 error)

DescribeFargateProfileWithContext provides a mock function.

func (*MockeksAPI) DescribeNodegroup 

func (_m *MockeksAPI) DescribeNodegroup(_parameter_0 *eks.DescribeNodegroupInput) (_result_0 *eks.DescribeNodegroupOutput, _result_1 error)

DescribeNodegroup provides a mock function.

func (*MockeksAPI) DescribeNodegroupRequest 

func (_m *MockeksAPI) DescribeNodegroupRequest(_parameter_0 *eks.DescribeNodegroupInput) (_result_0 *request.Request, _result_1 *eks.DescribeNodegroupOutput)

DescribeNodegroupRequest provides a mock function.

func (*MockeksAPI) DescribeNodegroupWithContext 

func (_m *MockeksAPI) DescribeNodegroupWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeNodegroupInput, _parameter_2 ...request.Option) (_result_0 *eks.DescribeNodegroupOutput, _result_1 error)

DescribeNodegroupWithContext provides a mock function.

func (*MockeksAPI) DescribeUpdate 

func (_m *MockeksAPI) DescribeUpdate(_parameter_0 *eks.DescribeUpdateInput) (_result_0 *eks.DescribeUpdateOutput, _result_1 error)

DescribeUpdate provides a mock function.

func (*MockeksAPI) DescribeUpdateRequest 

func (_m *MockeksAPI) DescribeUpdateRequest(_parameter_0 *eks.DescribeUpdateInput) (_result_0 *request.Request, _result_1 *eks.DescribeUpdateOutput)

DescribeUpdateRequest provides a mock function.

func (*MockeksAPI) DescribeUpdateWithContext 

func (_m *MockeksAPI) DescribeUpdateWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeUpdateInput, _parameter_2 ...request.Option) (_result_0 *eks.DescribeUpdateOutput, _result_1 error)

DescribeUpdateWithContext provides a mock function.

func (*MockeksAPI) ListAddons 

func (_m *MockeksAPI) ListAddons(_parameter_0 *eks.ListAddonsInput) (_result_0 *eks.ListAddonsOutput, _result_1 error)

ListAddons provides a mock function.

func (*MockeksAPI) ListAddonsPages 

func (_m *MockeksAPI) ListAddonsPages(_parameter_0 *eks.ListAddonsInput, _parameter_1 func(*eks.ListAddonsOutput, bool) bool) (_result_0 error)

ListAddonsPages provides a mock function.

func (*MockeksAPI) ListAddonsPagesWithContext 

func (_m *MockeksAPI) ListAddonsPagesWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListAddonsInput, _parameter_2 func(*eks.ListAddonsOutput, bool) bool, _parameter_3 ...request.Option) (_result_0 error)

ListAddonsPagesWithContext provides a mock function.

func (*MockeksAPI) ListAddonsRequest 

func (_m *MockeksAPI) ListAddonsRequest(_parameter_0 *eks.ListAddonsInput) (_result_0 *request.Request, _result_1 *eks.ListAddonsOutput)

ListAddonsRequest provides a mock function.

func (*MockeksAPI) ListAddonsWithContext 

func (_m *MockeksAPI) ListAddonsWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListAddonsInput, _parameter_2 ...request.Option) (_result_0 *eks.ListAddonsOutput, _result_1 error)

ListAddonsWithContext provides a mock function.

func (*MockeksAPI) ListClusters 

func (_m *MockeksAPI) ListClusters(_parameter_0 *eks.ListClustersInput) (_result_0 *eks.ListClustersOutput, _result_1 error)

ListClusters provides a mock function.

func (*MockeksAPI) ListClustersPages 

func (_m *MockeksAPI) ListClustersPages(_parameter_0 *eks.ListClustersInput, _parameter_1 func(*eks.ListClustersOutput, bool) bool) (_result_0 error)

ListClustersPages provides a mock function.

func (*MockeksAPI) ListClustersPagesWithContext 

func (_m *MockeksAPI) ListClustersPagesWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListClustersInput, _parameter_2 func(*eks.ListClustersOutput, bool) bool, _parameter_3 ...request.Option) (_result_0 error)

ListClustersPagesWithContext provides a mock function.

func (*MockeksAPI) ListClustersRequest 

func (_m *MockeksAPI) ListClustersRequest(_parameter_0 *eks.ListClustersInput) (_result_0 *request.Request, _result_1 *eks.ListClustersOutput)

ListClustersRequest provides a mock function.

func (*MockeksAPI) ListClustersWithContext 

func (_m *MockeksAPI) ListClustersWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListClustersInput, _parameter_2 ...request.Option) (_result_0 *eks.ListClustersOutput, _result_1 error)

ListClustersWithContext provides a mock function.

func (*MockeksAPI) ListFargateProfiles 

func (_m *MockeksAPI) ListFargateProfiles(_parameter_0 *eks.ListFargateProfilesInput) (_result_0 *eks.ListFargateProfilesOutput, _result_1 error)

ListFargateProfiles provides a mock function.

func (*MockeksAPI) ListFargateProfilesPages 

func (_m *MockeksAPI) ListFargateProfilesPages(_parameter_0 *eks.ListFargateProfilesInput, _parameter_1 func(*eks.ListFargateProfilesOutput, bool) bool) (_result_0 error)

ListFargateProfilesPages provides a mock function.

func (*MockeksAPI) ListFargateProfilesPagesWithContext 

func (_m *MockeksAPI) ListFargateProfilesPagesWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListFargateProfilesInput, _parameter_2 func(*eks.ListFargateProfilesOutput, bool) bool, _parameter_3 ...request.Option) (_result_0 error)

ListFargateProfilesPagesWithContext provides a mock function.

func (*MockeksAPI) ListFargateProfilesRequest 

func (_m *MockeksAPI) ListFargateProfilesRequest(_parameter_0 *eks.ListFargateProfilesInput) (_result_0 *request.Request, _result_1 *eks.ListFargateProfilesOutput)

ListFargateProfilesRequest provides a mock function.

func (*MockeksAPI) ListFargateProfilesWithContext 

func (_m *MockeksAPI) ListFargateProfilesWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListFargateProfilesInput, _parameter_2 ...request.Option) (_result_0 *eks.ListFargateProfilesOutput, _result_1 error)

ListFargateProfilesWithContext provides a mock function.

func (*MockeksAPI) ListNodegroups 

func (_m *MockeksAPI) ListNodegroups(_parameter_0 *eks.ListNodegroupsInput) (_result_0 *eks.ListNodegroupsOutput, _result_1 error)

ListNodegroups provides a mock function.

func (*MockeksAPI) ListNodegroupsPages 

func (_m *MockeksAPI) ListNodegroupsPages(_parameter_0 *eks.ListNodegroupsInput, _parameter_1 func(*eks.ListNodegroupsOutput, bool) bool) (_result_0 error)

ListNodegroupsPages provides a mock function.

func (*MockeksAPI) ListNodegroupsPagesWithContext 

func (_m *MockeksAPI) ListNodegroupsPagesWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListNodegroupsInput, _parameter_2 func(*eks.ListNodegroupsOutput, bool) bool, _parameter_3 ...request.Option) (_result_0 error)

ListNodegroupsPagesWithContext provides a mock function.

func (*MockeksAPI) ListNodegroupsRequest 

func (_m *MockeksAPI) ListNodegroupsRequest(_parameter_0 *eks.ListNodegroupsInput) (_result_0 *request.Request, _result_1 *eks.ListNodegroupsOutput)

ListNodegroupsRequest provides a mock function.

func (*MockeksAPI) ListNodegroupsWithContext 

func (_m *MockeksAPI) ListNodegroupsWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListNodegroupsInput, _parameter_2 ...request.Option) (_result_0 *eks.ListNodegroupsOutput, _result_1 error)

ListNodegroupsWithContext provides a mock function.

func (*MockeksAPI) ListTagsForResource 

func (_m *MockeksAPI) ListTagsForResource(_parameter_0 *eks.ListTagsForResourceInput) (_result_0 *eks.ListTagsForResourceOutput, _result_1 error)

ListTagsForResource provides a mock function.

func (*MockeksAPI) ListTagsForResourceRequest 

func (_m *MockeksAPI) ListTagsForResourceRequest(_parameter_0 *eks.ListTagsForResourceInput) (_result_0 *request.Request, _result_1 *eks.ListTagsForResourceOutput)

ListTagsForResourceRequest provides a mock function.

func (*MockeksAPI) ListTagsForResourceWithContext 

func (_m *MockeksAPI) ListTagsForResourceWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListTagsForResourceInput, _parameter_2 ...request.Option) (_result_0 *eks.ListTagsForResourceOutput, _result_1 error)

ListTagsForResourceWithContext provides a mock function.

func (*MockeksAPI) ListUpdates 

func (_m *MockeksAPI) ListUpdates(_parameter_0 *eks.ListUpdatesInput) (_result_0 *eks.ListUpdatesOutput, _result_1 error)

ListUpdates provides a mock function.

func (*MockeksAPI) ListUpdatesPages 

func (_m *MockeksAPI) ListUpdatesPages(_parameter_0 *eks.ListUpdatesInput, _parameter_1 func(*eks.ListUpdatesOutput, bool) bool) (_result_0 error)

ListUpdatesPages provides a mock function.

func (*MockeksAPI) ListUpdatesPagesWithContext 

func (_m *MockeksAPI) ListUpdatesPagesWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListUpdatesInput, _parameter_2 func(*eks.ListUpdatesOutput, bool) bool, _parameter_3 ...request.Option) (_result_0 error)

ListUpdatesPagesWithContext provides a mock function.

func (*MockeksAPI) ListUpdatesRequest 

func (_m *MockeksAPI) ListUpdatesRequest(_parameter_0 *eks.ListUpdatesInput) (_result_0 *request.Request, _result_1 *eks.ListUpdatesOutput)

ListUpdatesRequest provides a mock function.

func (*MockeksAPI) ListUpdatesWithContext 

func (_m *MockeksAPI) ListUpdatesWithContext(_parameter_0 context.Context, _parameter_1 *eks.ListUpdatesInput, _parameter_2 ...request.Option) (_result_0 *eks.ListUpdatesOutput, _result_1 error)

ListUpdatesWithContext provides a mock function.

func (*MockeksAPI) TagResource 

func (_m *MockeksAPI) TagResource(_parameter_0 *eks.TagResourceInput) (_result_0 *eks.TagResourceOutput, _result_1 error)

TagResource provides a mock function.

func (*MockeksAPI) TagResourceRequest 

func (_m *MockeksAPI) TagResourceRequest(_parameter_0 *eks.TagResourceInput) (_result_0 *request.Request, _result_1 *eks.TagResourceOutput)

TagResourceRequest provides a mock function.

func (*MockeksAPI) TagResourceWithContext 

func (_m *MockeksAPI) TagResourceWithContext(_parameter_0 context.Context, _parameter_1 *eks.TagResourceInput, _parameter_2 ...request.Option) (_result_0 *eks.TagResourceOutput, _result_1 error)

TagResourceWithContext provides a mock function.

func (*MockeksAPI) UntagResource 

func (_m *MockeksAPI) UntagResource(_parameter_0 *eks.UntagResourceInput) (_result_0 *eks.UntagResourceOutput, _result_1 error)

UntagResource provides a mock function.

func (*MockeksAPI) UntagResourceRequest 

func (_m *MockeksAPI) UntagResourceRequest(_parameter_0 *eks.UntagResourceInput) (_result_0 *request.Request, _result_1 *eks.UntagResourceOutput)

UntagResourceRequest provides a mock function.

func (*MockeksAPI) UntagResourceWithContext 

func (_m *MockeksAPI) UntagResourceWithContext(_parameter_0 context.Context, _parameter_1 *eks.UntagResourceInput, _parameter_2 ...request.Option) (_result_0 *eks.UntagResourceOutput, _result_1 error)

UntagResourceWithContext provides a mock function.

func (*MockeksAPI) UpdateAddon 

func (_m *MockeksAPI) UpdateAddon(_parameter_0 *eks.UpdateAddonInput) (_result_0 *eks.UpdateAddonOutput, _result_1 error)

UpdateAddon provides a mock function.

func (*MockeksAPI) UpdateAddonRequest 

func (_m *MockeksAPI) UpdateAddonRequest(_parameter_0 *eks.UpdateAddonInput) (_result_0 *request.Request, _result_1 *eks.UpdateAddonOutput)

UpdateAddonRequest provides a mock function.

func (*MockeksAPI) UpdateAddonWithContext 

func (_m *MockeksAPI) UpdateAddonWithContext(_parameter_0 context.Context, _parameter_1 *eks.UpdateAddonInput, _parameter_2 ...request.Option) (_result_0 *eks.UpdateAddonOutput, _result_1 error)

UpdateAddonWithContext provides a mock function.

func (*MockeksAPI) UpdateClusterConfig 

func (_m *MockeksAPI) UpdateClusterConfig(_parameter_0 *eks.UpdateClusterConfigInput) (_result_0 *eks.UpdateClusterConfigOutput, _result_1 error)

UpdateClusterConfig provides a mock function.

func (*MockeksAPI) UpdateClusterConfigRequest 

func (_m *MockeksAPI) UpdateClusterConfigRequest(_parameter_0 *eks.UpdateClusterConfigInput) (_result_0 *request.Request, _result_1 *eks.UpdateClusterConfigOutput)

UpdateClusterConfigRequest provides a mock function.

func (*MockeksAPI) UpdateClusterConfigWithContext 

func (_m *MockeksAPI) UpdateClusterConfigWithContext(_parameter_0 context.Context, _parameter_1 *eks.UpdateClusterConfigInput, _parameter_2 ...request.Option) (_result_0 *eks.UpdateClusterConfigOutput, _result_1 error)

UpdateClusterConfigWithContext provides a mock function.

func (*MockeksAPI) UpdateClusterVersion 

func (_m *MockeksAPI) UpdateClusterVersion(_parameter_0 *eks.UpdateClusterVersionInput) (_result_0 *eks.UpdateClusterVersionOutput, _result_1 error)

UpdateClusterVersion provides a mock function.

func (*MockeksAPI) UpdateClusterVersionRequest 

func (_m *MockeksAPI) UpdateClusterVersionRequest(_parameter_0 *eks.UpdateClusterVersionInput) (_result_0 *request.Request, _result_1 *eks.UpdateClusterVersionOutput)

UpdateClusterVersionRequest provides a mock function.

func (*MockeksAPI) UpdateClusterVersionWithContext 

func (_m *MockeksAPI) UpdateClusterVersionWithContext(_parameter_0 context.Context, _parameter_1 *eks.UpdateClusterVersionInput, _parameter_2 ...request.Option) (_result_0 *eks.UpdateClusterVersionOutput, _result_1 error)

UpdateClusterVersionWithContext provides a mock function.

func (*MockeksAPI) UpdateNodegroupConfig 

func (_m *MockeksAPI) UpdateNodegroupConfig(_parameter_0 *eks.UpdateNodegroupConfigInput) (_result_0 *eks.UpdateNodegroupConfigOutput, _result_1 error)

UpdateNodegroupConfig provides a mock function.

func (*MockeksAPI) UpdateNodegroupConfigRequest 

func (_m *MockeksAPI) UpdateNodegroupConfigRequest(_parameter_0 *eks.UpdateNodegroupConfigInput) (_result_0 *request.Request, _result_1 *eks.UpdateNodegroupConfigOutput)

UpdateNodegroupConfigRequest provides a mock function.

func (*MockeksAPI) UpdateNodegroupConfigWithContext 

func (_m *MockeksAPI) UpdateNodegroupConfigWithContext(_parameter_0 context.Context, _parameter_1 *eks.UpdateNodegroupConfigInput, _parameter_2 ...request.Option) (_result_0 *eks.UpdateNodegroupConfigOutput, _result_1 error)

UpdateNodegroupConfigWithContext provides a mock function.

func (*MockeksAPI) UpdateNodegroupVersion 

func (_m *MockeksAPI) UpdateNodegroupVersion(_parameter_0 *eks.UpdateNodegroupVersionInput) (_result_0 *eks.UpdateNodegroupVersionOutput, _result_1 error)

UpdateNodegroupVersion provides a mock function.

func (*MockeksAPI) UpdateNodegroupVersionRequest 

func (_m *MockeksAPI) UpdateNodegroupVersionRequest(_parameter_0 *eks.UpdateNodegroupVersionInput) (_result_0 *request.Request, _result_1 *eks.UpdateNodegroupVersionOutput)

UpdateNodegroupVersionRequest provides a mock function.

func (*MockeksAPI) UpdateNodegroupVersionWithContext 

func (_m *MockeksAPI) UpdateNodegroupVersionWithContext(_parameter_0 context.Context, _parameter_1 *eks.UpdateNodegroupVersionInput, _parameter_2 ...request.Option) (_result_0 *eks.UpdateNodegroupVersionOutput, _result_1 error)

UpdateNodegroupVersionWithContext provides a mock function.

func (*MockeksAPI) WaitUntilAddonActive 

func (_m *MockeksAPI) WaitUntilAddonActive(_parameter_0 *eks.DescribeAddonInput) (_result_0 error)

WaitUntilAddonActive provides a mock function.

func (*MockeksAPI) WaitUntilAddonActiveWithContext 

func (_m *MockeksAPI) WaitUntilAddonActiveWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeAddonInput, _parameter_2 ...request.WaiterOption) (_result_0 error)

WaitUntilAddonActiveWithContext provides a mock function.

func (*MockeksAPI) WaitUntilAddonDeleted 

func (_m *MockeksAPI) WaitUntilAddonDeleted(_parameter_0 *eks.DescribeAddonInput) (_result_0 error)

WaitUntilAddonDeleted provides a mock function.

func (*MockeksAPI) WaitUntilAddonDeletedWithContext 

func (_m *MockeksAPI) WaitUntilAddonDeletedWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeAddonInput, _parameter_2 ...request.WaiterOption) (_result_0 error)

WaitUntilAddonDeletedWithContext provides a mock function.

func (*MockeksAPI) WaitUntilClusterActive 

func (_m *MockeksAPI) WaitUntilClusterActive(_parameter_0 *eks.DescribeClusterInput) (_result_0 error)

WaitUntilClusterActive provides a mock function.

func (*MockeksAPI) WaitUntilClusterActiveWithContext 

func (_m *MockeksAPI) WaitUntilClusterActiveWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeClusterInput, _parameter_2 ...request.WaiterOption) (_result_0 error)

WaitUntilClusterActiveWithContext provides a mock function.

func (*MockeksAPI) WaitUntilClusterDeleted 

func (_m *MockeksAPI) WaitUntilClusterDeleted(_parameter_0 *eks.DescribeClusterInput) (_result_0 error)

WaitUntilClusterDeleted provides a mock function.

func (*MockeksAPI) WaitUntilClusterDeletedWithContext 

func (_m *MockeksAPI) WaitUntilClusterDeletedWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeClusterInput, _parameter_2 ...request.WaiterOption) (_result_0 error)

WaitUntilClusterDeletedWithContext provides a mock function.

func (*MockeksAPI) WaitUntilNodegroupActive 

func (_m *MockeksAPI) WaitUntilNodegroupActive(_parameter_0 *eks.DescribeNodegroupInput) (_result_0 error)

WaitUntilNodegroupActive provides a mock function.

func (*MockeksAPI) WaitUntilNodegroupActiveWithContext 

func (_m *MockeksAPI) WaitUntilNodegroupActiveWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeNodegroupInput, _parameter_2 ...request.WaiterOption) (_result_0 error)

WaitUntilNodegroupActiveWithContext provides a mock function.

func (*MockeksAPI) WaitUntilNodegroupDeleted 

func (_m *MockeksAPI) WaitUntilNodegroupDeleted(_parameter_0 *eks.DescribeNodegroupInput) (_result_0 error)

WaitUntilNodegroupDeleted provides a mock function.

func (*MockeksAPI) WaitUntilNodegroupDeletedWithContext 

func (_m *MockeksAPI) WaitUntilNodegroupDeletedWithContext(_parameter_0 context.Context, _parameter_1 *eks.DescribeNodegroupInput, _parameter_2 ...request.WaiterOption) (_result_0 error)

WaitUntilNodegroupDeletedWithContext provides a mock function.

type Provider 

type Provider struct {
	KeyARN string
}

type SaveClusterVersionActivity 

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

func NewSaveClusterVersionActivity 

func NewSaveClusterVersionActivity(manager Clusters) SaveClusterVersionActivity

func (SaveClusterVersionActivity) Execute 

func (a SaveClusterVersionActivity) Execute(ctx context.Context, input SaveClusterVersionActivityInput) error

type SaveClusterVersionActivityInput 

type SaveClusterVersionActivityInput struct {
	ClusterID uint
	Version   string
}

type SaveK8sConfigActivity 

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

func NewSaveK8sConfigActivity 

func NewSaveK8sConfigActivity(awsSessionFactory *awsworkflow.AWSSessionFactory, manager Clusters) SaveK8sConfigActivity

func (SaveK8sConfigActivity) Execute 

func (a SaveK8sConfigActivity) Execute(ctx context.Context, input SaveK8sConfigActivityInput) (string, error)

type SaveK8sConfigActivityInput 

type SaveK8sConfigActivityInput struct {
	ClusterID   uint
	ClusterUID  string
	ClusterName string

	OrganizationID   uint
	ProviderSecretID string
	UserSecretID     string
	Region           string
}

type SaveNetworkDetailsActivity 

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

func NewSaveNetworkDetailsActivity 

func NewSaveNetworkDetailsActivity(manager Clusters) SaveNetworkDetailsActivity

func (SaveNetworkDetailsActivity) Execute 

func (a SaveNetworkDetailsActivity) Execute(ctx context.Context, input SaveNetworkDetailsInput) error

type SaveNetworkDetailsInput 

type SaveNetworkDetailsInput struct {
	ClusterID uint

	VpcID              string
	NodeInstanceRoleID string
	Subnets            []Subnet
}

type SaveNodePoolsActivity 

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

func NewSaveNodePoolsActivity 

func NewSaveNodePoolsActivity(manager Clusters) SaveNodePoolsActivity

func (SaveNodePoolsActivity) Execute 

func (a SaveNodePoolsActivity) Execute(ctx context.Context, input SaveNodePoolsActivityInput) error

type SaveNodePoolsActivityInput 

type SaveNodePoolsActivityInput struct {
	ClusterID uint

	NodePoolsToDelete map[string]AutoscaleGroup
	NodePoolsToUpdate map[string]AutoscaleGroup
	NodePoolsToCreate map[string]AutoscaleGroup
	NodePoolsToKeep   map[string]bool
}

type SelectVolumeSizeActivity 

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

func NewSelectVolumeSizeActivity 

func NewSelectVolumeSizeActivity(defaultVolumeSize int) (activity *SelectVolumeSizeActivity)

func (*SelectVolumeSizeActivity) Execute 

func (a *SelectVolumeSizeActivity) Execute(ctx context.Context, input SelectVolumeSizeActivityInput) (output *SelectVolumeSizeActivityOutput, err error)

func (SelectVolumeSizeActivity) Register 

func (a SelectVolumeSizeActivity) Register(worker worker.Registry)

Register registers the activity.

type SelectVolumeSizeActivityInput 

type SelectVolumeSizeActivityInput struct {
	AMISize            int
	OptionalVolumeSize int
}

type SelectVolumeSizeActivityOutput 

type SelectVolumeSizeActivityOutput struct {
	VolumeSize int
}

type SetClusterStatusActivity 

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

func NewSetClusterStatusActivity 

func NewSetClusterStatusActivity(manager Clusters) SetClusterStatusActivity

func (SetClusterStatusActivity) Execute 

func (a SetClusterStatusActivity) Execute(ctx context.Context, input SetClusterStatusActivityInput) error

type SetClusterStatusActivityInput 

type SetClusterStatusActivityInput struct {
	ClusterID     uint
	Status        string
	StatusMessage string
}

type SetNodePoolStatusActivity 

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

SetNodePoolStatusActivity collects the static high level component objects required for setting a node pool\s status.

func NewSetNodePoolStatusActivity 

func NewSetNodePoolStatusActivity(nodePoolStore eks.NodePoolStore) (activity *SetNodePoolStatusActivity)

NewSetNodePoolStatusActivity instantiates a node pool status setting activity.

func (SetNodePoolStatusActivity) Execute 

func (a SetNodePoolStatusActivity) Execute(ctx context.Context, input SetNodePoolStatusActivityInput) (err error)

Execute executes the activity.

func (SetNodePoolStatusActivity) Register 

func (a SetNodePoolStatusActivity) Register(worker worker.Registry)

Register registers the activity.

type SetNodePoolStatusActivityInput 

type SetNodePoolStatusActivityInput struct {
	ClusterID             uint
	ClusterName           string
	NodePoolName          string
	NodePoolStatus        eks.NodePoolStatus
	NodePoolStatusMessage string
	OrganizationID        uint
}

SetNodePoolStatusActivityInput collects the required parameters for setting a node pool\s status.

type Subnet 

type Subnet struct {
	SubnetID         string
	Cidr             string
	AvailabilityZone string
}

Subnet holds the fields of a Amazon subnet

func NewSubnetsFromEKSSubnets 

func NewSubnetsFromEKSSubnets(
	eksSubnets []*eksmodel.EKSSubnetModel,
	optionalIncludedSubnetIDs ...string,
) ([]Subnet, error)

NewSubnetsFromEKSSubnets returns subnet objects optionally matching the specified subnet IDs from a EKS subnet model collection or an error if a subnet ID is not found among the provided EKS subnet models. If no subnet IDs are specified then all EKS subnet models are returned as subnets.

type UpdateAsgActivity 

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

UpdateAsgActivity responsible for creating IAM roles

func NewUpdateAsgActivity 

func NewUpdateAsgActivity(
	awsSessionFactory *awsworkflow.AWSSessionFactory,
	cloudFormationTemplate string,
	defaultNodeVolumeEncryption *eks.NodePoolVolumeEncryption,
) *UpdateAsgActivity

UpdateAsgActivity instantiates a new UpdateAsgActivity

func (*UpdateAsgActivity) Execute 

func (a *UpdateAsgActivity) Execute(ctx context.Context, input UpdateAsgActivityInput) (*UpdateAsgActivityOutput, error)

type UpdateAsgActivityInput 

type UpdateAsgActivityInput struct {
	EKSActivityInput

	// name of the cloud formation template stack
	StackName            string
	Name                 string
	Version              string
	NodeSpotPrice        string
	Autoscaling          bool
	NodeMinCount         int
	NodeMaxCount         int
	Count                int
	NodeVolumeEncryption *eks.NodePoolVolumeEncryption
	NodeVolumeSize       int
	NodeVolumeType       string
	NodeImage            string
	NodeInstanceType     string

	// SecurityGroups collects the user specified custom node security group
	// IDs.
	SecurityGroups   []string
	UseInstanceStore *bool

	Labels map[string]string
	Tags   map[string]string

	CurrentTemplateVersion semver.Version
}

UpdateAsgActivityInput holds data needed for setting up IAM roles

type UpdateAsgActivityOutput 

type UpdateAsgActivityOutput struct{}

UpdateAsgActivityOutput holds the output data of the UpdateAsgActivityOutput

type UploadSSHKeyActivity 

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

UploadSSHKeyActivity responsible for uploading SSH key

func NewUploadSSHKeyActivity 

func NewUploadSSHKeyActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *UploadSSHKeyActivity

UploadSSHKeyActivity instantiates a new UploadSSHKeyActivity

func (*UploadSSHKeyActivity) Execute 

func (a *UploadSSHKeyActivity) Execute(ctx context.Context, input UploadSSHKeyActivityInput) (*UploadSSHKeyActivityOutput, error)

type UploadSSHKeyActivityInput 

type UploadSSHKeyActivityInput struct {
	EKSActivityInput
	SSHKeyName  string
	SSHSecretID string
}

UploadSSHKeyActivityInput holds data needed to upload SSH key

type UploadSSHKeyActivityOutput 

type UploadSSHKeyActivityOutput struct{}

UploadSSHKeyActivityOutput holds the output data of UploadSSHKeyActivity

type ValidateIAMRoleActivity 

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

ValidateIAMRoleActivity responsible for validating IAM role

func NewValidateIAMRoleActivity 

func NewValidateIAMRoleActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *ValidateIAMRoleActivity

NewValidateIAMRoleActivity instantiates a new ValidateIAMRoleActivity

func (*ValidateIAMRoleActivity) Execute 

func (a *ValidateIAMRoleActivity) Execute(ctx context.Context, input ValidateIAMRoleActivityInput) (*ValidateIAMRoleActivityOutput, error)

type ValidateIAMRoleActivityInput 

type ValidateIAMRoleActivityInput struct {
	EKSActivityInput

	ClusterRoleID string
}

ValidateIAMRoleActivityInput holds data needed to validate IAM Role

type ValidateIAMRoleActivityOutput 

type ValidateIAMRoleActivityOutput struct{}

ValidateIAMRoleActivityOutput holds the output data of ValidateIAMRoleActivity

type WaitELBsDeletionActivity 

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

WaitELBsDeletionActivity waits for the deletion of a list of ELBs identified by name

func NewWaitELBsDeletionActivity 

func NewWaitELBsDeletionActivity(awsSessionFactory *awsworkflow.AWSSessionFactory) *WaitELBsDeletionActivity

NewWaitELBsDeletionActivity instantiates a new NewWaitELBsDeletionActivity

func (*WaitELBsDeletionActivity) Execute 

func (a *WaitELBsDeletionActivity) Execute(ctx context.Context, input WaitELBsDeletionActivityActivityInput) error

type WaitELBsDeletionActivityActivityInput 

type WaitELBsDeletionActivityActivityInput struct {
	EKSActivityInput
	LoadBalancerNames []string
}

WaitELBsDeletionActivity holds the names of the ELBs to wait for to be deleted

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.