k8sorchestrator

Documentation

Index

• type FSSConfigMapInfo
• type K8sGuestInitParams
• type K8sOrchestrator
  • func Newk8sOrchestrator(ctx context.Context, controllerClusterFlavor cnstypes.CnsClusterFlavor, ...) (*K8sOrchestrator, error)
  • func (c *K8sOrchestrator) ClearFakeAttached(ctx context.Context, volumeID string) error
  • func (c *K8sOrchestrator) InitTopologyServiceInController(ctx context.Context) (commoncotypes.ControllerTopologyService, error)
  • func (c *K8sOrchestrator) InitTopologyServiceInNode(ctx context.Context) (commoncotypes.NodeTopologyService, error)
  • func (c *K8sOrchestrator) IsFSSEnabled(ctx context.Context, featureName string) bool
  • func (c *K8sOrchestrator) IsFakeAttachAllowed(ctx context.Context, volumeID string, volumeManager cnsvolume.Manager) (bool, error)
  • func (c *K8sOrchestrator) MarkFakeAttached(ctx context.Context, volumeID string) error
• type K8sSupervisorInitParams
• type K8sVanillaInitParams

Types

type FSSConfigMapInfo

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

FSSConfigMapInfo contains details about the FSS configmap(s) present in all flavors.

type K8sGuestInitParams

type K8sGuestInitParams struct {
	InternalFeatureStatesConfigInfo   cnsconfig.FeatureStatesConfigInfo
	SupervisorFeatureStatesConfigInfo cnsconfig.FeatureStatesConfigInfo
	ServiceMode                       string
}

K8sGuestInitParams lists the set of parameters required to run the init for K8sOrchestrator in Guest cluster.

type K8sOrchestrator

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

K8sOrchestrator defines set of properties specific to K8s.

func Newk8sOrchestrator

func Newk8sOrchestrator(ctx context.Context, controllerClusterFlavor cnstypes.CnsClusterFlavor,
	params interface{}) (*K8sOrchestrator, error)

Newk8sOrchestrator instantiates K8sOrchestrator object and returns this object. NOTE: As Newk8sOrchestrator is created in the init of the driver and syncer components, raise an error only if it is of utmost importance.

func (*K8sOrchestrator) ClearFakeAttached

func (c *K8sOrchestrator) ClearFakeAttached(ctx context.Context, volumeID string) error

ClearFakeAttached checks if pvc corresponding to the volume has fake annotations, and unmark it as not fake attached.

func (*K8sOrchestrator) InitTopologyServiceInController

func (c *K8sOrchestrator) InitTopologyServiceInController(ctx context.Context) (
	commoncotypes.ControllerTopologyService, error)

InitTopologyServiceInController returns a singleton implementation of the commoncotypes.ControllerTopologyService interface.

func (*K8sOrchestrator) InitTopologyServiceInNode

func (c *K8sOrchestrator) InitTopologyServiceInNode(ctx context.Context) (
	commoncotypes.NodeTopologyService, error)

InitTopologyServiceInNode returns a singleton implementation of the commoncotypes.NodeTopologyService interface.

func (*K8sOrchestrator) IsFSSEnabled

func (c *K8sOrchestrator) IsFSSEnabled(ctx context.Context, featureName string) bool

IsFSSEnabled utilises the cluster flavor to check their corresponding FSS maps and returns if the feature state switch is enabled for the given feature indicated by featureName.

func (*K8sOrchestrator) IsFakeAttachAllowed

func (c *K8sOrchestrator) IsFakeAttachAllowed(ctx context.Context, volumeID string,
	volumeManager cnsvolume.Manager) (bool, error)

IsFakeAttachAllowed checks if the volume is eligible to be fake attached and returns a bool value.

func (*K8sOrchestrator) MarkFakeAttached

func (c *K8sOrchestrator) MarkFakeAttached(ctx context.Context, volumeID string) error

MarkFakeAttached updates the pvc corresponding to volume to have a fake attach annotation.

type K8sSupervisorInitParams

type K8sSupervisorInitParams struct {
	SupervisorFeatureStatesConfigInfo cnsconfig.FeatureStatesConfigInfo
	ServiceMode                       string
}

K8sSupervisorInitParams lists the set of parameters required to run the init for K8sOrchestrator in Supervisor cluster.

type K8sVanillaInitParams

type K8sVanillaInitParams struct {
	InternalFeatureStatesConfigInfo cnsconfig.FeatureStatesConfigInfo
	ServiceMode                     string
}

K8sVanillaInitParams lists the set of parameters required to run the init for K8sOrchestrator in Vanilla cluster.