engine

Documentation

Index

• Constants
• Variables
• func GetDataSync(kmClient client.Client, name, namespace string) (*v1alpha1.DataSync, error)
• func GetRemoteDataSync(me *MoveEngineAction) (*v1alpha1.DataSync, error)
• func NewMultiAPIResources() map[string]*MultiResource
• func ValidateEngine(mov *v1alpha1.MoveEngine) error
• type MResources
• type MoveEngineAction
  • func NewMoveEngineAction(log logr.Logger, c client.Client, h helper.Helper, me *v1alpha1.MoveEngine) (*MoveEngineAction, error)
  • func (m *MoveEngineAction) CreateDataSync() (string, error)
  • func (m *MoveEngineAction) CreateDataSyncAtRemote(dsName string) error
  • func (m *MoveEngineAction) CreateResourceAtRemote(gvr schema.GroupVersionResource) error
  • func (m *MoveEngineAction) CreateStandbyMoveEngine() error
  • func (m *MoveEngineAction) GetStandbyMoveEngineStatus() (v1alpha1.MoveEngineStatus, error)
  • func (m *MoveEngineAction) ListResourcesFromAPI(api metav1.APIResource) (*unstructured.UnstructuredList, error)
  • func (m *MoveEngineAction) ParseResourceEngine(mov *v1alpha1.MoveEngine) error
  • func (m *MoveEngineAction) SetMoveEngineState(state v1alpha1.MoveEngineState) error
  • func (m *MoveEngineAction) ShouldRestore(obj unstructured.Unstructured) bool
  • func (m *MoveEngineAction) ShouldRestoreRS(name, ns string) bool
  • func (m *MoveEngineAction) SyncDataSyncStatus() (bool, error)
  • func (m *MoveEngineAction) UpdateMoveEngineStatus(newStatus *v1alpha1.MoveEngineStatus) error
  • func (m *MoveEngineAction) UpdateStandbyMoveEngineStatus(newStatus *v1alpha1.MoveEngineStatus) error
  • func (m *MoveEngineAction) UpdateSyncResourceList() error
• type MultiResource
• type NamedObj

Constants

const (
	MoveEngineActive  = "active"
	MoveEngineStandby = "standby"
)

const (
	ResourcePhaseSynced string = "Synced"
)

TODO new package for status

Variables

var PVCWaitInterval = 1 * time.Second

var PVCWaitTime = 5 * time.Second

TODO

Functions

func GetDataSync

func GetDataSync(kmClient client.Client, name, namespace string) (*v1alpha1.DataSync, error)

func GetRemoteDataSync

func GetRemoteDataSync(me *MoveEngineAction) (*v1alpha1.DataSync, error)

func NewMultiAPIResources

func NewMultiAPIResources() map[string]*MultiResource

If any API resource have multiple APIVersion then add it here

func ValidateEngine

func ValidateEngine(mov *v1alpha1.MoveEngine) error

Types

type MResources

type MResources struct {
	Name       string
	Kind       string
	APIVersion string
}

type MoveEngineAction

type MoveEngineAction struct {
	MEngine v1alpha1.MoveEngine
	// contains filtered or unexported fields
}

func NewMoveEngineAction

func NewMoveEngineAction(log logr.Logger, c client.Client, h helper.Helper, me *v1alpha1.MoveEngine) (*MoveEngineAction, error)

func (*MoveEngineAction) CreateDataSync

func (m *MoveEngineAction) CreateDataSync() (string, error)

func (*MoveEngineAction) CreateDataSyncAtRemote

func (m *MoveEngineAction) CreateDataSyncAtRemote(dsName string) error

func (*MoveEngineAction) CreateResourceAtRemote

func (m *MoveEngineAction) CreateResourceAtRemote(gvr schema.GroupVersionResource) error

func (*MoveEngineAction) CreateStandbyMoveEngine

func (m *MoveEngineAction) CreateStandbyMoveEngine() error

CreateStandbyMoveEngine creates MoveEngine in the destination cluster with standby mode.

func (*MoveEngineAction) GetStandbyMoveEngineStatus

func (m *MoveEngineAction) GetStandbyMoveEngineStatus() (v1alpha1.MoveEngineStatus, error)

GetStandbyMoveEngineStatus returns the status of standby MoveEngine from remote cluster

func (*MoveEngineAction) ListResourcesFromAPI

func (m *MoveEngineAction) ListResourcesFromAPI(api metav1.APIResource) (*unstructured.UnstructuredList, error)

func (*MoveEngineAction) ParseResourceEngine

func (m *MoveEngineAction) ParseResourceEngine(mov *v1alpha1.MoveEngine) error

func (*MoveEngineAction) SetMoveEngineState

func (m *MoveEngineAction) SetMoveEngineState(state v1alpha1.MoveEngineState) error

SetMoveEngineState set status of the respective MoveEngine CR

func (*MoveEngineAction) ShouldRestore

func (m *MoveEngineAction) ShouldRestore(obj unstructured.Unstructured) bool

func (*MoveEngineAction) ShouldRestoreRS

func (m *MoveEngineAction) ShouldRestoreRS(name, ns string) bool

func (*MoveEngineAction) SyncDataSyncStatus

func (m *MoveEngineAction) SyncDataSyncStatus() (bool, error)

func (*MoveEngineAction) UpdateMoveEngineStatus

func (m *MoveEngineAction) UpdateMoveEngineStatus(newStatus *v1alpha1.MoveEngineStatus) error

func (*MoveEngineAction) UpdateStandbyMoveEngineStatus

func (m *MoveEngineAction) UpdateStandbyMoveEngineStatus(newStatus *v1alpha1.MoveEngineStatus) error

func (*MoveEngineAction) UpdateSyncResourceList

func (m *MoveEngineAction) UpdateSyncResourceList() error

type MultiResource

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

type NamedObj

type NamedObj map[string]unstructured.Unstructured