endpoint

package

Go to main page

Versions in this module

v0

v0.6.1

Sep 10, 2023

Changes in this version

type AbstractionType

+ func (t AbstractionType) IsSnapshotOrBookmark() bool

type AbstractionTypeSet

+ func (s AbstractionTypeSet) ExtractBookmark(dp *zfs.DatasetPath, v *zfs.FilesystemVersion) Abstraction

type FSFilter

+ UserSpecifiedDatasets func() zfs.UserSpecifiedDatasetsSet

type ReplicationGuaranteeIncremental

+ func (g ReplicationGuaranteeIncremental) String() string

type ReplicationGuaranteeNone

+ func (g ReplicationGuaranteeNone) String() string

type ReplicationGuaranteeResumability

+ func (g ReplicationGuaranteeResumability) String() string

v0.6.0

Oct 31, 2022

v0.5.0

Jan 9, 2022

Changes in this version

+ type PlaceholderCreationEncryptionProperty int

+ const PlaceholderCreationEncryptionPropertyInherit

+ const PlaceholderCreationEncryptionPropertyOff

+ const PlaceholderCreationEncryptionPropertyUnspecified

+ func PlaceholderCreationEncryptionPropertyString(s string) (PlaceholderCreationEncryptionProperty, error)

+ func PlaceholderCreationEncryptionPropertyValues() []PlaceholderCreationEncryptionProperty

+ func (i PlaceholderCreationEncryptionProperty) IsAPlaceholderCreationEncryptionProperty() bool

+ func (i PlaceholderCreationEncryptionProperty) String() string

type Receiver

+ Test_OverrideClientIdentityFunc func() string

+ func (s *Receiver) SendDry(ctx context.Context, r *pdu.SendReq) (*pdu.SendRes, error)

type ReceiverConfig

+ BandwidthLimit bandwidthlimit.Config

+ PlaceholderEncryption PlaceholderCreationEncryptionProperty

type Sender

+ func (s *Sender) SendDry(ctx context.Context, r *pdu.SendReq) (*pdu.SendRes, error)

type SenderConfig

+ BandwidthLimit bandwidthlimit.Config

v0.5.0-rc1

Dec 18, 2021

v0.4.0

Apr 17, 2021

Changes in this version

type ReceiverConfig

+ InheritProperties []zfsprop.Property

+ OverrideProperties map[zfsprop.Property]string

type SenderConfig

+ SendBackupProperties bool

+ SendCompressed bool

+ SendEmbeddedData bool

+ SendLargeBlocks bool

+ SendProperties bool

+ SendRaw bool

+ SendSaved bool

v0.4.0-rc2

Mar 25, 2021

v0.4.0-rc1

Mar 14, 2021

v0.3.1

Nov 1, 2020

v0.3.0

Aug 21, 2020

Changes in this version

+ const LastReceivedHoldTagNamePrefix

+ var AbstractionTypesAll = map[AbstractionType]bool

+ var ErrV1ReplicationCursor = fmt.Errorf("bookmark name is a v1-replication cursor")

+ func AbstractionEquals(a, b Abstraction) bool

+ func AbstractionsCacheInvalidate(fs string)

+ func BatchDestroy(ctx context.Context, abs []Abstraction) <-chan BatchDestroyResult

+ func GetMostRecentReplicationCursorOfJob(ctx context.Context, fs string, jobID JobID) (*zfs.FilesystemVersion, error)

+ func GetReplicationCursors(ctx context.Context, dp *zfs.DatasetPath, jobID JobID) ([]zfs.FilesystemVersion, error)

+ func LastReceivedHoldTag(jobID JobID) (string, error)

+ func ListAbstractions(ctx context.Context, query ListZFSHoldsAndBookmarksQuery) (out []Abstraction, outErrs []ListAbstractionsError, err error)

+ func ListAbstractionsStreamed(ctx context.Context, query ListZFSHoldsAndBookmarksQuery) (<-chan Abstraction, <-chan ListAbstractionsError, error)

+ func RegisterMetrics(r prometheus.Registerer)

+ func ReplicationCursorBookmarkName(fs string, guid uint64, id JobID) (string, error)

+ func StepHoldTag(jobid JobID) (string, error)

+ func TentativeReplicationCursorBookmarkName(fs string, guid uint64, id JobID) (string, error)

+ type Abstraction interface

+ Destroy func(context.Context) error

+ GetCreateTXG func() uint64

+ GetFS func() string

+ GetFilesystemVersion func() zfs.FilesystemVersion

+ GetFullPath func() string

+ GetJobID func() *JobID

+ GetName func() string

+ GetType func() AbstractionType

+ String func() string

