csi_replicator

package

v1.0.0 Latest Latest Go to latest Published: Sep 17, 2021 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dell/csm-replication

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type ActionAnnotation
type ActionResult
type ActionType
- func (a ActionType) Equals(val string) bool
- func (a ActionType) String() string
type PersistentVolumeClaimReconciler
- func (r *PersistentVolumeClaimReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *PersistentVolumeClaimReconciler) SetupWithManager(mgr ctrl.Manager, limiter ratelimiter.RateLimiter, maxReconcilers int) error
type PersistentVolumeReconciler
- func (r *PersistentVolumeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *PersistentVolumeReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, limiter ratelimiter.RateLimiter, ...) error
type ReplicationGroupMonitoring
- func (r *ReplicationGroupMonitoring) Monitor(ctx context.Context) error
type ReplicationGroupReconciler
- func (r *ReplicationGroupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *ReplicationGroupReconciler) SetupWithManager(mgr ctrl.Manager, limiter ratelimiter.RateLimiter, maxReconcilers int) error

Constants ¶

View Source

const (
	ReadyState                 = "Ready"
	InvalidState               = "Invalid"
	ErrorState                 = "Error"
	NoState                    = ""
	InProgress                 = "IN_PROGRESS"
	DeletingState              = "Deleting"
	Action                     = "Action"
	MaxRetryDurationForActions = 1 * time.Hour
	MaxNumberOfConditions      = 20
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ActionAnnotation ¶

type ActionAnnotation struct {
	ActionName            string `json:"name"`
	Completed             bool   `json:"completed"`
	FinalError            string `json:"finalError"`
	FinishTime            string `json:"finishTime"`
	ProtectionGroupStatus string `json:"protectionGroupStatus"`
}

type ActionResult ¶

type ActionResult struct {
	ActionType   ActionType
	Time         time.Time
	Error        error
	IsFinalError bool
	PGStatus     *csiext.StorageProtectionGroupStatus
}

type ActionType ¶

type ActionType string

func (ActionType) Equals ¶

func (a ActionType) Equals(val string) bool

func (ActionType) String ¶

func (a ActionType) String() string

type PersistentVolumeClaimReconciler ¶

type PersistentVolumeClaimReconciler struct {
	client.Client
	Log               logr.Logger
	Scheme            *runtime.Scheme
	EventRecorder     record.EventRecorder
	DriverName        string
	ReplicationClient csireplication.Replication
	ContextPrefix     string
	SingleFlightGroup singleflight.Group
	Domain            string
}

PersistentVolumeClaimReconciler reconciles a PersistentVolumeClaim object

func (*PersistentVolumeClaimReconciler) Reconcile ¶

func (r *PersistentVolumeClaimReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PersistentVolumeClaimReconciler) SetupWithManager ¶

func (r *PersistentVolumeClaimReconciler) SetupWithManager(mgr ctrl.Manager, limiter ratelimiter.RateLimiter, maxReconcilers int) error

type PersistentVolumeReconciler ¶

type PersistentVolumeReconciler struct {
	client.Client
	Log               logr.Logger
	Scheme            *runtime.Scheme
	EventRecorder     record.EventRecorder
	DriverName        string
	ReplicationClient csireplication.Replication
	ContextPrefix     string
	SingleFlightGroup singleflight.Group
	Domain            string
}

func (*PersistentVolumeReconciler) Reconcile ¶

func (r *PersistentVolumeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PersistentVolumeReconciler) SetupWithManager ¶

func (r *PersistentVolumeReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, limiter ratelimiter.RateLimiter, maxReconcilers int) error

type ReplicationGroupMonitoring ¶

type ReplicationGroupMonitoring struct {
	client.Client
	EventRecorder      record.EventRecorder
	Log                logr.Logger
	DriverName         string
	ReplicationClient  csireplication.Replication
	MonitoringInterval time.Duration
}

func (*ReplicationGroupMonitoring) Monitor ¶

func (r *ReplicationGroupMonitoring) Monitor(ctx context.Context) error

Monitor polls RGs over a defined interval and updates the ReplicationLinkStatus depending on the response received from the driver.

type ReplicationGroupReconciler ¶

type ReplicationGroupReconciler struct {
	client.Client
	Log                        logr.Logger
	Scheme                     *runtime.Scheme
	EventRecorder              record.EventRecorder
	DriverName                 string
	ReplicationClient          csireplication.Replication
	SupportedActions           []*csiext.SupportedActions
	MaxRetryDurationForActions time.Duration
}

func (*ReplicationGroupReconciler) Reconcile ¶

func (r *ReplicationGroupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ReplicationGroupReconciler) SetupWithManager ¶

func (r *ReplicationGroupReconciler) SetupWithManager(mgr ctrl.Manager, limiter ratelimiter.RateLimiter, maxReconcilers int) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL