job

package

Go to main page

Versions in this module

v0

v0.9.7

Feb 27, 2025

v0.9.6

Feb 7, 2025

v0.9.5

Jan 27, 2025

v0.9.4

Jan 8, 2025

v0.9.3

Dec 12, 2024

Changes in this version

type ActiveSide

+ func (j *ActiveSide) Cron() string

type ActiveSideState

+ const ActiveSideSnapshot

type Job

+ Cron func() string

type PassiveSide

+ func (j *PassiveSide) Cron() string

+ type SenderOnce struct

+ func NewSenderOnce(ctx context.Context, endpoint logic.Sender) *SenderOnce

+ func (self *SenderOnce) ListFilesystems(context.Context) (*pdu.ListFilesystemRes, error)

type SnapJob

+ func (j *SnapJob) Cron() string

type Status

+ Err string

+ NextCron time.Time

v0.9.2

Nov 21, 2024

Changes in this version

+ type LocalSender struct

+ func NewLocalSender(ctx context.Context, target pruner.Target) *LocalSender

+ func (self *LocalSender) ListFilesystems(ctx context.Context) (*pdu.ListFilesystemRes, error)

+ func (self *LocalSender) ReplicationCursor(ctx context.Context, req *pdu.ReplicationCursorReq) (*pdu.ReplicationCursorRes, error)

v0.9.1

Nov 14, 2024

v0.9.0

Nov 8, 2024

Changes in this version

+ const EpDestroySnapshots

+ const EpListFilesystemVersions

+ const EpListFilesystems

+ const EpReceive

+ const EpReplicationCursor

+ const EpSend

+ const EpSendCompleted

+ const EpSendDry

+ const EpWaitForConnectivity

+ func EndpointNames(jobName string) []string

type ActiveSide

+ func (j *ActiveSide) Runnable() bool

+ type Client struct

+ func NewClient(jobName string, client *jsonclient.Client) *Client

+ func (self *Client) DestroySnapshots(ctx context.Context, req *pdu.DestroySnapshotsReq) (*pdu.DestroySnapshotsRes, error)

+ func (self *Client) ListFilesystemVersions(ctx context.Context, req *pdu.ListFilesystemVersionsReq) (*pdu.ListFilesystemVersionsRes, error)

+ func (self *Client) ListFilesystems(ctx context.Context) (*pdu.ListFilesystemRes, error)

+ func (self *Client) Receive(ctx context.Context, req *pdu.ReceiveReq, receive io.ReadCloser) error

+ func (self *Client) ReplicationCursor(ctx context.Context, req *pdu.ReplicationCursorReq) (*pdu.ReplicationCursorRes, error)

+ func (self *Client) Send(ctx context.Context, req *pdu.SendReq) (*pdu.SendRes, io.ReadCloser, error)

+ func (self *Client) SendCompleted(ctx context.Context, req *pdu.SendCompletedReq) error

+ func (self *Client) SendDry(ctx context.Context, req *pdu.SendReq) (*pdu.SendRes, error)

+ func (self *Client) WaitForConnectivity(ctx context.Context) error

+ func (self *Client) WithTimeout(d time.Duration) *Client

+ type Connected interface

+ Endpoint func() Endpoint

+ Name func() string

+ type Connecter struct

+ func NewConnecter(keys []config.AuthKey) *Connecter

+ func (self *Connecter) AddJob(listnerName string, j *PassiveSide)

+ func (self *Connecter) FromConfig(in *config.Connect) (Connected, error)

+ func (self *Connecter) Job(name string) *PassiveSide

+ func (self *Connecter) Validate() error

+ func (self *Connecter) WithTimeout(d time.Duration) *Connecter

+ type Endpoint interface

type Job

+ Runnable func() bool

type PassiveSide

+ func (j *PassiveSide) Endpoint(clientIdentity string) Endpoint

+ func (j *PassiveSide) KnownClient(clientIdentity string) bool

+ func (j *PassiveSide) Runnable() bool

type SnapJob

+ func (j *SnapJob) Runnable() bool

v0.8.10

Oct 27, 2024

Changes in this version

type ActiveSideStatus

+ Err string

+ type Hook struct

+ func NewHookFromConfig(in *config.HookCommand) *Hook

+ func (self *Hook) ErrIsFatal() bool

+ func (self *Hook) Run(ctx context.Context, j Job) error

+ func (self *Hook) WithPostHook(v bool) *Hook

v0.8.9

Oct 20, 2024

v0.8.8

Oct 18, 2024

Changes in this version

+ func FakeActiveSideDirectMethodInvocationClientIdentity(jobId endpoint.JobID) string

+ type ActiveSide struct

+ func (j *ActiveSide) Name() string

+ func (j *ActiveSide) OwnedDatasetSubtreeRoot() (rfs *zfs.DatasetPath, ok bool)

+ func (j *ActiveSide) RegisterMetrics(registerer prometheus.Registerer)

+ func (j *ActiveSide) Run(ctx context.Context, cron *cron.Cron) error

+ func (j *ActiveSide) Running() (d time.Duration, ok bool)

+ func (j *ActiveSide) SenderConfig() *endpoint.SenderConfig