+ func CreateLastReceivedHold(ctx context.Context, fs string, to zfs.FilesystemVersion, jobID JobID) (Abstraction, error)

+ func CreateReplicationCursor(ctx context.Context, fs string, target zfs.FilesystemVersion, jobID JobID) (a Abstraction, err error)

+ func CreateTentativeReplicationCursor(ctx context.Context, fs string, target zfs.FilesystemVersion, jobID JobID) (a Abstraction, err error)

+ func HoldStep(ctx context.Context, fs string, v zfs.FilesystemVersion, jobID JobID) (Abstraction, error)

+ func LastReceivedHoldExtractor(fs *zfs.DatasetPath, v zfs.FilesystemVersion, holdTag string) Abstraction

+ func ReplicationCursorV1Extractor(fs *zfs.DatasetPath, v zfs.FilesystemVersion) (_ Abstraction)

+ func ReplicationCursorV2Extractor(fs *zfs.DatasetPath, v zfs.FilesystemVersion) (_ Abstraction)

+ func StepHoldExtractor(fs *zfs.DatasetPath, v zfs.FilesystemVersion, holdTag string) Abstraction

+ func TentativeReplicationCursorExtractor(fs *zfs.DatasetPath, v zfs.FilesystemVersion) (_ Abstraction)

+ type AbstractionJSON struct

+ func (a AbstractionJSON) MarshalJSON() ([]byte, error)

+ type AbstractionType string

+ const AbstractionLastReceivedHold

+ const AbstractionReplicationCursorBookmarkV1

+ const AbstractionReplicationCursorBookmarkV2

+ const AbstractionStepHold

+ const AbstractionTentativeReplicationCursorBookmark

+ func (t AbstractionType) BookmarkExtractor() BookmarkExtractor

+ func (t AbstractionType) BookmarkNamer() func(fs string, guid uint64, jobId JobID) (string, error)

+ func (t AbstractionType) HoldExtractor() HoldExtractor

+ func (t AbstractionType) MustValidate() error

+ func (t AbstractionType) Validate() error

+ type AbstractionTypeSet map[AbstractionType]bool

+ func AbstractionTypeSetFromStrings(sts []string) (AbstractionTypeSet, error)

+ func (s AbstractionTypeSet) ContainsAll(q AbstractionTypeSet) bool

+ func (s AbstractionTypeSet) ContainsAnyOf(q AbstractionTypeSet) bool

+ func (s AbstractionTypeSet) String() string

+ func (s AbstractionTypeSet) Validate() error

+ type BatchDestroyResult struct

+ DestroyErr error

+ func (r BatchDestroyResult) MarshalJSON() ([]byte, error)

+ type BookmarkExtractor func(fs *zfs.DatasetPath, v zfs.FilesystemVersion) Abstraction

+ type CreateTXGRange struct

+ Since *CreateTXGRangeBound

+ Until *CreateTXGRangeBound

+ func (r *CreateTXGRange) Contains(qCreateTxg uint64) bool

+ func (r *CreateTXGRange) IsUnbounded() bool

+ func (r *CreateTXGRange) String() string

+ func (r *CreateTXGRange) Validate() error

+ type CreateTXGRangeBound struct

+ CreateTXG uint64

+ Inclusive *zfs.NilBool

+ func (i *CreateTXGRangeBound) Validate() error

+ type HoldExtractor = func(fs *zfs.DatasetPath, v zfs.FilesystemVersion, tag string) Abstraction

+ type JobID struct

+ func MakeJobID(s string) (JobID, error)

+ func MustMakeJobID(s string) JobID

+ func ParseLastReceivedHoldTag(tag string) (JobID, error)

+ func ParseReplicationCursorBookmarkName(fullname string) (uint64, JobID, error)

+ func ParseStepHoldTag(tag string) (JobID, error)

+ func ParseTentativeReplicationCursorBookmarkName(fullname string) (guid uint64, jobID JobID, err error)

+ func (j *JobID) UnmarshalJSON(b []byte) error

+ func (j JobID) MarshalJSON() ([]byte, error)

+ func (j JobID) MustValidate()

+ func (j JobID) String() string

+ type ListAbstractionsError struct

+ Err error

+ FS string

+ Snap string

+ What string

+ func (e ListAbstractionsError) Error() string

+ type ListAbstractionsErrors []ListAbstractionsError

+ func (e ListAbstractionsErrors) Error() string

+ type ListStaleQueryError struct

+ type ListZFSHoldsAndBookmarksQuery struct

+ Concurrency int64

+ CreateTXG CreateTXGRange

+ FS ListZFSHoldsAndBookmarksQueryFilesystemFilter

