Documentation ¶
Index ¶
- Constants
- func DeleteClusterWorkflow(ctx workflow.Context, input DeleteClusterWorkflowInput) error
- func SelectImageAndVolumeSize(ctx workflow.Context, awsActivityInput AWSActivityInput, clusterID uint, ...) (selectedImageID string, selectedVolumeSize int, err error)
- func WithHeartBeatOption(ctx context.Context) request.Option
- type AWSActivityInput
- type AWSClientFactory
- type AWSCluster
- type AWSFactory
- type CalculateNodePoolVersionActivity
- type CalculateNodePoolVersionActivityInput
- type CalculateNodePoolVersionActivityOutput
- type Cluster
- type ClusterSecretStore
- type Clusters
- type CreateAWSRolesActivity
- type CreateAWSRolesActivityInput
- type CreateClusterWorkflow
- type CreateClusterWorkflowInput
- type CreateDexClientActivity
- type CreateDexClientActivityInput
- type CreateElasticIPActivity
- type CreateElasticIPActivityInput
- type CreateElasticIPActivityOutput
- type CreateMasterActivity
- type CreateMasterActivityInput
- type CreateNLBActivity
- type CreateNLBActivityInput
- type CreateNLBActivityOutput
- type CreateSubnetActivity
- type CreateSubnetActivityInput
- type CreateSubnetActivityOutput
- type CreateVPCActivity
- type CreateVPCActivityInput
- type CreateVpcActivityOutput
- type CreateWorkerPoolActivity
- type CreateWorkerPoolActivityInput
- type DeleteClusterWorkflowInput
- type DeleteDexClientActivity
- type DeleteDexClientActivityInput
- type DeleteElasticIPActivity
- type DeleteElasticIPActivityInput
- type DeleteNLBActivity
- type DeleteNLBActivityInput
- type DeletePoolActivity
- type DeletePoolActivityInput
- type DeleteSSHKeyPairActivity
- type DeleteSSHKeyPairActivityInput
- type DeleteSubnetActivity
- type DeleteSubnetActivityInput
- type DeleteVPCActivity
- type DeleteVPCActivityInput
- type EC2APIFactory
- type EC2Factory
- type GenerateCertificatesActivity
- type GenerateCertificatesActivityInput
- type GetVpcDefaultSecurityGroupActivity
- type GetVpcDefaultSecurityGroupActivityInput
- type ListNodePoolsActivity
- type ListNodePoolsActivityInput
- type NodePool
- type Secret
- type SecretStore
- type SelectImageActivity
- type SelectImageActivityInput
- type SelectImageActivityOutput
- type SelectVolumeSizeActivity
- type SelectVolumeSizeActivityInput
- type SelectVolumeSizeActivityOutput
- type SetMasterTaintActivity
- type SetMasterTaintActivityInput
- type TokenGenerator
- type UpdateClusterNetworkActivity
- type UpdateClusterNetworkActivityInput
- type UpdateClusterStatusActivity
- type UpdateClusterStatusActivityInput
- type UpdateClusterWorkflow
- type UpdateClusterWorkflowInput
- type UpdateMasterNodeGroupActivity
- type UpdateMasterNodeGroupActivityInput
- type UpdateMasterNodeGroupActivityOutput
- type UpdateNodeGroupActivity
- type UpdateNodeGroupActivityInput
- type UpdateNodeGroupActivityOutput
- type UpdatePoolActivity
- type UpdatePoolActivityInput
- type UploadSSHKeyPairActivity
- type UploadSSHKeyPairActivityInput
- type UploadSSHKeyPairActivityOutput
- type WaitCFCompletionActivity
- type WaitCFCompletionActivityInput
- type WaitForDeleteNLBActivity
- type WaitForDeletePoolActivity
- type WaitForDeleteSubnetActivity
- type WaitForDeleteVPCActivity
Constants ¶
const ( CreateAWSRolesActivityName = "pke-create-aws-roles-activity" PkeGlobalStackName = "pke-global" )
const ( DeletePoolActivityName = "pke-delete-aws-pool-activity" WaitForDeletePoolActivityName = "wait-for-pke-delete-aws-pool-activity" )
const CalculateNodePoolVersionActivityName = "pke-calculate-node-pool-version"
const (
CreateClusterWorkflowName = "pke-create-cluster"
)
const CreateDexClientActivityName = "pke-create-dex-client-activity"
const CreateElasticIPActivityName = "pke-create-eip-activity"
const CreateMasterActivityName = "pke-create-master-activity"
const CreateNLBActivityName = "pke-create-nlb-activity"
const CreateSubnetActivityName = "pke-create-subnet"
const CreateVPCActivityName = "pke-create-vpc-activity"
const CreateWorkerPoolActivityName = "pke-create-aws-worker-pool-activity"
const DeleteClusterWorkflowName = "pke-delete-cluster"
const DeleteDexClientActivityName = "pke-delete-dex-client-activity"
const DeleteElasticIPActivityName = "pke-delete-eip-activity"
const DeleteNLBActivityName = "pke-delete-nlb-activity"
const DeleteSSHKeyPairActivityName = "pke-delete-ssh-key-pair-activity"
const DeleteSubnetActivityName = "pke-delete-subnet-activity"
const DeleteVPCActivityName = "pke-delete-vpc-activity"
const ErrReasonStackFailed = "CLOUDFORMATION_STACK_FAILED"
ErrReasonStackFailed cadence custom error reason that denotes a stack operation that resulted a stack failure
const GenerateCertificatesActivityName = "pke-generate-certificates-activity"
const GetVpcDefaultSecurityGroupActivityName = "pke-get-vpc-default-sg-activity"
const ListNodePoolsActivityName = "pke-list-node-pools-activity"
const PKECloudFormationTemplateBasePath = "templates/pke"
const SelectImageActivityName = "pke-select-image-activity"
const (
SelectVolumeSizeActivityName = "pke-select-volume-size-activity"
)
const SetMasterTaintActivityName = "set-master-taint-activity"
const SubnetCloudFormationTemplate = "subnet.cf.yaml"
const UpdateClusterNetworkActivityName = "pke-update-cluster-network-activity"
const UpdateClusterStatusActivityName = "pke-update-cluster-status-activity"
const UpdateClusterWorkflowName = "pke-update-cluster"
const UpdateMasterNodeGroupActivityName = "pke-aws-update-master-node-group"
const UpdateNodeGroupActivityName = "pke-aws-update-node-group"
const UpdatePoolActivityName = "pke-update-aws-pool-activity"
const UploadSSHKeyPairActivityName = "pke-upload-ssh-key-pair-activity"
const WaitCFCompletionActivityName = "pke-wait-cf-completion-activity"
const WaitForDeleteNLBActivityName = "wait-for-pke-delete-nlb-activity"
const WaitForDeleteSubnetActivityName = "wait-for-pke-delete-subnet-activity"
const WaitForDeleteVPCActivityName = "wait-for-pke-delete-vpc-activity"
const WorkerCloudFormationTemplate = "worker.cf.yaml"
Variables ¶
This section is empty.
Functions ¶
func DeleteClusterWorkflow ¶
func DeleteClusterWorkflow(ctx workflow.Context, input DeleteClusterWorkflowInput) error
func SelectImageAndVolumeSize ¶
func SelectImageAndVolumeSize( ctx workflow.Context, awsActivityInput AWSActivityInput, clusterID uint, instanceType string, optionalImageID string, optionalVolumeSize int, defaultVolumeSize int, ) (selectedImageID string, selectedVolumeSize int, err error)
SelectImageAndVolumeSize returns an image ID and a volume size for the specified arguments after determining an image to use and the required volume size for it.
Types ¶
type AWSActivityInput ¶
type AWSClientFactory ¶
type AWSClientFactory struct {
// contains filtered or unexported fields
}
AWSClientFactory creates a new AWS client.
func NewAWSClientFactory ¶
func NewAWSClientFactory(secrets SecretStore) *AWSClientFactory
NewAWSClientFactory returns a new AWS client factory.
type AWSCluster ¶
type AWSCluster interface { GetAWSClient() (*session.Session, error) GetBootstrapCommand(string, string, bool, string, []string, string) (string, error) GetKubernetesVersion() (string, error) GetKubernetesContainerRuntime() (string, error) GetKubernetesNetworkProvider() (string, error) GetNetworkCloudProvider() (cloudProvider, vpcID string, subnets []string, err error) SaveNetworkCloudProvider(string, string, []string) error SaveNetworkApiServerAddress(string, string) error }
type AWSFactory ¶
type AWSFactory interface { // New instantiates an AWS client object. New(organizationID uint, secretID string, region string) (*session.Session, error) }
AWSFactory provides an interface for instantiating AWS client objects.
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 CalculateNodePoolVersionActivityOutput ¶
type CalculateNodePoolVersionActivityOutput struct {
Version string
}
type ClusterSecretStore ¶
type ClusterSecretStore interface { // EnsureSecretExists creates a secret for a cluster if it cannot be found and returns it's ID. EnsureSecretExists(ctx context.Context, clusterID uint, secret clustersecret.SecretCreateRequest) (string, error) }
type CreateAWSRolesActivity ¶
type CreateAWSRolesActivity struct {
// contains filtered or unexported fields
}
func NewCreateAWSRolesActivity ¶
func NewCreateAWSRolesActivity(awsClientFactory *AWSClientFactory) *CreateAWSRolesActivity
func (*CreateAWSRolesActivity) Execute ¶
func (a *CreateAWSRolesActivity) Execute(ctx context.Context, input CreateAWSRolesActivityInput) (string, error)
type CreateAWSRolesActivityInput ¶
type CreateAWSRolesActivityInput struct { AWSActivityInput ClusterID uint }
type CreateClusterWorkflow ¶
type CreateClusterWorkflow struct { DefaultEBSCSIDriverChartVersion string DefaultNodeVolumeSize int GlobalRegion string // contains filtered or unexported fields }
func NewCreateClusterWorkflow ¶
func NewCreateClusterWorkflow( defaultEBSCSIDriverChartVersion string, defaultNodeVolumeSize int, globalRegion string, ) CreateClusterWorkflow
func (CreateClusterWorkflow) Execute ¶
func (w CreateClusterWorkflow) Execute(ctx workflow.Context, input CreateClusterWorkflowInput) (err error)
type CreateDexClientActivity ¶
type CreateDexClientActivity struct {
// contains filtered or unexported fields
}
func NewCreateDexClientActivity ¶
func NewCreateDexClientActivity(clusters Clusters, clusterAuthService auth.ClusterAuthService) *CreateDexClientActivity
func (*CreateDexClientActivity) Execute ¶
func (a *CreateDexClientActivity) Execute(ctx context.Context, input CreateDexClientActivityInput) error
type CreateDexClientActivityInput ¶
type CreateDexClientActivityInput struct {
ClusterID uint
}
type CreateElasticIPActivity ¶
type CreateElasticIPActivity struct {
// contains filtered or unexported fields
}
func NewCreateElasticIPActivity ¶
func NewCreateElasticIPActivity(awsClientFactory *AWSClientFactory) *CreateElasticIPActivity
func (*CreateElasticIPActivity) Execute ¶
func (a *CreateElasticIPActivity) Execute(ctx context.Context, input CreateElasticIPActivityInput) (*CreateElasticIPActivityOutput, error)
type CreateElasticIPActivityInput ¶
type CreateElasticIPActivityInput struct { AWSActivityInput ClusterID uint ClusterName string }
type CreateMasterActivity ¶
type CreateMasterActivity struct {
// contains filtered or unexported fields
}
func NewCreateMasterActivity ¶
func NewCreateMasterActivity( clusters Clusters, tokenGenerator TokenGenerator, ) *CreateMasterActivity
func (*CreateMasterActivity) Execute ¶
func (a *CreateMasterActivity) Execute(ctx context.Context, input CreateMasterActivityInput) (string, error)
type CreateNLBActivity ¶
type CreateNLBActivity struct {
// contains filtered or unexported fields
}
func NewCreateNLBActivity ¶
func NewCreateNLBActivity(awsClientFactory *AWSClientFactory) *CreateNLBActivity
func (*CreateNLBActivity) Execute ¶
func (a *CreateNLBActivity) Execute(ctx context.Context, input CreateNLBActivityInput) (*CreateNLBActivityOutput, error)
type CreateNLBActivityInput ¶
type CreateNLBActivityInput struct { AWSActivityInput ClusterID uint ClusterName string VPCID string SubnetIds []string }
type CreateNLBActivityOutput ¶
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(awsClientFactory *AWSClientFactory) *CreateSubnetActivity
func (*CreateSubnetActivity) Execute ¶
func (a *CreateSubnetActivity) Execute(ctx context.Context, input CreateSubnetActivityInput) (*CreateSubnetActivityOutput, error)
type CreateSubnetActivityInput ¶
type CreateSubnetActivityInput struct { AWSActivityInput ClusterID uint ClusterName string // 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 CIDR of the subnet Cidr string // The availability zone of the subnet AvailabilityZone string }
CreateSubnetActivityInput holds data needed for setting up a Subnet for EKS cluster
type CreateSubnetActivityOutput ¶
CreateSubnetActivityOutput holds the output data of the CreateSubnetActivity
type CreateVPCActivity ¶
type CreateVPCActivity struct {
// contains filtered or unexported fields
}
func NewCreateVPCActivity ¶
func NewCreateVPCActivity(awsClientFactory *AWSClientFactory) *CreateVPCActivity
func (*CreateVPCActivity) Execute ¶
func (a *CreateVPCActivity) Execute(ctx context.Context, input CreateVPCActivityInput) (string, error)
type CreateVPCActivityInput ¶
type CreateVPCActivityInput struct { AWSActivityInput ClusterID uint ClusterName string VPCID string AvailabilityZone string }
type CreateVpcActivityOutput ¶
type CreateVpcActivityOutput struct { VpcID string RouteTableID string SecurityGroupID string NodeSecurityGroupID string StackID string }
CreateVpcActivityOutput holds the output data of the CreateVpcActivity
type CreateWorkerPoolActivity ¶
type CreateWorkerPoolActivity struct {
// contains filtered or unexported fields
}
func NewCreateWorkerPoolActivity ¶
func NewCreateWorkerPoolActivity( clusters Clusters, tokenGenerator TokenGenerator, ) *CreateWorkerPoolActivity
func (*CreateWorkerPoolActivity) Execute ¶
func (a *CreateWorkerPoolActivity) Execute(ctx context.Context, input CreateWorkerPoolActivityInput) (string, error)
type DeleteClusterWorkflowInput ¶
type DeleteClusterWorkflowInput struct {
ClusterID uint
}
type DeleteDexClientActivity ¶
type DeleteDexClientActivity struct {
// contains filtered or unexported fields
}
func NewDeleteDexClientActivity ¶
func NewDeleteDexClientActivity(clusters Clusters, clusterAuthService auth.ClusterAuthService) *DeleteDexClientActivity
func (*DeleteDexClientActivity) Execute ¶
func (a *DeleteDexClientActivity) Execute(ctx context.Context, input DeleteDexClientActivityInput) error
type DeleteDexClientActivityInput ¶
type DeleteDexClientActivityInput struct {
ClusterID uint
}
type DeleteElasticIPActivity ¶
type DeleteElasticIPActivity struct {
// contains filtered or unexported fields
}
func NewDeleteElasticIPActivity ¶
func NewDeleteElasticIPActivity(clusters Clusters) *DeleteElasticIPActivity
func (*DeleteElasticIPActivity) Execute ¶
func (a *DeleteElasticIPActivity) Execute(ctx context.Context, input DeleteElasticIPActivityInput) error
type DeleteElasticIPActivityInput ¶
type DeleteElasticIPActivityInput struct {
ClusterID uint
}
type DeleteNLBActivity ¶
type DeleteNLBActivity struct {
// contains filtered or unexported fields
}
func NewDeleteNLBActivity ¶
func NewDeleteNLBActivity(clusters Clusters) *DeleteNLBActivity
func (*DeleteNLBActivity) Execute ¶
func (a *DeleteNLBActivity) Execute(ctx context.Context, input DeleteNLBActivityInput) error
type DeleteNLBActivityInput ¶
type DeleteNLBActivityInput struct {
ClusterID uint
}
type DeletePoolActivity ¶
type DeletePoolActivity struct {
// contains filtered or unexported fields
}
func NewDeletePoolActivity ¶
func NewDeletePoolActivity(clusters Clusters) *DeletePoolActivity
func (*DeletePoolActivity) Execute ¶
func (a *DeletePoolActivity) Execute(ctx context.Context, input DeletePoolActivityInput) error
type DeletePoolActivityInput ¶
type DeleteSSHKeyPairActivity ¶
type DeleteSSHKeyPairActivity struct {
// contains filtered or unexported fields
}
func NewDeleteSSHKeyPairActivity ¶
func NewDeleteSSHKeyPairActivity(clusters Clusters) *DeleteSSHKeyPairActivity
func (*DeleteSSHKeyPairActivity) Execute ¶
func (a *DeleteSSHKeyPairActivity) Execute(ctx context.Context, input DeleteSSHKeyPairActivityInput) error
type DeleteSSHKeyPairActivityInput ¶
type DeleteSSHKeyPairActivityInput struct {
ClusterID uint
}
type DeleteSubnetActivity ¶
type DeleteSubnetActivity struct {
// contains filtered or unexported fields
}
func NewDeleteSubnetActivity ¶
func NewDeleteSubnetActivity(clusters Clusters) *DeleteSubnetActivity
func (*DeleteSubnetActivity) Execute ¶
func (a *DeleteSubnetActivity) Execute(ctx context.Context, input DeleteSubnetActivityInput) error
type DeleteVPCActivity ¶
type DeleteVPCActivity struct {
// contains filtered or unexported fields
}
func NewDeleteVPCActivity ¶
func NewDeleteVPCActivity(clusters Clusters) *DeleteVPCActivity
func (*DeleteVPCActivity) Execute ¶
func (a *DeleteVPCActivity) Execute(ctx context.Context, input DeleteVPCActivityInput) error
type DeleteVPCActivityInput ¶
type DeleteVPCActivityInput struct {
ClusterID uint
}
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 GenerateCertificatesActivity ¶
type GenerateCertificatesActivity struct {
// contains filtered or unexported fields
}
func NewGenerateCertificatesActivity ¶
func NewGenerateCertificatesActivity(secrets ClusterSecretStore) *GenerateCertificatesActivity
func (*GenerateCertificatesActivity) Execute ¶
func (a *GenerateCertificatesActivity) Execute(ctx context.Context, input GenerateCertificatesActivityInput) error
type GenerateCertificatesActivityInput ¶
type GenerateCertificatesActivityInput struct {
ClusterID uint
}
type GetVpcDefaultSecurityGroupActivity ¶
type GetVpcDefaultSecurityGroupActivity struct {
// contains filtered or unexported fields
}
func NewGetVpcDefaultSecurityGroupActivity ¶
func NewGetVpcDefaultSecurityGroupActivity(awsClientFactory *AWSClientFactory) *GetVpcDefaultSecurityGroupActivity
func (*GetVpcDefaultSecurityGroupActivity) Execute ¶
func (a *GetVpcDefaultSecurityGroupActivity) Execute(ctx context.Context, input GetVpcDefaultSecurityGroupActivityInput) (string, error)
type GetVpcDefaultSecurityGroupActivityInput ¶
type GetVpcDefaultSecurityGroupActivityInput struct { AWSActivityInput ClusterID uint VpcID string }
type ListNodePoolsActivity ¶
type ListNodePoolsActivity struct {
// contains filtered or unexported fields
}
func NewListNodePoolsActivity ¶
func NewListNodePoolsActivity(clusters Clusters) *ListNodePoolsActivity
func (*ListNodePoolsActivity) Execute ¶
func (a *ListNodePoolsActivity) Execute(ctx context.Context, input ListNodePoolsActivityInput) ([]NodePool, error)
type ListNodePoolsActivityInput ¶
type ListNodePoolsActivityInput struct {
ClusterID uint
}
type Secret ¶
type Secret interface { // GetValues returns the secret values. GetValues() map[string]string // ValidateSecretType checks that the secret is of a certain type. ValidateSecretType(t string) error }
Secret represents an item in the secret store.
type SecretStore ¶
type SecretStore interface { // GetSecret returns a secret from an organization. GetSecret(organizationID uint, secretID string) (Secret, error) }
SecretStore accesses secrets.
type SelectImageActivity ¶
type SelectImageActivity struct {
// contains filtered or unexported fields
}
func NewSelectImageActivity ¶
func NewSelectImageActivity(clusters Clusters, imageSelector pkeaws.ImageSelector) *SelectImageActivity
func (*SelectImageActivity) Execute ¶
func (a *SelectImageActivity) Execute(ctx context.Context, input SelectImageActivityInput) (*SelectImageActivityOutput, error)
type SelectImageActivityOutput ¶
type SelectImageActivityOutput struct {
ImageID string
}
type SelectVolumeSizeActivity ¶
type SelectVolumeSizeActivity struct {
// contains filtered or unexported fields
}
func NewSelectVolumeSizeActivity ¶
func NewSelectVolumeSizeActivity(awsFactory AWSFactory, ec2Factory EC2APIFactory) *SelectVolumeSizeActivity
func (*SelectVolumeSizeActivity) Execute ¶
func (a *SelectVolumeSizeActivity) Execute(ctx context.Context, input SelectVolumeSizeActivityInput) (*SelectVolumeSizeActivityOutput, error)
type SelectVolumeSizeActivityInput ¶
type SelectVolumeSizeActivityInput struct { AWSActivityInput ImageID string }
type SelectVolumeSizeActivityOutput ¶
type SelectVolumeSizeActivityOutput struct {
VolumeSize int
}
type SetMasterTaintActivity ¶
type SetMasterTaintActivity struct {
// contains filtered or unexported fields
}
SetMasterTaintActivity sets the correct taints and labels for a single-node PKE cluster
func NewSetMasterTaintActivity ¶
func NewSetMasterTaintActivity(clusters Clusters) *SetMasterTaintActivity
func (*SetMasterTaintActivity) Execute ¶
func (a *SetMasterTaintActivity) Execute(ctx context.Context, input SetMasterTaintActivityInput) error
type SetMasterTaintActivityInput ¶
type SetMasterTaintActivityInput struct {
ClusterID uint
}
type TokenGenerator ¶
type UpdateClusterNetworkActivity ¶
type UpdateClusterNetworkActivity struct {
// contains filtered or unexported fields
}
func NewUpdateClusterNetworkActivity ¶
func NewUpdateClusterNetworkActivity(clusters Clusters) *UpdateClusterNetworkActivity
func (*UpdateClusterNetworkActivity) Execute ¶
func (a *UpdateClusterNetworkActivity) Execute(ctx context.Context, input UpdateClusterNetworkActivityInput) error
type UpdateClusterStatusActivity ¶
type UpdateClusterStatusActivity struct {
// contains filtered or unexported fields
}
func NewUpdateClusterStatusActivity ¶
func NewUpdateClusterStatusActivity(clusters Clusters) *UpdateClusterStatusActivity
func (*UpdateClusterStatusActivity) Execute ¶
func (a *UpdateClusterStatusActivity) Execute(ctx context.Context, input UpdateClusterStatusActivityInput) error
type UpdateClusterWorkflow ¶
type UpdateClusterWorkflow struct {
DefaultNodeVolumeSize int
}
func (UpdateClusterWorkflow) Execute ¶
func (w UpdateClusterWorkflow) Execute(ctx workflow.Context, input UpdateClusterWorkflowInput) error
type UpdateClusterWorkflowInput ¶
type UpdateClusterWorkflowInput struct { OrganizationID uint ClusterID uint ClusterUID string ClusterName string SecretID string Region string PipelineExternalURL string PipelineExternalURLInsecure bool NodePoolsToAdd []NodePool NodePoolsToDelete []NodePool NodePoolsToUpdate []NodePool VPCID string SubnetIDs []string }
type UpdateMasterNodeGroupActivity ¶
type UpdateMasterNodeGroupActivity struct {
// contains filtered or unexported fields
}
UpdateMasterNodeGroupActivity updates a master node group.
func NewUpdateMasterNodeGroupActivity ¶
func NewUpdateMasterNodeGroupActivity( sessionFactory AWSFactory, clusters Clusters, tokenGenerator TokenGenerator, externalBaseURL string, externalBaseURLInsecure bool, ) UpdateMasterNodeGroupActivity
NewUpdateMasterNodeGroupActivity creates a new UpdateMasterNodeGroupActivity instance.
func (UpdateMasterNodeGroupActivity) Execute ¶
func (a UpdateMasterNodeGroupActivity) Execute(ctx context.Context, input UpdateMasterNodeGroupActivityInput) (UpdateMasterNodeGroupActivityOutput, error)
Execute is the main body of the activity, returns true if there was any update and that was successful.
func (UpdateMasterNodeGroupActivity) Register ¶
func (a UpdateMasterNodeGroupActivity) Register(worker worker.Registry)
Register registers the activity in the worker.
type UpdateMasterNodeGroupActivityInput ¶
type UpdateMasterNodeGroupActivityInput struct { SecretID string Region string OrganizationID uint ClusterName string ClusterID uint StackName string NodePoolName string NodePoolVersion string NodeVolumeSize int NodeImage string Version string DesiredCapacity int64 ClusterTags map[string]string }
UpdateMasterNodeGroupActivityInput holds the parameters for the node group update.
type UpdateMasterNodeGroupActivityOutput ¶
type UpdateMasterNodeGroupActivityOutput struct {
NodePoolChanged bool
}
type UpdateNodeGroupActivity ¶
type UpdateNodeGroupActivity struct {
// contains filtered or unexported fields
}
UpdateNodeGroupActivity updates an existing node group.
func NewUpdateNodeGroupActivity ¶
func NewUpdateNodeGroupActivity( sessionFactory AWSFactory, clusters Clusters, tokenGenerator TokenGenerator, externalBaseURL string, externalBaseURLInsecure bool, ) UpdateNodeGroupActivity
NewUpdateNodeGroupActivity creates a new UpdateNodeGroupActivity instance.
func (UpdateNodeGroupActivity) Execute ¶
func (a UpdateNodeGroupActivity) Execute(ctx context.Context, input UpdateNodeGroupActivityInput) (UpdateNodeGroupActivityOutput, error)
Execute is the main body of the activity, returns true if there was any update and that was successful.
func (UpdateNodeGroupActivity) Register ¶
func (a UpdateNodeGroupActivity) Register(worker worker.Registry)
Register registers the activity in the worker.
type UpdateNodeGroupActivityInput ¶
type UpdateNodeGroupActivityInput struct { SecretID string Region string OrganizationID uint ClusterName string ClusterID uint StackName string NodePoolName string NodePoolVersion string NodeVolumeSize int NodeImage string Version string DesiredCapacity int64 MaxBatchSize int ClusterTags map[string]string }
UpdateNodeGroupActivityInput holds the parameters for the node group update.
type UpdateNodeGroupActivityOutput ¶
type UpdateNodeGroupActivityOutput struct {
NodePoolChanged bool
}
type UpdatePoolActivity ¶
type UpdatePoolActivity struct {
// contains filtered or unexported fields
}
func NewUpdatePoolActivity ¶
func NewUpdatePoolActivity(awsClientFactory *AWSClientFactory) *UpdatePoolActivity
func (*UpdatePoolActivity) Execute ¶
func (a *UpdatePoolActivity) Execute(ctx context.Context, input UpdatePoolActivityInput) error
type UpdatePoolActivityInput ¶
type UpdatePoolActivityInput struct { AWSActivityInput Pool NodePool AutoScalingGroup string }
type UploadSSHKeyPairActivity ¶
type UploadSSHKeyPairActivity struct {
// contains filtered or unexported fields
}
func NewUploadSSHKeyPairActivity ¶
func NewUploadSSHKeyPairActivity(clusters Clusters) *UploadSSHKeyPairActivity
func (*UploadSSHKeyPairActivity) Execute ¶
func (a *UploadSSHKeyPairActivity) Execute(ctx context.Context, input UploadSSHKeyPairActivityInput) (*UploadSSHKeyPairActivityOutput, error)
type UploadSSHKeyPairActivityInput ¶
type UploadSSHKeyPairActivityInput struct {
ClusterID uint
}
type UploadSSHKeyPairActivityOutput ¶
type UploadSSHKeyPairActivityOutput struct {
KeyName string
}
type WaitCFCompletionActivity ¶
type WaitCFCompletionActivity struct {
// contains filtered or unexported fields
}
func NewWaitCFCompletionActivity ¶
func NewWaitCFCompletionActivity(awsClientFactory *AWSClientFactory) *WaitCFCompletionActivity
func (*WaitCFCompletionActivity) Execute ¶
func (a *WaitCFCompletionActivity) Execute(ctx context.Context, input WaitCFCompletionActivityInput) (map[string]string, error)
type WaitCFCompletionActivityInput ¶
type WaitCFCompletionActivityInput struct { AWSActivityInput StackID string }
type WaitForDeleteNLBActivity ¶
type WaitForDeleteNLBActivity struct {
// contains filtered or unexported fields
}
func NewWaitForDeleteNLBActivity ¶
func NewWaitForDeleteNLBActivity(clusters Clusters) *WaitForDeleteNLBActivity
func (*WaitForDeleteNLBActivity) Execute ¶
func (a *WaitForDeleteNLBActivity) Execute(ctx context.Context, input DeleteNLBActivityInput) error
type WaitForDeletePoolActivity ¶
type WaitForDeletePoolActivity struct {
// contains filtered or unexported fields
}
func NewWaitForDeletePoolActivity ¶
func NewWaitForDeletePoolActivity(clusters Clusters) *WaitForDeletePoolActivity
func (*WaitForDeletePoolActivity) Execute ¶
func (a *WaitForDeletePoolActivity) Execute(ctx context.Context, input DeletePoolActivityInput) error
type WaitForDeleteSubnetActivity ¶
type WaitForDeleteSubnetActivity struct { AvailabilityZone string // contains filtered or unexported fields }
func NewWaitForDeleteSubnetActivity ¶
func NewWaitForDeleteSubnetActivity(clusters Clusters) *WaitForDeleteSubnetActivity
func (*WaitForDeleteSubnetActivity) Execute ¶
func (a *WaitForDeleteSubnetActivity) Execute(ctx context.Context, input DeleteSubnetActivityInput) error
type WaitForDeleteVPCActivity ¶
type WaitForDeleteVPCActivity struct {
DeleteVPCActivity
}
func NewWaitForDeleteVPCActivity ¶
func NewWaitForDeleteVPCActivity(clusters Clusters) *WaitForDeleteVPCActivity
func (*WaitForDeleteVPCActivity) Execute ¶
func (a *WaitForDeleteVPCActivity) Execute(ctx context.Context, input DeleteVPCActivityInput) error
Source Files ¶
- aws.go
- calculate_node_pool_version_activity.go
- cloudformation.go
- cluster.go
- create_aws_roles_activity.go
- create_aws_worker_pool_activity.go
- create_cluster.go
- create_dex_client.go
- create_elastic_ip_activity.go
- create_master_activity.go
- create_nlb_activity.go
- create_subnet_activity.go
- create_vpc_activity.go
- delete_aws_pool_activity.go
- delete_cluster.go
- delete_dex_client.go
- delete_elastic_ip_activity.go
- delete_nlb.go
- delete_ssh_key_pair_activity.go
- delete_subnet_activity.go
- delete_vpc_activity.go
- ec2.go
- generate_certificates_activity.go
- get_vpc_default_sg_activity.go
- heartbeat_option.go
- list_nodepools_activity.go
- operation.go
- select_image_activity.go
- select_image_and_volume_size.go
- select_volume_size_activity.go
- set_master_taint_activity.go
- update_aws_pool_activity.go
- update_cluster.go
- update_cluster_network.go
- update_cluster_status_activity.go
- update_master_node_group_activity.go
- update_node_group_activity.go
- upload_ssh_key_pair_activity.go
- wait_for_cf_completion_activity.go