pkeworkflow

type AWSActivityInput struct {
	OrganizationID uint
	SecretID       string
	Region         string
}

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

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 interface {
	// New instantiates an AWS client object.
	New(organizationID uint, secretID string, region string) (*session.Session, error)
}

type CalculateNodePoolVersionActivity struct{}

type CalculateNodePoolVersionActivityInput struct {
	Image      string
	VolumeSize int
	Version    string
}

type CalculateNodePoolVersionActivityOutput struct {
	Version string
}

type Cluster interface {
	GetID() uint
	GetUID() string
	GetName() string
	GetOrganizationId() uint
	SetStatus(string, string) error
	GetNodePools() []NodePool
	GetSshPublicKey() (string, error)
	GetLocation() string
	GetK8sConfig() ([]byte, error)
}

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 Clusters interface {
	GetCluster(ctx context.Context, id uint) (Cluster, error)
}

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

type CreateAWSRolesActivityInput struct {
	AWSActivityInput
	ClusterID uint
}

type CreateClusterWorkflow struct {
	DefaultEBSCSIDriverChartVersion string
	DefaultNodeVolumeSize           int
	GlobalRegion                    string
	// contains filtered or unexported fields
}

type CreateClusterWorkflowInput struct {
	OrganizationID              uint
	ClusterID                   uint
	ClusterUID                  string
	ClusterName                 string
	SecretID                    string
	Region                      string
	PipelineExternalURL         string
	PipelineExternalURLInsecure bool
	OIDCEnabled                 bool
	VPCID                       string
	KubernetesVersion           string
}

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

type CreateDexClientActivityInput struct {
	ClusterID uint
}

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

type CreateElasticIPActivityInput struct {
	AWSActivityInput
	ClusterID   uint
	ClusterName string
}

type CreateElasticIPActivityOutput struct {
	PublicIp     string
	AllocationId string
}

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

type CreateMasterActivityInput struct {
	ClusterID                 uint
	VPCID                     string
	VPCDefaultSecurityGroupID string
	SubnetIDs                 []string
	MultiMaster               bool
	MasterInstanceProfile     string
	ExternalBaseUrl           string
	ExternalBaseUrlInsecure   bool
	Pool                      NodePool
	SSHKeyName                string

	EIPAllocationID string

	TargetGroup string
}

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

type CreateNLBActivityInput struct {
	AWSActivityInput
	ClusterID   uint
	ClusterName string
	VPCID       string
	SubnetIds   []string
}

type CreateNLBActivityOutput struct {
	DNSName     string
	TargetGroup string
}

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

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
}

type CreateSubnetActivityOutput struct {
	SubnetID         string
	Cidr             string
	AvailabilityZone string
}

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

type CreateVPCActivityInput struct {
	AWSActivityInput
	ClusterID        uint
	ClusterName      string
	VPCID            string
	AvailabilityZone string
}

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

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

type CreateWorkerPoolActivityInput struct {
	ClusterID                 uint
	Pool                      NodePool
	VPCID                     string
	VPCDefaultSecurityGroupID string
	SubnetIDs                 []string
	WorkerInstanceProfile     string
	ClusterSecurityGroup      string
	ExternalBaseUrl           string
	ExternalBaseUrlInsecure   bool
	ImageID                   string
	SSHKeyName                string
}

type DeleteClusterWorkflowInput struct {
	ClusterID uint
}

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

type DeleteDexClientActivityInput struct {
	ClusterID uint
}

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

type DeleteElasticIPActivityInput struct {
	ClusterID uint
}

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

type DeleteNLBActivityInput struct {
	ClusterID uint
}

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

type DeletePoolActivityInput struct {
	ClusterID uint
	Pool      NodePool
}

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

type DeleteSSHKeyPairActivityInput struct {
	ClusterID uint
}

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

type DeleteSubnetActivityInput struct {
	ClusterID        uint
	AvailabilityZone string
}

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

type DeleteVPCActivityInput struct {
	ClusterID uint
}

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)
}

type EC2Factory struct{}

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

type GenerateCertificatesActivityInput struct {
	ClusterID uint
}

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

type GetVpcDefaultSecurityGroupActivityInput struct {
	AWSActivityInput
	ClusterID uint
	VpcID     string
}

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

type ListNodePoolsActivityInput struct {
	ClusterID uint
}

type NodePool struct {
	Name              string
	MinCount          int
	MaxCount          int
	Count             int
	Autoscaling       bool
	Master            bool
	Worker            bool
	InstanceType      string
	AvailabilityZones []string
	ImageID           string
	VolumeSize        int
	SpotPrice         string
	Subnets           []string
}

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
}

type SecretStore interface {
	// GetSecret returns a secret from an organization.
	GetSecret(organizationID uint, secretID string) (Secret, error)
}

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

type SelectImageActivityInput struct {
	ClusterID    uint
	InstanceType string
}

type SelectImageActivityOutput struct {
	ImageID string
}

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

type SelectVolumeSizeActivityInput struct {
	AWSActivityInput
	ImageID string
}

type SelectVolumeSizeActivityOutput struct {
	VolumeSize int
}

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

type SetMasterTaintActivityInput struct {
	ClusterID uint
}

type TokenGenerator interface {
	GenerateClusterToken(orgID, clusterID uint) (string, string, error)
}

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

type UpdateClusterNetworkActivityInput struct {
	ClusterID       uint
	APISeverAddress string
	VPCID           string
	Subnets         []string
}

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

type UpdateClusterStatusActivityInput struct {
	ClusterID     uint
	Status        string
	StatusMessage string
}

type UpdateClusterWorkflow struct {
	DefaultNodeVolumeSize int
}

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 struct {
	// contains filtered or unexported fields
}

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
}

type UpdateMasterNodeGroupActivityOutput struct {
	NodePoolChanged bool
}

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

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
}

type UpdateNodeGroupActivityOutput struct {
	NodePoolChanged bool
}

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

type UpdatePoolActivityInput struct {
	AWSActivityInput
	Pool             NodePool
	AutoScalingGroup string
}

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

type UploadSSHKeyPairActivityInput struct {
	ClusterID uint
}

type UploadSSHKeyPairActivityOutput struct {
	KeyName string
}

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

type WaitCFCompletionActivityInput struct {
	AWSActivityInput
	StackID string
}

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

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

type WaitForDeleteSubnetActivity struct {
	AvailabilityZone string
	// contains filtered or unexported fields
}

type WaitForDeleteVPCActivity struct {
	DeleteVPCActivity
}