nutanix

Documentation

Index

• Constants
• func CategoryValue(clusterName string) string
• func GetCategories(ctx context.Context, client *ClientSet) ([]nutanixv3.CategoryKeyStatus, error)
• func GetCategoryValues(ctx context.Context, client *ClientSet, category string) ([]nutanixv3.CategoryValueStatus, error)
• func GetClusterByName(ctx context.Context, client *ClientSet, name string) (*nutanixv3.ClusterIntentResponse, error)
• func GetClusters(ctx context.Context, client *ClientSet) ([]nutanixv3.ClusterIntentResponse, error)
• func GetProjectByName(ctx context.Context, client *ClientSet, name string) (*nutanixv3.Project, error)
• func GetProjects(ctx context.Context, client *ClientSet) ([]nutanixv3.Project, error)
• func GetSubnetByName(ctx context.Context, client *ClientSet, name, clusterID string) (*nutanixv3.SubnetIntentResponse, error)
• func GetSubnets(ctx context.Context, client *ClientSet, clusterName, projectName string) ([]nutanixv3.SubnetIntentResponse, error)
• func ValidateCredentials(ctx context.Context, endpoint string, port *int32, allowInsecure *bool, ...) error
• type ClientSet
  • func GetClientSet(dc *kubermaticv1.DatacenterSpecNutanix, cloud *kubermaticv1.NutanixCloudSpec, ...) (*ClientSet, error)
  • func GetClientSetWithCreds(endpoint string, port *int32, allowInsecure *bool, ...) (*ClientSet, error)
• type ErrorResponse
  • func ParseNutanixError(err error) (*ErrorResponse, error)
• type ErrorResponseMsg
• type Nutanix
  • func NewCloudProvider(dc *kubermaticv1.Datacenter, ...) (*Nutanix, error)
  • func (n *Nutanix) CleanUpCloudProvider(ctx context.Context, cluster *kubermaticv1.Cluster, ...) (*kubermaticv1.Cluster, error)
  • func (n *Nutanix) DefaultCloudSpec(_ context.Context, spec *kubermaticv1.CloudSpec) error
  • func (n *Nutanix) InitializeCloudProvider(ctx context.Context, cluster *kubermaticv1.Cluster, ...) (*kubermaticv1.Cluster, error)
  • func (n *Nutanix) ReconcileCluster(ctx context.Context, cluster *kubermaticv1.Cluster, ...) (*kubermaticv1.Cluster, error)
  • func (n *Nutanix) ValidateCloudSpec(ctx context.Context, spec kubermaticv1.CloudSpec) error
  • func (n *Nutanix) ValidateCloudSpecUpdate(_ context.Context, oldSpec kubermaticv1.CloudSpec, ...) error

Constants

const (
	ClusterCategoryName = "KKPCluster"
	ProjectCategoryName = "KKPProject"

	DefaultProject = "default"
)

Functions

func CategoryValue

func CategoryValue(clusterName string) string

func GetCategories

func GetCategories(ctx context.Context, client *ClientSet) ([]nutanixv3.CategoryKeyStatus, error)

func GetCategoryValues

func GetCategoryValues(ctx context.Context, client *ClientSet, category string) ([]nutanixv3.CategoryValueStatus, error)

func GetClusterByName

func GetClusterByName(ctx context.Context, client *ClientSet, name string) (*nutanixv3.ClusterIntentResponse, error)

func GetClusters

func GetClusters(ctx context.Context, client *ClientSet) ([]nutanixv3.ClusterIntentResponse, error)

func GetProjectByName

func GetProjectByName(ctx context.Context, client *ClientSet, name string) (*nutanixv3.Project, error)

func GetProjects

func GetProjects(ctx context.Context, client *ClientSet) ([]nutanixv3.Project, error)

func GetSubnetByName

func GetSubnetByName(ctx context.Context, client *ClientSet, name, clusterID string) (*nutanixv3.SubnetIntentResponse, error)

func GetSubnets

func GetSubnets(ctx context.Context, client *ClientSet, clusterName, projectName string) ([]nutanixv3.SubnetIntentResponse, error)

func ValidateCredentials

func ValidateCredentials(ctx context.Context, endpoint string, port *int32, allowInsecure *bool, proxyURL, username, password string) error

Types

type ClientSet

type ClientSet struct {
	Prism *nutanixv3.Client
}

func GetClientSet

func GetClientSet(dc *kubermaticv1.DatacenterSpecNutanix, cloud *kubermaticv1.NutanixCloudSpec, secretKeyGetter provider.SecretKeySelectorValueFunc) (*ClientSet, error)

func GetClientSetWithCreds

func GetClientSetWithCreds(endpoint string, port *int32, allowInsecure *bool, proxyURL, username, password string) (*ClientSet, error)

type ErrorResponse

type ErrorResponse struct {
	APIVersion  string             `json:"api_version"`
	Kind        string             `json:"kind"`
	State       string             `json:"state"`
	MessageList []ErrorResponseMsg `json:"message_list"`
	Code        int32              `json:"code"`
}

func ParseNutanixError

func ParseNutanixError(err error) (*ErrorResponse, error)

type ErrorResponseMsg

type ErrorResponseMsg struct {
	Message string `json:"message"`
	Reason  string `json:"reason"`
}

type Nutanix

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

func NewCloudProvider

func NewCloudProvider(dc *kubermaticv1.Datacenter, secretKeyGetter provider.SecretKeySelectorValueFunc) (*Nutanix, error)

func (*Nutanix) CleanUpCloudProvider

func (n *Nutanix) CleanUpCloudProvider(ctx context.Context, cluster *kubermaticv1.Cluster, update provider.ClusterUpdater) (*kubermaticv1.Cluster, error)

func (*Nutanix) DefaultCloudSpec

func (n *Nutanix) DefaultCloudSpec(_ context.Context, spec *kubermaticv1.CloudSpec) error

func (*Nutanix) InitializeCloudProvider

func (n *Nutanix) InitializeCloudProvider(ctx context.Context, cluster *kubermaticv1.Cluster, update provider.ClusterUpdater) (*kubermaticv1.Cluster, error)

func (*Nutanix) ReconcileCluster

func (n *Nutanix) ReconcileCluster(ctx context.Context, cluster *kubermaticv1.Cluster, update provider.ClusterUpdater) (*kubermaticv1.Cluster, error)

func (*Nutanix) ValidateCloudSpec

func (n *Nutanix) ValidateCloudSpec(ctx context.Context, spec kubermaticv1.CloudSpec) error

func (*Nutanix) ValidateCloudSpecUpdate

func (n *Nutanix) ValidateCloudSpecUpdate(_ context.Context, oldSpec kubermaticv1.CloudSpec, newSpec kubermaticv1.CloudSpec) error