Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ActiveSide ¶
type ActiveSide struct {
// contains filtered or unexported fields
}
func (*ActiveSide) Name ¶
func (j *ActiveSide) Name() string
func (*ActiveSide) OwnedDatasetSubtreeRoot ¶
func (j *ActiveSide) OwnedDatasetSubtreeRoot() (rfs *zfs.DatasetPath, ok bool)
func (*ActiveSide) RegisterMetrics ¶
func (j *ActiveSide) RegisterMetrics(registerer prometheus.Registerer)
func (*ActiveSide) Run ¶
func (j *ActiveSide) Run(ctx context.Context)
func (*ActiveSide) Status ¶
func (j *ActiveSide) Status() *Status
type ActiveSideState ¶
type ActiveSideState int
const ( ActiveSideReplicating ActiveSideState = 1 << iota ActiveSidePruneSender ActiveSidePruneReceiver ActiveSideDone // also errors )
func ActiveSideStateString ¶
func ActiveSideStateString(s string) (ActiveSideState, error)
ActiveSideStateString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.
func ActiveSideStateValues ¶
func ActiveSideStateValues() []ActiveSideState
ActiveSideStateValues returns all values of the enum
func (ActiveSideState) IsAActiveSideState ¶
func (i ActiveSideState) IsAActiveSideState() bool
IsAActiveSideState returns "true" if the value is listed in the enum definition. "false" otherwise
func (ActiveSideState) String ¶
func (i ActiveSideState) String() string
type ActiveSideStatus ¶
type Job ¶
type Job interface {
Name() string
Run(ctx context.Context)
Status() *Status
RegisterMetrics(registerer prometheus.Registerer)
// Jobs that return a subtree of the dataset hierarchy
// must return the root of that subtree as rfs and ok = true
OwnedDatasetSubtreeRoot() (rfs *zfs.DatasetPath, ok bool)
}
type PassiveSide ¶
type PassiveSide struct {
// contains filtered or unexported fields
}
func (*PassiveSide) Name ¶
func (j *PassiveSide) Name() string
func (*PassiveSide) OwnedDatasetSubtreeRoot ¶
func (j *PassiveSide) OwnedDatasetSubtreeRoot() (rfs *zfs.DatasetPath, ok bool)
func (*PassiveSide) RegisterMetrics ¶
func (*PassiveSide) RegisterMetrics(registerer prometheus.Registerer)
func (*PassiveSide) Run ¶
func (j *PassiveSide) Run(ctx context.Context)
func (*PassiveSide) Status ¶
func (s *PassiveSide) Status() *Status
type PassiveStatus ¶
type PassiveStatus struct{}
type SnapJob ¶
type SnapJob struct {
// contains filtered or unexported fields
}
func (*SnapJob) OwnedDatasetSubtreeRoot ¶
func (j *SnapJob) OwnedDatasetSubtreeRoot() (rfs *zfs.DatasetPath, ok bool)
func (*SnapJob) RegisterMetrics ¶
func (j *SnapJob) RegisterMetrics(registerer prometheus.Registerer)
type SnapJobStatus ¶
type Status ¶
type Status struct {
Type Type
JobSpecific interface{}
}
func (*Status) MarshalJSON ¶
func (*Status) UnmarshalJSON ¶
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.