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) 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 (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 (*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 ReplicationCursorReq
- func (*ReplicationCursorReq) Descriptor() ([]byte, []int)
- func (m *ReplicationCursorReq) GetFilesystem() string
- func (m *ReplicationCursorReq) GetGet() *ReplicationCursorReq_GetOp
- func (m *ReplicationCursorReq) GetOp() isReplicationCursorReq_Op
- func (m *ReplicationCursorReq) GetSet() *ReplicationCursorReq_SetOp
- 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 (*ReplicationCursorReq) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *ReplicationCursorReq) XXX_Size() int
- func (m *ReplicationCursorReq) XXX_Unmarshal(b []byte) error
- type ReplicationCursorReq_Get
- type ReplicationCursorReq_GetOp
- func (*ReplicationCursorReq_GetOp) Descriptor() ([]byte, []int)
- func (*ReplicationCursorReq_GetOp) ProtoMessage()
- func (m *ReplicationCursorReq_GetOp) Reset()
- func (m *ReplicationCursorReq_GetOp) String() string
- func (m *ReplicationCursorReq_GetOp) XXX_DiscardUnknown()
- func (m *ReplicationCursorReq_GetOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ReplicationCursorReq_GetOp) XXX_Merge(src proto.Message)
- func (m *ReplicationCursorReq_GetOp) XXX_Size() int
- func (m *ReplicationCursorReq_GetOp) XXX_Unmarshal(b []byte) error
- type ReplicationCursorReq_Set
- type ReplicationCursorReq_SetOp
- func (*ReplicationCursorReq_SetOp) Descriptor() ([]byte, []int)
- func (m *ReplicationCursorReq_SetOp) GetSnapshot() string
- func (*ReplicationCursorReq_SetOp) ProtoMessage()
- func (m *ReplicationCursorReq_SetOp) Reset()
- func (m *ReplicationCursorReq_SetOp) String() string
- func (m *ReplicationCursorReq_SetOp) XXX_DiscardUnknown()
- func (m *ReplicationCursorReq_SetOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ReplicationCursorReq_SetOp) XXX_Merge(src proto.Message)
- func (m *ReplicationCursorReq_SetOp) XXX_Size() int
- func (m *ReplicationCursorReq_SetOp) 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 ReplicationServer
- type SendReq
- func (*SendReq) Descriptor() ([]byte, []int)
- func (m *SendReq) GetCompress() bool
- func (m *SendReq) GetDedup() bool
- func (m *SendReq) GetDryRun() bool
- func (m *SendReq) GetFilesystem() string
- func (m *SendReq) GetFrom() string
- func (m *SendReq) GetResumeToken() string
- func (m *SendReq) GetTo() string
- 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
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,
}
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Filesystem) Descriptor ¶
func (*Filesystem) Descriptor() ([]byte, []int)
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) 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"` // If true, the receiver should clear the resume token before perfoming the zfs recv of the stream in the request ClearResumeToken bool `protobuf:"varint,2,opt,name=ClearResumeToken,proto3" json:"ClearResumeToken,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) 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) }
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 ReplicationCursorReq ¶
type ReplicationCursorReq struct { Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` // Types that are valid to be assigned to Op: // *ReplicationCursorReq_Get // *ReplicationCursorReq_Set Op isReplicationCursorReq_Op `protobuf_oneof:"op"` 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) GetGet ¶
func (m *ReplicationCursorReq) GetGet() *ReplicationCursorReq_GetOp
func (*ReplicationCursorReq) GetOp ¶
func (m *ReplicationCursorReq) GetOp() isReplicationCursorReq_Op
func (*ReplicationCursorReq) GetSet ¶
func (m *ReplicationCursorReq) GetSet() *ReplicationCursorReq_SetOp
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_OneofFuncs ¶
func (*ReplicationCursorReq) 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 (*ReplicationCursorReq) XXX_Size ¶
func (m *ReplicationCursorReq) XXX_Size() int
func (*ReplicationCursorReq) XXX_Unmarshal ¶
func (m *ReplicationCursorReq) XXX_Unmarshal(b []byte) error
type ReplicationCursorReq_Get ¶
type ReplicationCursorReq_Get struct {
Get *ReplicationCursorReq_GetOp `protobuf:"bytes,2,opt,name=get,proto3,oneof"`
}
type ReplicationCursorReq_GetOp ¶
type ReplicationCursorReq_GetOp struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReplicationCursorReq_GetOp) Descriptor ¶
func (*ReplicationCursorReq_GetOp) Descriptor() ([]byte, []int)
func (*ReplicationCursorReq_GetOp) ProtoMessage ¶
func (*ReplicationCursorReq_GetOp) ProtoMessage()
func (*ReplicationCursorReq_GetOp) Reset ¶
func (m *ReplicationCursorReq_GetOp) Reset()
func (*ReplicationCursorReq_GetOp) String ¶
func (m *ReplicationCursorReq_GetOp) String() string
func (*ReplicationCursorReq_GetOp) XXX_DiscardUnknown ¶
func (m *ReplicationCursorReq_GetOp) XXX_DiscardUnknown()
func (*ReplicationCursorReq_GetOp) XXX_Marshal ¶
func (m *ReplicationCursorReq_GetOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicationCursorReq_GetOp) XXX_Merge ¶
func (dst *ReplicationCursorReq_GetOp) XXX_Merge(src proto.Message)
func (*ReplicationCursorReq_GetOp) XXX_Size ¶
func (m *ReplicationCursorReq_GetOp) XXX_Size() int
func (*ReplicationCursorReq_GetOp) XXX_Unmarshal ¶
func (m *ReplicationCursorReq_GetOp) XXX_Unmarshal(b []byte) error
type ReplicationCursorReq_Set ¶
type ReplicationCursorReq_Set struct {
Set *ReplicationCursorReq_SetOp `protobuf:"bytes,3,opt,name=set,proto3,oneof"`
}
type ReplicationCursorReq_SetOp ¶
type ReplicationCursorReq_SetOp struct { Snapshot string `protobuf:"bytes,2,opt,name=Snapshot,proto3" json:"Snapshot,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReplicationCursorReq_SetOp) Descriptor ¶
func (*ReplicationCursorReq_SetOp) Descriptor() ([]byte, []int)
func (*ReplicationCursorReq_SetOp) GetSnapshot ¶
func (m *ReplicationCursorReq_SetOp) GetSnapshot() string
func (*ReplicationCursorReq_SetOp) ProtoMessage ¶
func (*ReplicationCursorReq_SetOp) ProtoMessage()
func (*ReplicationCursorReq_SetOp) Reset ¶
func (m *ReplicationCursorReq_SetOp) Reset()
func (*ReplicationCursorReq_SetOp) String ¶
func (m *ReplicationCursorReq_SetOp) String() string
func (*ReplicationCursorReq_SetOp) XXX_DiscardUnknown ¶
func (m *ReplicationCursorReq_SetOp) XXX_DiscardUnknown()
func (*ReplicationCursorReq_SetOp) XXX_Marshal ¶
func (m *ReplicationCursorReq_SetOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicationCursorReq_SetOp) XXX_Merge ¶
func (dst *ReplicationCursorReq_SetOp) XXX_Merge(src proto.Message)
func (*ReplicationCursorReq_SetOp) XXX_Size ¶
func (m *ReplicationCursorReq_SetOp) XXX_Size() int
func (*ReplicationCursorReq_SetOp) XXX_Unmarshal ¶
func (m *ReplicationCursorReq_SetOp) 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 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) }
ReplicationServer is the server API for Replication service.
type SendReq ¶
type SendReq struct { Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"` From string `protobuf:"bytes,2,opt,name=From,proto3" json:"From,omitempty"` // May be empty / null to request a full transfer of From To string `protobuf:"bytes,3,opt,name=To,proto3" json:"To,omitempty"` // If ResumeToken is not empty, the resume token that CAN be tried for 'zfs send' by the sender. // The sender MUST indicate in 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"` Compress bool `protobuf:"varint,5,opt,name=Compress,proto3" json:"Compress,omitempty"` Dedup bool `protobuf:"varint,6,opt,name=Dedup,proto3" json:"Dedup,omitempty"` DryRun bool `protobuf:"varint,7,opt,name=DryRun,proto3" json:"DryRun,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendReq) Descriptor ¶
func (*SendReq) GetCompress ¶
func (*SendReq) GetFilesystem ¶
func (*SendReq) GetResumeToken ¶
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. 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.