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 (*Nutanix) ClusterNeedsReconciling(cluster *kubermaticv1.Cluster) bool
  • func (n *Nutanix) DefaultCloudSpec(_ context.Context, spec *kubermaticv1.ClusterSpec) 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"`
}

ErrorResponse matches the struct in upstream, but is copied here because upstream has its version in an internal package. Can be removed if and when Nutanix SDK does not return stringified errors that we have to parse ourselves.

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

func (*Nutanix) ClusterNeedsReconciling(cluster *kubermaticv1.Cluster) bool

func (*Nutanix) DefaultCloudSpec

func (n *Nutanix) DefaultCloudSpec(_ context.Context, spec *kubermaticv1.ClusterSpec) 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