adapter

Documentation

Index

• Constants
• func Migrate(db *gorm.DB, logger common.Logger) error
• type ClusterStore
  • func NewClusterStore(db *gorm.DB, logger common.Logger) ClusterStore
  • func (s ClusterStore) Create(params pke.CreateParams) (pke.Cluster, error)
  • func (s ClusterStore) CreateNodePool(clusterID uint, nodePool pke.NodePool) error
  • func (s ClusterStore) Delete(clusterID uint) error
  • func (s ClusterStore) DeleteNodePool(clusterID uint, nodePoolName string) error
  • func (s ClusterStore) GetByID(clusterID uint) (pke.Cluster, error)
  • func (s ClusterStore) GetConfigSecretID(clusterID uint) (string, error)
  • func (s ClusterStore) SetActiveWorkflowID(clusterID uint, workflowID string) error
  • func (s ClusterStore) SetConfigSecretID(clusterID uint, secretID string) error
  • func (s ClusterStore) SetNodePoolSizes(clusterID uint, nodePoolName string, min, max, desiredCount uint, ...) error
  • func (s ClusterStore) SetSSHSecretID(clusterID uint, secretID string) error
  • func (s ClusterStore) SetStatus(clusterID uint, status, message string) error
  • func (s ClusterStore) UpdateClusterAccessPoints(clusterID uint, accessPoints pke.AccessPoints) error

Constants

const (
	ClustersTableName  = "azure_pke_clusters"
	NodePoolsTableName = "azure_pke_node_pools"
)

Functions

func Migrate

func Migrate(db *gorm.DB, logger common.Logger) error

Migrate executes the table migrations for the provider.

Types

type ClusterStore

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

func NewClusterStore

func NewClusterStore(db *gorm.DB, logger common.Logger) ClusterStore

func (ClusterStore) Create

func (s ClusterStore) Create(params pke.CreateParams) (pke.Cluster, error)

func (ClusterStore) CreateNodePool

func (s ClusterStore) CreateNodePool(clusterID uint, nodePool pke.NodePool) error

func (ClusterStore) Delete

func (s ClusterStore) Delete(clusterID uint) error

func (ClusterStore) DeleteNodePool

func (s ClusterStore) DeleteNodePool(clusterID uint, nodePoolName string) error

func (ClusterStore) GetByID

func (s ClusterStore) GetByID(clusterID uint) (pke.Cluster, error)

func (ClusterStore) GetConfigSecretID

func (s ClusterStore) GetConfigSecretID(clusterID uint) (string, error)

func (ClusterStore) SetActiveWorkflowID

func (s ClusterStore) SetActiveWorkflowID(clusterID uint, workflowID string) error

func (ClusterStore) SetConfigSecretID

func (s ClusterStore) SetConfigSecretID(clusterID uint, secretID string) error

func (ClusterStore) SetNodePoolSizes

func (s ClusterStore) SetNodePoolSizes(clusterID uint, nodePoolName string, min, max, desiredCount uint, autoscaling bool) error

func (ClusterStore) SetSSHSecretID

func (s ClusterStore) SetSSHSecretID(clusterID uint, secretID string) error

func (ClusterStore) SetStatus

func (s ClusterStore) SetStatus(clusterID uint, status, message string) error

func (ClusterStore) UpdateClusterAccessPoints

func (s ClusterStore) UpdateClusterAccessPoints(clusterID uint, accessPoints pke.AccessPoints) error