+ JobID *JobID

+ What AbstractionTypeSet

+ func (q *ListZFSHoldsAndBookmarksQuery) Validate() error

+ type ListZFSHoldsAndBookmarksQueryFilesystemFilter struct

+ FS *string

+ Filter zfs.DatasetFilter

+ func (f *ListZFSHoldsAndBookmarksQueryFilesystemFilter) Filesystems(ctx context.Context) ([]string, error)

+ func (f *ListZFSHoldsAndBookmarksQueryFilesystemFilter) Validate() error

type Receiver

+ func (p *Receiver) SendCompleted(ctx context.Context, _ *pdu.SendCompletedReq) (*pdu.SendCompletedRes, error)

+ type ReceiverConfig struct

+ AppendClientIdentity bool

+ JobID JobID

+ RootWithoutClientComponent *zfs.DatasetPath

+ func (c *ReceiverConfig) Validate() error

+ type ReplicationCursorV1 struct

+ FS string

+ Type AbstractionType

+ func (c ReplicationCursorV1) Destroy(ctx context.Context) error

+ func (c ReplicationCursorV1) GetFS() string

+ func (c ReplicationCursorV1) GetFilesystemVersion() zfs.FilesystemVersion

+ func (c ReplicationCursorV1) GetFullPath() string

+ func (c ReplicationCursorV1) GetJobID() *JobID

+ func (c ReplicationCursorV1) GetType() AbstractionType

+ func (c ReplicationCursorV1) MarshalJSON() ([]byte, error)

+ func (c ReplicationCursorV1) String() string

+ type ReplicationGuaranteeIncremental struct

+ func (g ReplicationGuaranteeIncremental) Kind() ReplicationGuaranteeKind

+ func (g ReplicationGuaranteeIncremental) ReceiverPostRecv(ctx context.Context, jid JobID, fs string, toRecvd zfs.FilesystemVersion) (keep []Abstraction, err error)

+ func (g ReplicationGuaranteeIncremental) SenderPostRecvConfirmed(ctx context.Context, jid JobID, fs string, to zfs.FilesystemVersion) (keep []Abstraction, err error)

+ func (g ReplicationGuaranteeIncremental) SenderPreSend(ctx context.Context, jid JobID, sendArgs *zfs.ZFSSendArgsValidated) (keep []Abstraction, err error)

+ type ReplicationGuaranteeKind int

+ const ReplicationGuaranteeKindIncremental

+ const ReplicationGuaranteeKindNone

+ const ReplicationGuaranteeKindResumability

+ func ReplicationGuaranteeKindString(s string) (ReplicationGuaranteeKind, error)

+ func ReplicationGuaranteeKindValues() []ReplicationGuaranteeKind

+ func (i *ReplicationGuaranteeKind) UnmarshalJSON(data []byte) error

+ func (i ReplicationGuaranteeKind) IsAReplicationGuaranteeKind() bool

+ func (i ReplicationGuaranteeKind) MarshalJSON() ([]byte, error)

+ func (i ReplicationGuaranteeKind) String() string

+ type ReplicationGuaranteeNone struct

+ func (g ReplicationGuaranteeNone) Kind() ReplicationGuaranteeKind

+ func (g ReplicationGuaranteeNone) ReceiverPostRecv(ctx context.Context, jid JobID, fs string, toRecvd zfs.FilesystemVersion) (keep []Abstraction, err error)

+ func (g ReplicationGuaranteeNone) SenderPostRecvConfirmed(ctx context.Context, jid JobID, fs string, to zfs.FilesystemVersion) (keep []Abstraction, err error)

+ func (g ReplicationGuaranteeNone) SenderPreSend(ctx context.Context, jid JobID, sendArgs *zfs.ZFSSendArgsValidated) (keep []Abstraction, err error)

+ type ReplicationGuaranteeOptions struct

+ Incremental ReplicationGuaranteeKind

+ Initial ReplicationGuaranteeKind

+ func (o ReplicationGuaranteeOptions) Strategy(incremental bool) ReplicationGuaranteeStrategy

+ type ReplicationGuaranteeResumability struct

+ func (g ReplicationGuaranteeResumability) Kind() ReplicationGuaranteeKind

+ func (g ReplicationGuaranteeResumability) ReceiverPostRecv(ctx context.Context, jid JobID, fs string, toRecvd zfs.FilesystemVersion) (keep []Abstraction, err error)

+ func (g ReplicationGuaranteeResumability) SenderPostRecvConfirmed(ctx context.Context, jid JobID, fs string, to zfs.FilesystemVersion) (keep []Abstraction, err error)

