Documentation
¶
Index ¶
- Variables
- func FilesystemVersionCreation(t time.Time) string
- func RegisterReplicationServer(s *grpc.Server, srv ReplicationServer)
- type DestroySnapshotRes
- func (*DestroySnapshotRes) Descriptor() ([]byte, []int)
- func (m *DestroySnapshotRes) GetError() string
- func (m *DestroySnapshotRes) GetSnapshot() *FilesystemVersion
- func (*DestroySnapshotRes) ProtoMessage()
- func (m *DestroySnapshotRes) Reset()
- func (m *DestroySnapshotRes) String() string
- func (m *DestroySnapshotRes) XXX_DiscardUnknown()
- func (m *DestroySnapshotRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DestroySnapshotRes) XXX_Merge(src proto.Message)
- func (m *DestroySnapshotRes) XXX_Size() int
- func (m *DestroySnapshotRes) XXX_Unmarshal(b []byte) error
- type DestroySnapshotsReq
- func (*DestroySnapshotsReq) Descriptor() ([]byte, []int)
- func (m *DestroySnapshotsReq) GetFilesystem() string
- func (m *DestroySnapshotsReq) GetSnapshots() []*FilesystemVersion
- func (*DestroySnapshotsReq) ProtoMessage()
- func (m *DestroySnapshotsReq) Reset()
- func (m *DestroySnapshotsReq) String() string
- func (m *DestroySnapshotsReq) XXX_DiscardUnknown()
- func (m *DestroySnapshotsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DestroySnapshotsReq) XXX_Merge(src proto.Message)
- func (m *DestroySnapshotsReq) XXX_Size() int
- func (m *DestroySnapshotsReq) XXX_Unmarshal(b []byte) error
- type DestroySnapshotsRes
- func (*DestroySnapshotsRes) Descriptor() ([]byte, []int)
- func (m *DestroySnapshotsRes) GetResults() []*DestroySnapshotRes
- func (*DestroySnapshotsRes) ProtoMessage()
- func (m *DestroySnapshotsRes) Reset()
- func (m *DestroySnapshotsRes) String() string
- func (m *DestroySnapshotsRes) XXX_DiscardUnknown()
- func (m *DestroySnapshotsRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DestroySnapshotsRes) XXX_Merge(src proto.Message)
- func (m *DestroySnapshotsRes) XXX_Size() int
- func (m *DestroySnapshotsRes) XXX_Unmarshal(b []byte) error
- type Filesystem
- func (*Filesystem) Descriptor() ([]byte, []int)
- func (m *Filesystem) GetIsEncrypted() bool
- func (m *Filesystem) GetIsPlaceholder() bool
- func (m *Filesystem) GetPath() string
- func (m *Filesystem) GetResumeToken() string
- func (*Filesystem) ProtoMessage()
- func (m *Filesystem) Reset()
- func (m *Filesystem) String() string
- func (m *Filesystem) XXX_DiscardUnknown()
- func (m *Filesystem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Filesystem) XXX_Merge(src proto.Message)
- func (m *Filesystem) XXX_Size() int
- func (m *Filesystem) XXX_Unmarshal(b []byte) error
- type FilesystemVersion
- func (v *FilesystemVersion) CreationAsTime() (time.Time, error)
- func (*FilesystemVersion) Descriptor() ([]byte, []int)
- func (m *FilesystemVersion) GetCreateTXG() uint64
- func (m *FilesystemVersion) GetCreation() string
- func (m *FilesystemVersion) GetGuid() uint64
- func (m *FilesystemVersion) GetName() string
- func (v *FilesystemVersion) GetRelName() string
- func (m *FilesystemVersion) GetType() FilesystemVersion_VersionType
- func (*FilesystemVersion) ProtoMessage()
- func (v *FilesystemVersion) RelName() string
- func (m *FilesystemVersion) Reset()
- func (v *FilesystemVersion) SnapshotTime() time.Time
- func (m *FilesystemVersion) String() string
- func (m *FilesystemVersion) XXX_DiscardUnknown()
- func (m *FilesystemVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *FilesystemVersion) XXX_Merge(src proto.Message)
- func (m *FilesystemVersion) XXX_Size() int
- func (m *FilesystemVersion) XXX_Unmarshal(b []byte) error
- func (v *FilesystemVersion) ZFSFilesystemVersion() (*zfs.FilesystemVersion, error)
- type FilesystemVersion_VersionType
- type ListFilesystemReq
- func (*ListFilesystemReq) Descriptor() ([]byte, []int)
- func (*ListFilesystemReq) ProtoMessage()
- func (m *ListFilesystemReq) Reset()
- func (m *ListFilesystemReq) String() string
- func (m *ListFilesystemReq) XXX_DiscardUnknown()
- func (m *ListFilesystemReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ListFilesystemReq) XXX_Merge(src proto.Message)
- func (m *ListFilesystemReq) XXX_Size() int
- func (m *ListFilesystemReq) XXX_Unmarshal(b []byte) error
- type ListFilesystemRes
- func (*ListFilesystemRes) Descriptor() ([]byte, []int)
- func (m *ListFilesystemRes) GetFilesystems() []*Filesystem
- func (*ListFilesystemRes) ProtoMessage()
- func (m *ListFilesystemRes) Reset()
- func (m *ListFilesystemRes) String() string
- func (m *ListFilesystemRes) XXX_DiscardUnknown()
- func (m *ListFilesystemRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ListFilesystemRes) XXX_Merge(src proto.Message)
- func (m *ListFilesystemRes) XXX_Size() int
- func (m *ListFilesystemRes) XXX_Unmarshal(b []byte) error
- type ListFilesystemVersionsReq
- func (*ListFilesystemVersionsReq) Descriptor() ([]byte, []int)
- func (m *ListFilesystemVersionsReq) GetFilesystem() string
- func (*ListFilesystemVersionsReq) ProtoMessage()
- func (m *ListFilesystemVersionsReq) Reset()
- func (m *ListFilesystemVersionsReq) String() string
- func (m *ListFilesystemVersionsReq) XXX_DiscardUnknown()
- func (m *ListFilesystemVersionsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ListFilesystemVersionsReq) XXX_Merge(src proto.Message)
- func (m *ListFilesystemVersionsReq) XXX_Size() int
- func (m *ListFilesystemVersionsReq) XXX_Unmarshal(b []byte) error
- type ListFilesystemVersionsRes
- func (*ListFilesystemVersionsRes) Descriptor() ([]byte, []int)
- func (m *ListFilesystemVersionsRes) GetVersions() []*FilesystemVersion
- func (*ListFilesystemVersionsRes) ProtoMessage()
- func (m *ListFilesystemVersionsRes) Reset()
- func (m *ListFilesystemVersionsRes) String() string
- func (m *ListFilesystemVersionsRes) XXX_DiscardUnknown()
- func (m *ListFilesystemVersionsRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ListFilesystemVersionsRes) XXX_Merge(src proto.Message)
- func (m *ListFilesystemVersionsRes) XXX_Size() int
- func (m *ListFilesystemVersionsRes) XXX_Unmarshal(b []byte) error
- type PingReq
- func (*PingReq) Descriptor() ([]byte, []int)
- func (m *PingReq) GetMessage() string
- func (*PingReq) ProtoMessage()
- func (m *PingReq) Reset()
- func (m *PingReq) String() string
- func (m *PingReq) XXX_DiscardUnknown()
- func (m *PingReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PingReq) XXX_Merge(src proto.Message)
- func (m *PingReq) XXX_Size() int
- func (m *PingReq) XXX_Unmarshal(b []byte) error
- type PingRes
- func (*PingRes) Descriptor() ([]byte, []int)
- func (m *PingRes) GetEcho() string
- func (*PingRes) ProtoMessage()
- func (m *PingRes) Reset()
- func (m *PingRes) String() string
- func (m *PingRes) XXX_DiscardUnknown()
- func (m *PingRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PingRes) XXX_Merge(src proto.Message)
- func (m *PingRes) XXX_Size() int
- func (m *PingRes) XXX_Unmarshal(b []byte) error
- type Property
- func (*Property) Descriptor() ([]byte, []int)
- func (m *Property) GetName() string
- func (m *Property) GetValue() string
- func (*Property) ProtoMessage()
- func (m *Property) Reset()
- func (m *Property) String() string
- func (m *Property) XXX_DiscardUnknown()
- func (m *Property) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Property) XXX_Merge(src proto.Message)
- func (m *Property) XXX_Size() int
- func (m *Property) XXX_Unmarshal(b []byte) error
- type ReceiveReq
- func (*ReceiveReq) Descriptor() ([]byte, []int)
- func (m *ReceiveReq) GetClearResumeToken() bool
- func (m *ReceiveReq) GetFilesystem() string
- func (m *ReceiveReq) GetReplicationConfig() *ReplicationConfig
- func (m *ReceiveReq) GetTo() *FilesystemVersion
- func (*ReceiveReq) ProtoMessage()
- func (m *ReceiveReq) Reset()
- func (m *ReceiveReq) String() string
- func (m *ReceiveReq) XXX_DiscardUnknown()
- func (m *ReceiveReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ReceiveReq) XXX_Merge(src proto.Message)
- func (m *ReceiveReq) XXX_Size() int
- func (m *ReceiveReq) XXX_Unmarshal(b []byte) error
- type ReceiveRes
- func (*ReceiveRes) Descriptor() ([]byte, []int)
- func (*ReceiveRes) ProtoMessage()
- func (m *ReceiveRes) Reset()
- func (m *ReceiveRes) String() string
- func (m *ReceiveRes) XXX_DiscardUnknown()
- func (m *ReceiveRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ReceiveRes) XXX_Merge(src proto.Message)
- func (m *ReceiveRes) XXX_Size() int
- func (m *ReceiveRes) XXX_Unmarshal(b []byte) error
- type ReplicationClient
- type ReplicationConfig
- func (*ReplicationConfig) Descriptor() ([]byte, []int)
- func (m *ReplicationConfig) GetProtection() *ReplicationConfigProtection
- func (*ReplicationConfig) ProtoMessage()
- func (m *ReplicationConfig) Reset()
- func (m *ReplicationConfig) String() string
- func (m *ReplicationConfig) XXX_DiscardUnknown()
- func (m *ReplicationConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ReplicationConfig) XXX_Merge(src proto.Message)
- func (m *ReplicationConfig) XXX_Size() int
- func (m *ReplicationConfig) XXX_Unmarshal(b []byte) error
- type ReplicationConfigProtection
- func (*ReplicationConfigProtection) Descriptor() ([]byte, []int)
- func (m *ReplicationConfigProtection) GetIncremental() ReplicationGuaranteeKind
- func (m *ReplicationConfigProtection) GetInitial() ReplicationGuaranteeKind
- func (*ReplicationConfigProtection) ProtoMessage()
- func (m *ReplicationConfigProtection) Reset()
- func (m *ReplicationConfigProtection) String() string
- func (m *ReplicationConfigProtection) XXX_DiscardUnknown()
- func (m *ReplicationConfigProtection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ReplicationConfigProtection) XXX_Merge(src proto.Message)
- func (m *ReplicationConfigProtection) XXX_Size() int
- func (m *ReplicationConfigProtection) XXX_Unmarshal(b []byte) error
- type ReplicationCursorReq
- func (*ReplicationCursorReq) Descriptor() ([]byte, []int)
- func (m *ReplicationCursorReq) GetFilesystem() string
- func (*ReplicationCursorReq) ProtoMessage()
- func (m *ReplicationCursorReq) Reset()
- func (m *ReplicationCursorReq) String() string
- func (m *ReplicationCursorReq) XXX_DiscardUnknown()
- func (m *ReplicationCursorReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ReplicationCursorReq) XXX_Merge(src proto.Message)
- func (m *ReplicationCursorReq) XXX_Size() int
- func (m *ReplicationCursorReq) XXX_Unmarshal(b []byte) error
- type ReplicationCursorRes
- func (*ReplicationCursorRes) Descriptor() ([]byte, []int)
- func (m *ReplicationCursorRes) GetGuid() uint64
- func (m *ReplicationCursorRes) GetNotexist() bool
- func (m *ReplicationCursorRes) GetResult() isReplicationCursorRes_Result
- func (*ReplicationCursorRes) ProtoMessage()
- func (m *ReplicationCursorRes) Reset()
- func (m *ReplicationCursorRes) String() string
- func (m *ReplicationCursorRes) XXX_DiscardUnknown()
- func (m *ReplicationCursorRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ReplicationCursorRes) XXX_Merge(src proto.Message)
- func (*ReplicationCursorRes) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *ReplicationCursorRes) XXX_Size() int
- func (m *ReplicationCursorRes) XXX_Unmarshal(b []byte) error
- type ReplicationCursorRes_Guid
- type ReplicationCursorRes_Notexist
- type ReplicationGuaranteeKind
- type ReplicationServer
- type SendCompletedReq
- func (*SendCompletedReq) Descriptor() ([]byte, []int)
- func (m *SendCompletedReq) GetOriginalReq() *SendReq
- func (*SendCompletedReq) ProtoMessage()
- func (m *SendCompletedReq) Reset()
- func (m *SendCompletedReq) String() string
- func (m *SendCompletedReq) XXX_DiscardUnknown()
- func (m *SendCompletedReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SendCompletedReq) XXX_Merge(src proto.Message)
- func (m *SendCompletedReq) XXX_Size() int
- func (m *SendCompletedReq) XXX_Unmarshal(b []byte) error
- type SendCompletedRes
- func (*SendCompletedRes) Descriptor() ([]byte, []int)
- func (*SendCompletedRes) ProtoMessage()
- func (m *SendCompletedRes) Reset()
- func (m *SendCompletedRes) String() string
- func (m *SendCompletedRes) XXX_DiscardUnknown()
- func (m *SendCompletedRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SendCompletedRes) XXX_Merge(src proto.Message)
- func (m *SendCompletedRes) XXX_Size() int
- func (m *SendCompletedRes) XXX_Unmarshal(b []byte) error
- type SendReq
- func (*SendReq) Descriptor() ([]byte, []int)
- func (m *SendReq) GetDryRun() bool
- func (m *SendReq) GetEncrypted() Tri
- func (m *SendReq) GetFilesystem() string
- func (m *SendReq) GetFrom() *FilesystemVersion
- func (m *SendReq) GetReplicationConfig() *ReplicationConfig
- func (m *SendReq) GetResumeToken() string
- func (m *SendReq) GetTo() *FilesystemVersion
- func (*SendReq) ProtoMessage()
- func (m *SendReq) Reset()
- func (m *SendReq) String() string
- func (m *SendReq) XXX_DiscardUnknown()
- func (m *SendReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SendReq) XXX_Merge(src proto.Message)
- func (m *SendReq) XXX_Size() int
- func (m *SendReq) XXX_Unmarshal(b []byte) error
- type SendRes
- func (*SendRes) Descriptor() ([]byte, []int)
- func (m *SendRes) GetExpectedSize() int64
- func (m *SendRes) GetProperties() []*Property
- func (m *SendRes) GetUsedResumeToken() bool
- func (*SendRes) ProtoMessage()
- func (m *SendRes) Reset()
- func (m *SendRes) String() string
- func (m *SendRes) XXX_DiscardUnknown()
- func (m *SendRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SendRes) XXX_Merge(src proto.Message)
- func (m *SendRes) XXX_Size() int
- func (m *SendRes) XXX_Unmarshal(b []byte) error
- type Tri
Constants ¶
This section is empty.
Variables ¶
View Source
var FilesystemVersion_VersionType_name = map[int32]string{
0: "Snapshot",
1: "Bookmark",
}
View Source
var FilesystemVersion_VersionType_value = map[string]int32{
"Snapshot": 0,
"Bookmark": 1,
}
View Source
var ReplicationGuaranteeKind_name = map[int32]string{
0: "GuaranteeInvalid",
1: "GuaranteeResumability",
2: "GuaranteeIncrementalReplication",
3: "GuaranteeNothing",
}
View Source
var ReplicationGuaranteeKind_value = map[string]int32{
"GuaranteeInvalid": 0,
"GuaranteeResumability": 1,
"GuaranteeIncrementalReplication": 2,
"GuaranteeNothing": 3,
}
View Source
var Tri_name = map[int32]string{
0: "DontCare",
1: "False",
2: "True",
}
View Source
var Tri_value = map[string]int32{
"DontCare": 0,
"False": 1,
"True": 2,
}
Functions ¶
func RegisterReplicationServer ¶
func RegisterReplicationServer(s *grpc.Server, srv ReplicationServer)
Types ¶
type DestroySnapshotRes ¶
type DestroySnapshotRes struct { Snapshot *FilesystemVersion `protobuf:"bytes,1,opt,name=Snapshot,proto3" json:"Snapshot,omitempty"` Error string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DestroySnapshotRes) Descriptor ¶
func (*DestroySnapshotRes) Descriptor() ([]byte, []int)
func (*DestroySnapshotRes) GetError ¶
func (m *DestroySnapshotRes) GetError() string
func (*DestroySnapshotRes) GetSnapshot ¶
func (m *DestroySnapshotRes) GetSnapshot() *FilesystemVersion
func (*DestroySnapshotRes) ProtoMessage ¶
func (*DestroySnapshotRes) ProtoMessage()
func (*DestroySnapshotRes) Reset ¶
func (m *DestroySnapshotRes) Reset()
func (*DestroySnapshotRes) String ¶
func (m *DestroySnapshotRes) String() string
func (*DestroySnapshotRes) XXX_DiscardUnknown ¶
func (m *DestroySnapshotRes) XXX_DiscardUnknown()
func (*DestroySnapshotRes) XXX_Marshal ¶
func (m *DestroySnapshotRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DestroySnapshotRes) XXX_Merge ¶
func (dst *DestroySnapshotRes) XXX_Merge(src proto.Message)
func (*DestroySnapshotRes) XXX_Size ¶
func (m *DestroySnapshotRes) XXX_Size() int
func (*DestroySnapshotRes) XXX_Unmarshal ¶
func (m *DestroySnapshotRes) XXX_Unmarshal(b []byte) error
type DestroySnapshotsReq ¶
type DestroySnapshotsReq struct { Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` // Path to filesystem, snapshot or bookmark to be destroyed Snapshots []*FilesystemVersion `protobuf:"bytes,2,rep,name=Snapshots,proto3" json:"Snapshots,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DestroySnapshotsReq) Descriptor ¶
func (*DestroySnapshotsReq) Descriptor() ([]byte, []int)
func (*DestroySnapshotsReq) GetFilesystem ¶
func (m *DestroySnapshotsReq) GetFilesystem() string
func (*DestroySnapshotsReq) GetSnapshots ¶
func (m *DestroySnapshotsReq) GetSnapshots() []*FilesystemVersion
func (*DestroySnapshotsReq) ProtoMessage ¶
func (*DestroySnapshotsReq) ProtoMessage()
func (*DestroySnapshotsReq) Reset ¶
func (m *DestroySnapshotsReq) Reset()
func (*DestroySnapshotsReq) String ¶
func (m *DestroySnapshotsReq) String() string
func (*DestroySnapshotsReq) XXX_DiscardUnknown ¶
func (m *DestroySnapshotsReq) XXX_DiscardUnknown()
func (*DestroySnapshotsReq) XXX_Marshal ¶
func (m *DestroySnapshotsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DestroySnapshotsReq) XXX_Merge ¶
func (dst *DestroySnapshotsReq) XXX_Merge(src proto.Message)
func (*DestroySnapshotsReq) XXX_Size ¶
func (m *DestroySnapshotsReq) XXX_Size() int
func (*DestroySnapshotsReq) XXX_Unmarshal ¶
func (m *DestroySnapshotsReq) XXX_Unmarshal(b []byte) error
type DestroySnapshotsRes ¶
type DestroySnapshotsRes struct { Results []*DestroySnapshotRes `protobuf:"bytes,1,rep,name=Results,proto3" json:"Results,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DestroySnapshotsRes) Descriptor ¶
func (*DestroySnapshotsRes) Descriptor() ([]byte, []int)
func (*DestroySnapshotsRes) GetResults ¶
func (m *DestroySnapshotsRes) GetResults() []*DestroySnapshotRes
func (*DestroySnapshotsRes) ProtoMessage ¶
func (*DestroySnapshotsRes) ProtoMessage()
func (*DestroySnapshotsRes) Reset ¶
func (m *DestroySnapshotsRes) Reset()
func (*DestroySnapshotsRes) String ¶
func (m *DestroySnapshotsRes) String() string
func (*DestroySnapshotsRes) XXX_DiscardUnknown ¶
func (m *DestroySnapshotsRes) XXX_DiscardUnknown()
func (*DestroySnapshotsRes) XXX_Marshal ¶
func (m *DestroySnapshotsRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DestroySnapshotsRes) XXX_Merge ¶
func (dst *DestroySnapshotsRes) XXX_Merge(src proto.Message)
func (*DestroySnapshotsRes) XXX_Size ¶
func (m *DestroySnapshotsRes) XXX_Size() int
func (*DestroySnapshotsRes) XXX_Unmarshal ¶
func (m *DestroySnapshotsRes) XXX_Unmarshal(b []byte) error
type Filesystem ¶
type Filesystem struct { Path string `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"` ResumeToken string `protobuf:"bytes,2,opt,name=ResumeToken,proto3" json:"ResumeToken,omitempty"` IsPlaceholder bool `protobuf:"varint,3,opt,name=IsPlaceholder,proto3" json:"IsPlaceholder,omitempty"` IsEncrypted bool `protobuf:"varint,4,opt,name=IsEncrypted,proto3" json:"IsEncrypted,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Filesystem) Descriptor ¶
func (*Filesystem) Descriptor() ([]byte, []int)
func (*Filesystem) GetIsEncrypted ¶ added in v0.3.0
func (m *Filesystem) GetIsEncrypted() bool
func (*Filesystem) GetIsPlaceholder ¶
func (m *Filesystem) GetIsPlaceholder() bool
func (*Filesystem) GetPath ¶
func (m *Filesystem) GetPath() string
func (*Filesystem) GetResumeToken ¶
func (m *Filesystem) GetResumeToken() string
func (*Filesystem) ProtoMessage ¶
func (*Filesystem) ProtoMessage()
func (*Filesystem) Reset ¶
func (m *Filesystem) Reset()
func (*Filesystem) String ¶
func (m *Filesystem) String() string
func (*Filesystem) XXX_DiscardUnknown ¶
func (m *Filesystem) XXX_DiscardUnknown()
func (*Filesystem) XXX_Marshal ¶
func (m *Filesystem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Filesystem) XXX_Merge ¶
func (dst *Filesystem) XXX_Merge(src proto.Message)
func (*Filesystem) XXX_Size ¶
func (m *Filesystem) XXX_Size() int
func (*Filesystem) XXX_Unmarshal ¶
func (m *Filesystem) XXX_Unmarshal(b []byte) error
type FilesystemVersion ¶
type FilesystemVersion struct { Type FilesystemVersion_VersionType `protobuf:"varint,1,opt,name=Type,proto3,enum=FilesystemVersion_VersionType" json:"Type,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` Guid uint64 `protobuf:"varint,3,opt,name=Guid,proto3" json:"Guid,omitempty"` CreateTXG uint64 `protobuf:"varint,4,opt,name=CreateTXG,proto3" json:"CreateTXG,omitempty"` Creation string `protobuf:"bytes,5,opt,name=Creation,proto3" json:"Creation,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func FilesystemVersionFromZFS ¶
func FilesystemVersionFromZFS(fsv *zfs.FilesystemVersion) *FilesystemVersion
func (*FilesystemVersion) CreationAsTime ¶
func (v *FilesystemVersion) CreationAsTime() (time.Time, error)
func (*FilesystemVersion) Descriptor ¶
func (*FilesystemVersion) Descriptor() ([]byte, []int)
func (*FilesystemVersion) GetCreateTXG ¶
func (m *FilesystemVersion) GetCreateTXG() uint64
func (*FilesystemVersion) GetCreation ¶
func (m *FilesystemVersion) GetCreation() string
func (*FilesystemVersion) GetGuid ¶
func (m *FilesystemVersion) GetGuid() uint64
func (*FilesystemVersion) GetName ¶
func (m *FilesystemVersion) GetName() string
func (*FilesystemVersion) GetRelName ¶ added in v0.3.0
func (v *FilesystemVersion) GetRelName() string
func (*FilesystemVersion) GetType ¶
func (m *FilesystemVersion) GetType() FilesystemVersion_VersionType
func (*FilesystemVersion) ProtoMessage ¶
func (*FilesystemVersion) ProtoMessage()
func (*FilesystemVersion) RelName ¶
func (v *FilesystemVersion) RelName() string
func (*FilesystemVersion) Reset ¶
func (m *FilesystemVersion) Reset()
func (*FilesystemVersion) SnapshotTime ¶
func (v *FilesystemVersion) SnapshotTime() time.Time
implement fsfsm.FilesystemVersion
func (*FilesystemVersion) String ¶
func (m *FilesystemVersion) String() string
func (*FilesystemVersion) XXX_DiscardUnknown ¶
func (m *FilesystemVersion) XXX_DiscardUnknown()
func (*FilesystemVersion) XXX_Marshal ¶
func (m *FilesystemVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FilesystemVersion) XXX_Merge ¶
func (dst *FilesystemVersion) XXX_Merge(src proto.Message)
func (*FilesystemVersion) XXX_Size ¶
func (m *FilesystemVersion) XXX_Size() int
func (*FilesystemVersion) XXX_Unmarshal ¶
func (m *FilesystemVersion) XXX_Unmarshal(b []byte) error
func (*FilesystemVersion) ZFSFilesystemVersion ¶
func (v *FilesystemVersion) ZFSFilesystemVersion() (*zfs.FilesystemVersion, error)
type FilesystemVersion_VersionType ¶
type FilesystemVersion_VersionType int32
const ( FilesystemVersion_Snapshot FilesystemVersion_VersionType = 0 FilesystemVersion_Bookmark FilesystemVersion_VersionType = 1 )
func (FilesystemVersion_VersionType) EnumDescriptor ¶
func (FilesystemVersion_VersionType) EnumDescriptor() ([]byte, []int)
func (FilesystemVersion_VersionType) String ¶
func (x FilesystemVersion_VersionType) String() string
func (FilesystemVersion_VersionType) ZFSVersionType ¶
func (v FilesystemVersion_VersionType) ZFSVersionType() zfs.VersionType
type ListFilesystemReq ¶
type ListFilesystemReq struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListFilesystemReq) Descriptor ¶
func (*ListFilesystemReq) Descriptor() ([]byte, []int)
func (*ListFilesystemReq) ProtoMessage ¶
func (*ListFilesystemReq) ProtoMessage()
func (*ListFilesystemReq) Reset ¶
func (m *ListFilesystemReq) Reset()
func (*ListFilesystemReq) String ¶
func (m *ListFilesystemReq) String() string
func (*ListFilesystemReq) XXX_DiscardUnknown ¶
func (m *ListFilesystemReq) XXX_DiscardUnknown()
func (*ListFilesystemReq) XXX_Marshal ¶
func (m *ListFilesystemReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListFilesystemReq) XXX_Merge ¶
func (dst *ListFilesystemReq) XXX_Merge(src proto.Message)
func (*ListFilesystemReq) XXX_Size ¶
func (m *ListFilesystemReq) XXX_Size() int
func (*ListFilesystemReq) XXX_Unmarshal ¶
func (m *ListFilesystemReq) XXX_Unmarshal(b []byte) error
type ListFilesystemRes ¶
type ListFilesystemRes struct { Filesystems []*Filesystem `protobuf:"bytes,1,rep,name=Filesystems,proto3" json:"Filesystems,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListFilesystemRes) Descriptor ¶
func (*ListFilesystemRes) Descriptor() ([]byte, []int)
func (*ListFilesystemRes) GetFilesystems ¶
func (m *ListFilesystemRes) GetFilesystems() []*Filesystem
func (*ListFilesystemRes) ProtoMessage ¶
func (*ListFilesystemRes) ProtoMessage()
func (*ListFilesystemRes) Reset ¶
func (m *ListFilesystemRes) Reset()
func (*ListFilesystemRes) String ¶
func (m *ListFilesystemRes) String() string
func (*ListFilesystemRes) XXX_DiscardUnknown ¶
func (m *ListFilesystemRes) XXX_DiscardUnknown()
func (*ListFilesystemRes) XXX_Marshal ¶
func (m *ListFilesystemRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListFilesystemRes) XXX_Merge ¶
func (dst *ListFilesystemRes) XXX_Merge(src proto.Message)
func (*ListFilesystemRes) XXX_Size ¶
func (m *ListFilesystemRes) XXX_Size() int
func (*ListFilesystemRes) XXX_Unmarshal ¶
func (m *ListFilesystemRes) XXX_Unmarshal(b []byte) error
type ListFilesystemVersionsReq ¶
type ListFilesystemVersionsReq struct { Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListFilesystemVersionsReq) Descriptor ¶
func (*ListFilesystemVersionsReq) Descriptor() ([]byte, []int)
func (*ListFilesystemVersionsReq) GetFilesystem ¶
func (m *ListFilesystemVersionsReq) GetFilesystem() string
func (*ListFilesystemVersionsReq) ProtoMessage ¶
func (*ListFilesystemVersionsReq) ProtoMessage()
func (*ListFilesystemVersionsReq) Reset ¶
func (m *ListFilesystemVersionsReq) Reset()
func (*ListFilesystemVersionsReq) String ¶
func (m *ListFilesystemVersionsReq) String() string
func (*ListFilesystemVersionsReq) XXX_DiscardUnknown ¶
func (m *ListFilesystemVersionsReq) XXX_DiscardUnknown()
func (*ListFilesystemVersionsReq) XXX_Marshal ¶
func (m *ListFilesystemVersionsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListFilesystemVersionsReq) XXX_Merge ¶
func (dst *ListFilesystemVersionsReq) XXX_Merge(src proto.Message)
func (*ListFilesystemVersionsReq) XXX_Size ¶
func (m *ListFilesystemVersionsReq) XXX_Size() int
func (*ListFilesystemVersionsReq) XXX_Unmarshal ¶
func (m *ListFilesystemVersionsReq) XXX_Unmarshal(b []byte) error
type ListFilesystemVersionsRes ¶
type ListFilesystemVersionsRes struct { Versions []*FilesystemVersion `protobuf:"bytes,1,rep,name=Versions,proto3" json:"Versions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListFilesystemVersionsRes) Descriptor ¶
func (*ListFilesystemVersionsRes) Descriptor() ([]byte, []int)
func (*ListFilesystemVersionsRes) GetVersions ¶
func (m *ListFilesystemVersionsRes) GetVersions() []*FilesystemVersion
func (*ListFilesystemVersionsRes) ProtoMessage ¶
func (*ListFilesystemVersionsRes) ProtoMessage()
func (*ListFilesystemVersionsRes) Reset ¶
func (m *ListFilesystemVersionsRes) Reset()
func (*ListFilesystemVersionsRes) String ¶
func (m *ListFilesystemVersionsRes) String() string
func (*ListFilesystemVersionsRes) XXX_DiscardUnknown ¶
func (m *ListFilesystemVersionsRes) XXX_DiscardUnknown()
func (*ListFilesystemVersionsRes) XXX_Marshal ¶
func (m *ListFilesystemVersionsRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListFilesystemVersionsRes) XXX_Merge ¶
func (dst *ListFilesystemVersionsRes) XXX_Merge(src proto.Message)
func (*ListFilesystemVersionsRes) XXX_Size ¶
func (m *ListFilesystemVersionsRes) XXX_Size() int
func (*ListFilesystemVersionsRes) XXX_Unmarshal ¶
func (m *ListFilesystemVersionsRes) XXX_Unmarshal(b []byte) error
type PingReq ¶
type PingReq struct { Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PingReq) Descriptor ¶
func (*PingReq) GetMessage ¶
func (*PingReq) ProtoMessage ¶
func (*PingReq) ProtoMessage()
func (*PingReq) XXX_DiscardUnknown ¶
func (m *PingReq) XXX_DiscardUnknown()
func (*PingReq) XXX_Marshal ¶
func (*PingReq) XXX_Unmarshal ¶
type PingRes ¶
type PingRes struct { // Echo must be PingReq.Message Echo string `protobuf:"bytes,1,opt,name=Echo,proto3" json:"Echo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PingRes) Descriptor ¶
func (*PingRes) ProtoMessage ¶
func (*PingRes) ProtoMessage()
func (*PingRes) XXX_DiscardUnknown ¶
func (m *PingRes) XXX_DiscardUnknown()
func (*PingRes) XXX_Marshal ¶
func (*PingRes) XXX_Unmarshal ¶
type Property ¶
type Property struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Value string `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Property) Descriptor ¶
func (*Property) ProtoMessage ¶
func (*Property) ProtoMessage()
func (*Property) XXX_DiscardUnknown ¶
func (m *Property) XXX_DiscardUnknown()
func (*Property) XXX_Marshal ¶
func (*Property) XXX_Unmarshal ¶
type ReceiveReq ¶
type ReceiveReq struct { Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` To *FilesystemVersion `protobuf:"bytes,2,opt,name=To,proto3" json:"To,omitempty"` // If true, the receiver should clear the resume token before performing the // zfs recv of the stream in the request ClearResumeToken bool `protobuf:"varint,3,opt,name=ClearResumeToken,proto3" json:"ClearResumeToken,omitempty"` ReplicationConfig *ReplicationConfig `protobuf:"bytes,4,opt,name=ReplicationConfig,proto3" json:"ReplicationConfig,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReceiveReq) Descriptor ¶
func (*ReceiveReq) Descriptor() ([]byte, []int)
func (*ReceiveReq) GetClearResumeToken ¶
func (m *ReceiveReq) GetClearResumeToken() bool
func (*ReceiveReq) GetFilesystem ¶
func (m *ReceiveReq) GetFilesystem() string
func (*ReceiveReq) GetReplicationConfig ¶ added in v0.3.0
func (m *ReceiveReq) GetReplicationConfig() *ReplicationConfig
func (*ReceiveReq) GetTo ¶ added in v0.3.0
func (m *ReceiveReq) GetTo() *FilesystemVersion
func (*ReceiveReq) ProtoMessage ¶
func (*ReceiveReq) ProtoMessage()
func (*ReceiveReq) Reset ¶
func (m *ReceiveReq) Reset()
func (*ReceiveReq) String ¶
func (m *ReceiveReq) String() string
func (*ReceiveReq) XXX_DiscardUnknown ¶
func (m *ReceiveReq) XXX_DiscardUnknown()
func (*ReceiveReq) XXX_Marshal ¶
func (m *ReceiveReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReceiveReq) XXX_Merge ¶
func (dst *ReceiveReq) XXX_Merge(src proto.Message)
func (*ReceiveReq) XXX_Size ¶
func (m *ReceiveReq) XXX_Size() int
func (*ReceiveReq) XXX_Unmarshal ¶
func (m *ReceiveReq) XXX_Unmarshal(b []byte) error
type ReceiveRes ¶
type ReceiveRes struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReceiveRes) Descriptor ¶
func (*ReceiveRes) Descriptor() ([]byte, []int)
func (*ReceiveRes) ProtoMessage ¶
func (*ReceiveRes) ProtoMessage()
func (*ReceiveRes) Reset ¶
func (m *ReceiveRes) Reset()
func (*ReceiveRes) String ¶
func (m *ReceiveRes) String() string
func (*ReceiveRes) XXX_DiscardUnknown ¶
func (m *ReceiveRes) XXX_DiscardUnknown()
func (*ReceiveRes) XXX_Marshal ¶
func (m *ReceiveRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReceiveRes) XXX_Merge ¶
func (dst *ReceiveRes) XXX_Merge(src proto.Message)
func (*ReceiveRes) XXX_Size ¶
func (m *ReceiveRes) XXX_Size() int
func (*ReceiveRes) XXX_Unmarshal ¶
func (m *ReceiveRes) XXX_Unmarshal(b []byte) error
type ReplicationClient ¶
type ReplicationClient interface { Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingRes, error) ListFilesystems(ctx context.Context, in *ListFilesystemReq, opts ...grpc.CallOption) (*ListFilesystemRes, error) ListFilesystemVersions(ctx context.Context, in *ListFilesystemVersionsReq, opts ...grpc.CallOption) (*ListFilesystemVersionsRes, error) DestroySnapshots(ctx context.Context, in *DestroySnapshotsReq, opts ...grpc.CallOption) (*DestroySnapshotsRes, error) ReplicationCursor(ctx context.Context, in *ReplicationCursorReq, opts ...grpc.CallOption) (*ReplicationCursorRes, error) SendCompleted(ctx context.Context, in *SendCompletedReq, opts ...grpc.CallOption) (*SendCompletedRes, error) }
ReplicationClient is the client API for Replication service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewReplicationClient ¶
func NewReplicationClient(cc *grpc.ClientConn) ReplicationClient
type ReplicationConfig ¶ added in v0.3.0
type ReplicationConfig struct { Protection *ReplicationConfigProtection `protobuf:"bytes,1,opt,name=protection,proto3" json:"protection,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReplicationConfig) Descriptor ¶ added in v0.3.0
func (*ReplicationConfig) Descriptor() ([]byte, []int)
func (*ReplicationConfig) GetProtection ¶ added in v0.3.0
func (m *ReplicationConfig) GetProtection() *ReplicationConfigProtection
func (*ReplicationConfig) ProtoMessage ¶ added in v0.3.0
func (*ReplicationConfig) ProtoMessage()
func (*ReplicationConfig) Reset ¶ added in v0.3.0
func (m *ReplicationConfig) Reset()
func (*ReplicationConfig) String ¶ added in v0.3.0
func (m *ReplicationConfig) String() string
func (*ReplicationConfig) XXX_DiscardUnknown ¶ added in v0.3.0
func (m *ReplicationConfig) XXX_DiscardUnknown()
func (*ReplicationConfig) XXX_Marshal ¶ added in v0.3.0
func (m *ReplicationConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicationConfig) XXX_Merge ¶ added in v0.3.0
func (dst *ReplicationConfig) XXX_Merge(src proto.Message)
func (*ReplicationConfig) XXX_Size ¶ added in v0.3.0
func (m *ReplicationConfig) XXX_Size() int
func (*ReplicationConfig) XXX_Unmarshal ¶ added in v0.3.0
func (m *ReplicationConfig) XXX_Unmarshal(b []byte) error
type ReplicationConfigProtection ¶ added in v0.3.0
type ReplicationConfigProtection struct { Initial ReplicationGuaranteeKind `protobuf:"varint,1,opt,name=Initial,proto3,enum=ReplicationGuaranteeKind" json:"Initial,omitempty"` Incremental ReplicationGuaranteeKind `protobuf:"varint,2,opt,name=Incremental,proto3,enum=ReplicationGuaranteeKind" json:"Incremental,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func ReplicationConfigProtectionWithKind ¶ added in v0.3.0
func ReplicationConfigProtectionWithKind(both ReplicationGuaranteeKind) *ReplicationConfigProtection
func (*ReplicationConfigProtection) Descriptor ¶ added in v0.3.0
func (*ReplicationConfigProtection) Descriptor() ([]byte, []int)
func (*ReplicationConfigProtection) GetIncremental ¶ added in v0.3.0
func (m *ReplicationConfigProtection) GetIncremental() ReplicationGuaranteeKind
func (*ReplicationConfigProtection) GetInitial ¶ added in v0.3.0
func (m *ReplicationConfigProtection) GetInitial() ReplicationGuaranteeKind
func (*ReplicationConfigProtection) ProtoMessage ¶ added in v0.3.0
func (*ReplicationConfigProtection) ProtoMessage()
func (*ReplicationConfigProtection) Reset ¶ added in v0.3.0
func (m *ReplicationConfigProtection) Reset()
func (*ReplicationConfigProtection) String ¶ added in v0.3.0
func (m *ReplicationConfigProtection) String() string
func (*ReplicationConfigProtection) XXX_DiscardUnknown ¶ added in v0.3.0
func (m *ReplicationConfigProtection) XXX_DiscardUnknown()
func (*ReplicationConfigProtection) XXX_Marshal ¶ added in v0.3.0
func (m *ReplicationConfigProtection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicationConfigProtection) XXX_Merge ¶ added in v0.3.0
func (dst *ReplicationConfigProtection) XXX_Merge(src proto.Message)
func (*ReplicationConfigProtection) XXX_Size ¶ added in v0.3.0
func (m *ReplicationConfigProtection) XXX_Size() int
func (*ReplicationConfigProtection) XXX_Unmarshal ¶ added in v0.3.0
func (m *ReplicationConfigProtection) XXX_Unmarshal(b []byte) error
type ReplicationCursorReq ¶
type ReplicationCursorReq struct { Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReplicationCursorReq) Descriptor ¶
func (*ReplicationCursorReq) Descriptor() ([]byte, []int)
func (*ReplicationCursorReq) GetFilesystem ¶
func (m *ReplicationCursorReq) GetFilesystem() string
func (*ReplicationCursorReq) ProtoMessage ¶
func (*ReplicationCursorReq) ProtoMessage()
func (*ReplicationCursorReq) Reset ¶
func (m *ReplicationCursorReq) Reset()
func (*ReplicationCursorReq) String ¶
func (m *ReplicationCursorReq) String() string
func (*ReplicationCursorReq) XXX_DiscardUnknown ¶
func (m *ReplicationCursorReq) XXX_DiscardUnknown()
func (*ReplicationCursorReq) XXX_Marshal ¶
func (m *ReplicationCursorReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicationCursorReq) XXX_Merge ¶
func (dst *ReplicationCursorReq) XXX_Merge(src proto.Message)
func (*ReplicationCursorReq) XXX_Size ¶
func (m *ReplicationCursorReq) XXX_Size() int
func (*ReplicationCursorReq) XXX_Unmarshal ¶
func (m *ReplicationCursorReq) XXX_Unmarshal(b []byte) error
type ReplicationCursorRes ¶
type ReplicationCursorRes struct { // Types that are valid to be assigned to Result: // *ReplicationCursorRes_Guid // *ReplicationCursorRes_Notexist Result isReplicationCursorRes_Result `protobuf_oneof:"Result"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReplicationCursorRes) Descriptor ¶
func (*ReplicationCursorRes) Descriptor() ([]byte, []int)
func (*ReplicationCursorRes) GetGuid ¶
func (m *ReplicationCursorRes) GetGuid() uint64
func (*ReplicationCursorRes) GetNotexist ¶
func (m *ReplicationCursorRes) GetNotexist() bool
func (*ReplicationCursorRes) GetResult ¶
func (m *ReplicationCursorRes) GetResult() isReplicationCursorRes_Result
func (*ReplicationCursorRes) ProtoMessage ¶
func (*ReplicationCursorRes) ProtoMessage()
func (*ReplicationCursorRes) Reset ¶
func (m *ReplicationCursorRes) Reset()
func (*ReplicationCursorRes) String ¶
func (m *ReplicationCursorRes) String() string
func (*ReplicationCursorRes) XXX_DiscardUnknown ¶
func (m *ReplicationCursorRes) XXX_DiscardUnknown()
func (*ReplicationCursorRes) XXX_Marshal ¶
func (m *ReplicationCursorRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicationCursorRes) XXX_Merge ¶
func (dst *ReplicationCursorRes) XXX_Merge(src proto.Message)
func (*ReplicationCursorRes) XXX_OneofFuncs ¶
func (*ReplicationCursorRes) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*ReplicationCursorRes) XXX_Size ¶
func (m *ReplicationCursorRes) XXX_Size() int
func (*ReplicationCursorRes) XXX_Unmarshal ¶
func (m *ReplicationCursorRes) XXX_Unmarshal(b []byte) error
type ReplicationCursorRes_Guid ¶
type ReplicationCursorRes_Guid struct {
Guid uint64 `protobuf:"varint,1,opt,name=Guid,proto3,oneof"`
}
type ReplicationCursorRes_Notexist ¶
type ReplicationCursorRes_Notexist struct {
Notexist bool `protobuf:"varint,2,opt,name=Notexist,proto3,oneof"`
}
type ReplicationGuaranteeKind ¶ added in v0.3.0
type ReplicationGuaranteeKind int32
const ( ReplicationGuaranteeKind_GuaranteeInvalid ReplicationGuaranteeKind = 0 ReplicationGuaranteeKind_GuaranteeResumability ReplicationGuaranteeKind = 1 ReplicationGuaranteeKind_GuaranteeIncrementalReplication ReplicationGuaranteeKind = 2 ReplicationGuaranteeKind_GuaranteeNothing ReplicationGuaranteeKind = 3 )
func (ReplicationGuaranteeKind) EnumDescriptor ¶ added in v0.3.0
func (ReplicationGuaranteeKind) EnumDescriptor() ([]byte, []int)
func (ReplicationGuaranteeKind) String ¶ added in v0.3.0
func (x ReplicationGuaranteeKind) String() string
type ReplicationServer ¶
type ReplicationServer interface { Ping(context.Context, *PingReq) (*PingRes, error) ListFilesystems(context.Context, *ListFilesystemReq) (*ListFilesystemRes, error) ListFilesystemVersions(context.Context, *ListFilesystemVersionsReq) (*ListFilesystemVersionsRes, error) DestroySnapshots(context.Context, *DestroySnapshotsReq) (*DestroySnapshotsRes, error) ReplicationCursor(context.Context, *ReplicationCursorReq) (*ReplicationCursorRes, error) SendCompleted(context.Context, *SendCompletedReq) (*SendCompletedRes, error) }
ReplicationServer is the server API for Replication service.
type SendCompletedReq ¶ added in v0.3.0
type SendCompletedReq struct { OriginalReq *SendReq `protobuf:"bytes,2,opt,name=OriginalReq,proto3" json:"OriginalReq,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendCompletedReq) Descriptor ¶ added in v0.3.0
func (*SendCompletedReq) Descriptor() ([]byte, []int)
func (*SendCompletedReq) GetOriginalReq ¶ added in v0.3.0
func (m *SendCompletedReq) GetOriginalReq() *SendReq
func (*SendCompletedReq) ProtoMessage ¶ added in v0.3.0
func (*SendCompletedReq) ProtoMessage()
func (*SendCompletedReq) Reset ¶ added in v0.3.0
func (m *SendCompletedReq) Reset()
func (*SendCompletedReq) String ¶ added in v0.3.0
func (m *SendCompletedReq) String() string
func (*SendCompletedReq) XXX_DiscardUnknown ¶ added in v0.3.0
func (m *SendCompletedReq) XXX_DiscardUnknown()
func (*SendCompletedReq) XXX_Marshal ¶ added in v0.3.0
func (m *SendCompletedReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendCompletedReq) XXX_Merge ¶ added in v0.3.0
func (dst *SendCompletedReq) XXX_Merge(src proto.Message)
func (*SendCompletedReq) XXX_Size ¶ added in v0.3.0
func (m *SendCompletedReq) XXX_Size() int
func (*SendCompletedReq) XXX_Unmarshal ¶ added in v0.3.0
func (m *SendCompletedReq) XXX_Unmarshal(b []byte) error
type SendCompletedRes ¶ added in v0.3.0
type SendCompletedRes struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendCompletedRes) Descriptor ¶ added in v0.3.0
func (*SendCompletedRes) Descriptor() ([]byte, []int)
func (*SendCompletedRes) ProtoMessage ¶ added in v0.3.0
func (*SendCompletedRes) ProtoMessage()
func (*SendCompletedRes) Reset ¶ added in v0.3.0
func (m *SendCompletedRes) Reset()
func (*SendCompletedRes) String ¶ added in v0.3.0
func (m *SendCompletedRes) String() string
func (*SendCompletedRes) XXX_DiscardUnknown ¶ added in v0.3.0
func (m *SendCompletedRes) XXX_DiscardUnknown()
func (*SendCompletedRes) XXX_Marshal ¶ added in v0.3.0
func (m *SendCompletedRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendCompletedRes) XXX_Merge ¶ added in v0.3.0
func (dst *SendCompletedRes) XXX_Merge(src proto.Message)
func (*SendCompletedRes) XXX_Size ¶ added in v0.3.0
func (m *SendCompletedRes) XXX_Size() int
func (*SendCompletedRes) XXX_Unmarshal ¶ added in v0.3.0
func (m *SendCompletedRes) XXX_Unmarshal(b []byte) error
type SendReq ¶
type SendReq struct { Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` // May be empty / null to request a full transfer of To From *FilesystemVersion `protobuf:"bytes,2,opt,name=From,proto3" json:"From,omitempty"` To *FilesystemVersion `protobuf:"bytes,3,opt,name=To,proto3" json:"To,omitempty"` // If ResumeToken is not empty, the resume token that CAN be used for 'zfs // send' by the sender. The sender MUST indicate use of ResumeToken in the // reply message SendRes.UsedResumeToken If it does not work, the sender // SHOULD clear the resume token on their side and use From and To instead If // ResumeToken is not empty, the GUIDs of From and To MUST correspond to those // encoded in the ResumeToken. Otherwise, the Sender MUST return an error. ResumeToken string `protobuf:"bytes,4,opt,name=ResumeToken,proto3" json:"ResumeToken,omitempty"` Encrypted Tri `protobuf:"varint,5,opt,name=Encrypted,proto3,enum=Tri" json:"Encrypted,omitempty"` DryRun bool `protobuf:"varint,6,opt,name=DryRun,proto3" json:"DryRun,omitempty"` ReplicationConfig *ReplicationConfig `protobuf:"bytes,7,opt,name=ReplicationConfig,proto3" json:"ReplicationConfig,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendReq) Descriptor ¶
func (*SendReq) GetEncrypted ¶ added in v0.3.0
func (*SendReq) GetFilesystem ¶
func (*SendReq) GetFrom ¶
func (m *SendReq) GetFrom() *FilesystemVersion
func (*SendReq) GetReplicationConfig ¶ added in v0.3.0
func (m *SendReq) GetReplicationConfig() *ReplicationConfig
func (*SendReq) GetResumeToken ¶
func (*SendReq) GetTo ¶
func (m *SendReq) GetTo() *FilesystemVersion
func (*SendReq) ProtoMessage ¶
func (*SendReq) ProtoMessage()
func (*SendReq) XXX_DiscardUnknown ¶
func (m *SendReq) XXX_DiscardUnknown()
func (*SendReq) XXX_Marshal ¶
func (*SendReq) XXX_Unmarshal ¶
type SendRes ¶
type SendRes struct { // Whether the resume token provided in the request has been used or not. // If the SendReq.ResumeToken == "", this field has no meaning. UsedResumeToken bool `protobuf:"varint,2,opt,name=UsedResumeToken,proto3" json:"UsedResumeToken,omitempty"` // Expected stream size determined by dry run, not exact. // 0 indicates that for the given SendReq, no size estimate could be made. ExpectedSize int64 `protobuf:"varint,3,opt,name=ExpectedSize,proto3" json:"ExpectedSize,omitempty"` Properties []*Property `protobuf:"bytes,4,rep,name=Properties,proto3" json:"Properties,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendRes) Descriptor ¶
func (*SendRes) GetExpectedSize ¶
func (*SendRes) GetProperties ¶
func (*SendRes) GetUsedResumeToken ¶
func (*SendRes) ProtoMessage ¶
func (*SendRes) ProtoMessage()
func (*SendRes) XXX_DiscardUnknown ¶
func (m *SendRes) XXX_DiscardUnknown()
func (*SendRes) XXX_Marshal ¶
func (*SendRes) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.