commonco

Documentation

Index

• func SetInitParams(ctx context.Context, clusterFlavor cnstypes.CnsClusterFlavor, ...)
• type COCommonInterface
  • func GetContainerOrchestratorInterface(ctx context.Context, orchestratorType int, ...) (COCommonInterface, error)

Functions

func SetInitParams

func SetInitParams(ctx context.Context, clusterFlavor cnstypes.CnsClusterFlavor, initParams *interface{},
	supervisorFSSName, supervisorFSSNamespace, internalFSSName, internalFSSNamespace, serviceMode string)

SetInitParams initializes the parameters required to create a container agnostic orchestrator instance.

Types

type COCommonInterface

type COCommonInterface interface {
	// Check if feature state switch is enabled for the given feature indicated
	// by featureName.
	IsFSSEnabled(ctx context.Context, featureName string) bool
	// Check if the passed volume can be fake attached.
	IsFakeAttachAllowed(ctx context.Context, volumeID string, volumeManager cnsvolume.Manager) (bool, error)
	// Mark the volume as fake attached.
	MarkFakeAttached(ctx context.Context, volumeID string) error
	// Check if the volume was fake attached, and unmark it as not fake attached.
	ClearFakeAttached(ctx context.Context, volumeID string) error
	// InitTopologyServiceInController initializes the necessary resources
	// required for topology related functionality in the controller.
	InitTopologyServiceInController(ctx context.Context) (types.ControllerTopologyService, error)
	// InitTopologyServiceInNode initializes the necessary resources
	// required for topology related functionality in the nodes.
	InitTopologyServiceInNode(ctx context.Context) (types.NodeTopologyService, error)
	// GetNodesForVolumes returns a map of volumeID to list of node names
	GetNodesForVolumes(ctx context.Context, volumeIds []string) map[string][]string
	// GetNodeIDtoNameMap returns a map of node ID  to node names
	GetNodeIDtoNameMap(ctx context.Context) map[string]string
	// GetFakeAttachedVolumes returns a map of volumeIDs to a bool, which is set
	// to true if volumeID key is fake attached else false
	GetFakeAttachedVolumes(ctx context.Context, volumeIDs []string) map[string]bool
	//GetVolumeAttachment is used to fetch the VA object from the cluster.
	GetVolumeAttachment(ctx context.Context, volumeId string, nodeName string) (*storagev1.VolumeAttachment, error)
	// GetAllVolumes returns list of volumes in a bound state
	GetAllVolumes() []string
	// GetAllK8sVolumes returns list of volumes in a bound state, in the K8s cluster
	GetAllK8sVolumes() []string
}

COCommonInterface provides functionality to define container orchestrator related implementation to read resources/objects.

var ContainerOrchestratorUtility COCommonInterface

ContainerOrchestratorUtility represents the singleton instance of container orchestrator interface.

func GetContainerOrchestratorInterface

func GetContainerOrchestratorInterface(ctx context.Context, orchestratorType int,
	clusterFlavor cnstypes.CnsClusterFlavor, params interface{}) (COCommonInterface, error)

GetContainerOrchestratorInterface returns orchestrator object for a given container orchestrator type.