+ func (g ReplicationGuaranteeResumability) SenderPreSend(ctx context.Context, jid JobID, sendArgs *zfs.ZFSSendArgsValidated) (keep []Abstraction, err error)

+ type ReplicationGuaranteeStrategy interface

+ Kind func() ReplicationGuaranteeKind

+ ReceiverPostRecv func(ctx context.Context, jid JobID, fs string, toRecvd zfs.FilesystemVersion) (keep []Abstraction, err error)

+ SenderPostRecvConfirmed func(ctx context.Context, jid JobID, fs string, to zfs.FilesystemVersion) (keep []Abstraction, err error)

+ SenderPreSend func(ctx context.Context, jid JobID, sendArgs *zfs.ZFSSendArgsValidated) (keep []Abstraction, err error)

+ func ReplicationGuaranteeFromKind(k ReplicationGuaranteeKind) ReplicationGuaranteeStrategy

type Sender

+ func (p *Sender) SendCompleted(ctx context.Context, r *pdu.SendCompletedReq) (*pdu.SendCompletedRes, error)

+ type SenderConfig struct

+ Encrypt *zfs.NilBool

+ FSF zfs.DatasetFilter

+ JobID JobID

+ func (c *SenderConfig) Validate() error

+ type StalenessInfo struct

+ ConstructedWithQuery ListZFSHoldsAndBookmarksQuery

+ Live []Abstraction

+ Stale []Abstraction

+ func ListStale(ctx context.Context, q ListZFSHoldsAndBookmarksQuery) (*StalenessInfo, error)

v0.3.0-rc2

Jul 26, 2020

v0.3.0-rc1

Jun 14, 2020

v0.2.1

Nov 20, 2019

v0.2.0

Oct 10, 2019

v0.2.0-rc1

Sep 29, 2019

v0.1.1

Apr 6, 2019

v0.1.0

Mar 30, 2019

Changes in this version

+ const ClientIdentityKey

+ func TestClientIdentity(rootFS *zfs.DatasetPath, clientIdentity string) error

+ func WithLogger(ctx context.Context, log Logger) context.Context

+ type FSFilter interface

+ Filter func(path *zfs.DatasetPath) (pass bool, err error)

+ type FSMap interface

+ AsFilter func() FSFilter

+ Invert func() (FSMap, error)

+ Map func(path *zfs.DatasetPath) (*zfs.DatasetPath, error)

+ type Logger = logger.Logger

+ type Receiver struct

+ func NewReceiver(rootDataset *zfs.DatasetPath, appendClientIdentity bool) *Receiver

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

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

+ func (s *Receiver) ListFilesystems(ctx context.Context, req *pdu.ListFilesystemReq) (*pdu.ListFilesystemRes, error)

+ func (s *Receiver) Ping(ctx context.Context, req *pdu.PingReq) (*pdu.PingRes, error)

+ func (s *Receiver) PingDataconn(ctx context.Context, req *pdu.PingReq) (*pdu.PingRes, error)

+ func (s *Receiver) Receive(ctx context.Context, req *pdu.ReceiveReq, receive zfs.StreamCopier) (*pdu.ReceiveRes, error)

+ func (s *Receiver) ReplicationCursor(context.Context, *pdu.ReplicationCursorReq) (*pdu.ReplicationCursorRes, error)

+ func (s *Receiver) Send(ctx context.Context, req *pdu.SendReq) (*pdu.SendRes, zfs.StreamCopier, error)

+ func (s *Receiver) WaitForConnectivity(ctx context.Context) error

+ type Sender struct

+ FSFilter zfs.DatasetFilter

+ func NewSender(fsf zfs.DatasetFilter) *Sender

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

+ func (p *Sender) Ping(ctx context.Context, req *pdu.PingReq) (*pdu.PingRes, error)

+ func (p *Sender) PingDataconn(ctx context.Context, req *pdu.PingReq) (*pdu.PingRes, error)

+ func (p *Sender) Receive(ctx context.Context, r *pdu.ReceiveReq, receive zfs.StreamCopier) (*pdu.ReceiveRes, error)

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

+ func (p *Sender) WaitForConnectivity(ctx context.Context) error

+ func (s *Sender) ListFilesystemVersions(ctx context.Context, r *pdu.ListFilesystemVersionsReq) (*pdu.ListFilesystemVersionsRes, error)

+ func (s *Sender) ListFilesystems(ctx context.Context, r *pdu.ListFilesystemReq) (*pdu.ListFilesystemRes, error)

+ func (s *Sender) Send(ctx context.Context, r *pdu.SendReq) (*pdu.SendRes, zfs.StreamCopier, error)

v0.1.0-rc4

Mar 22, 2019

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