+ func (j *ActiveSide) Shutdown()

+ func (j *ActiveSide) Status() *Status

+ type ActiveSideState int

+ const ActiveSideDone

+ const ActiveSidePruneReceiver

+ const ActiveSidePruneSender

+ const ActiveSideReplicating

+ func ActiveSideStateString(s string) (ActiveSideState, error)

+ func ActiveSideStateValues() []ActiveSideState

+ func (i ActiveSideState) IsAActiveSideState() bool

+ func (i ActiveSideState) String() string

+ type ActiveSideStatus struct

+ CronSpec string

+ PruningReceiver *pruner.Report

+ PruningSender *pruner.Report

+ Replication *report.Report

+ SleepUntil time.Time

+ Snapshotting *snapper.Report

+ StartedAt time.Time

+ func (self *ActiveSideStatus) Cron() string

+ func (self *ActiveSideStatus) Error() string

+ func (self *ActiveSideStatus) Progress() (expected, completed uint64)

+ func (self *ActiveSideStatus) Running() (d time.Duration, ok bool)

+ func (self *ActiveSideStatus) SleepingUntil() time.Time

+ func (self *ActiveSideStatus) Steps() (expected, step int)

+ type Internal interface

+ RegisterMetrics func(registerer prometheus.Registerer)

+ Run func(ctx context.Context, cron *cron.Cron) error

+ Shutdown func()

+ type Job interface

+ Name func() string

+ OwnedDatasetSubtreeRoot func() (rfs *zfs.DatasetPath, ok bool)

+ SenderConfig func() *endpoint.SenderConfig

+ Status func() *Status

+ func JobsFromConfig(c *config.Config, parseFlags config.ParseFlags) ([]Job, error)

+ type JobStatus interface

+ Cron func() string

+ Error func() string

+ Progress func() (expected, completed uint64)

+ Running func() (time.Duration, bool)

+ SleepingUntil func() time.Time

+ Steps func() (expected, step int)

+ type Logger = logger.Logger

+ func GetLogger(ctx context.Context) Logger

+ type PassiveSide struct

+ func (*PassiveSide) RegisterMetrics(registerer prometheus.Registerer)

+ func (j *PassiveSide) Name() string

+ func (j *PassiveSide) OwnedDatasetSubtreeRoot() (rfs *zfs.DatasetPath, ok bool)

+ func (j *PassiveSide) Run(ctx context.Context, cron *cron.Cron) error

+ func (j *PassiveSide) SenderConfig() *endpoint.SenderConfig

+ func (j *PassiveSide) Shutdown()

+ func (s *PassiveSide) Status() *Status

+ type PassiveStatus struct

+ Snapper *snapper.Report

+ func (self *PassiveStatus) Cron() string

+ func (self *PassiveStatus) Error() string

+ func (self *PassiveStatus) Progress() (uint64, uint64)

+ func (self *PassiveStatus) Running() (time.Duration, bool)

+ func (self *PassiveStatus) SleepingUntil() time.Time

+ func (self *PassiveStatus) Steps() (expected, step int)

+ type ReceivingJobConfig interface

+ GetAppendClientIdentity func() bool

+ GetRecvOptions func() *config.RecvOptions

+ GetRootFS func() string

+ type SendingJobConfig interface

+ GetFilesystems func() config.FilesystemsFilter

+ GetSendOptions func() *config.SendOptions

+ type SnapJob struct

+ func (j *SnapJob) Name() string

+ func (j *SnapJob) OwnedDatasetSubtreeRoot() (rfs *zfs.DatasetPath, ok bool)

+ func (j *SnapJob) RegisterMetrics(registerer prometheus.Registerer)

+ func (j *SnapJob) Run(ctx context.Context, cron *cron.Cron) error

+ func (j *SnapJob) SenderConfig() *endpoint.SenderConfig

+ func (j *SnapJob) Shutdown()

+ func (j *SnapJob) Status() *Status

+ func (j *SnapJob) Type() Type

+ type SnapJobStatus struct

+ Pruning *pruner.Report

+ Snapshotting *snapper.Report

+ func (self *SnapJobStatus) Cron() string

+ func (self *SnapJobStatus) Error() string

+ func (self *SnapJobStatus) Progress() (uint64, uint64)

+ func (self *SnapJobStatus) Running() (d time.Duration, ok bool)

+ func (self *SnapJobStatus) SleepingUntil() time.Time

+ func (self *SnapJobStatus) Steps() (expected, step int)

+ type Status struct

+ JobSpecific JobStatus

+ Type Type

+ func (s *Status) CanSignal() string

+ func (s *Status) Cron() string

+ func (s *Status) Error() string

+ func (s *Status) Internal() bool

+ func (s *Status) MarshalJSON() ([]byte, error)

+ func (s *Status) Progress() (uint64, uint64)

+ func (s *Status) Running() (time.Duration, bool)

+ func (s *Status) SleepingUntil() time.Time

+ func (s *Status) Steps() (expected, step int)

+ func (s *Status) UnmarshalJSON(in []byte) (err error)

+ type Type string

+ const TypeInternal

+ const TypePull

+ const TypePush

+ const TypeSink

+ const TypeSnap

+ const TypeSource

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