pdu

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 31, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ReplicationGuaranteeKind_name = map[int32]string{
		0: "GuaranteeInvalid",
		1: "GuaranteeResumability",
		2: "GuaranteeIncrementalReplication",
		3: "GuaranteeNothing",
	}
	ReplicationGuaranteeKind_value = map[string]int32{
		"GuaranteeInvalid":                0,
		"GuaranteeResumability":           1,
		"GuaranteeIncrementalReplication": 2,
		"GuaranteeNothing":                3,
	}
)

Enum value maps for ReplicationGuaranteeKind.

View Source 
var (
	FilesystemVersion_VersionType_name = map[int32]string{
		0: "Snapshot",
		1: "Bookmark",
	}
	FilesystemVersion_VersionType_value = map[string]int32{
		"Snapshot": 0,
		"Bookmark": 1,
	}
)

Enum value maps for FilesystemVersion_VersionType.

View Source 
var File_pdu_proto protoreflect.FileDescriptor
View Source 
var Replication_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Replication",
	HandlerType: (*ReplicationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Replication_Ping_Handler,
		},
		{
			MethodName: "ListFilesystems",
			Handler:    _Replication_ListFilesystems_Handler,
		},
		{
			MethodName: "ListFilesystemVersions",
			Handler:    _Replication_ListFilesystemVersions_Handler,
		},
		{
			MethodName: "DestroySnapshots",
			Handler:    _Replication_DestroySnapshots_Handler,
		},
		{
			MethodName: "ReplicationCursor",
			Handler:    _Replication_ReplicationCursor_Handler,
		},
		{
			MethodName: "SendDry",
			Handler:    _Replication_SendDry_Handler,
		},
		{
			MethodName: "SendCompleted",
			Handler:    _Replication_SendCompleted_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pdu.proto",
}

Replication_ServiceDesc is the grpc.ServiceDesc for Replication service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func FilesystemVersionCreation 

func FilesystemVersionCreation(t time.Time) string

func RegisterReplicationServer 

func RegisterReplicationServer(s grpc.ServiceRegistrar, 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"`
	// contains filtered or unexported fields
}

func (*DestroySnapshotRes) Descriptor deprecated 

func (*DestroySnapshotRes) Descriptor() ([]byte, []int)

Deprecated: Use DestroySnapshotRes.ProtoReflect.Descriptor instead.

func (*DestroySnapshotRes) GetError 

func (x *DestroySnapshotRes) GetError() string

func (*DestroySnapshotRes) GetSnapshot 

func (x *DestroySnapshotRes) GetSnapshot() *FilesystemVersion

func (*DestroySnapshotRes) ProtoMessage 

func (*DestroySnapshotRes) ProtoMessage()

func (*DestroySnapshotRes) ProtoReflect added in v0.4.0 

func (x *DestroySnapshotRes) ProtoReflect() protoreflect.Message

func (*DestroySnapshotRes) Reset 

func (x *DestroySnapshotRes) Reset()

func (*DestroySnapshotRes) String 

func (x *DestroySnapshotRes) String() string

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"`
	// contains filtered or unexported fields
}

func (*DestroySnapshotsReq) Descriptor deprecated 

func (*DestroySnapshotsReq) Descriptor() ([]byte, []int)

Deprecated: Use DestroySnapshotsReq.ProtoReflect.Descriptor instead.

func (*DestroySnapshotsReq) GetFilesystem 

func (x *DestroySnapshotsReq) GetFilesystem() string

func (*DestroySnapshotsReq) GetSnapshots 

func (x *DestroySnapshotsReq) GetSnapshots() []*FilesystemVersion

func (*DestroySnapshotsReq) ProtoMessage 

func (*DestroySnapshotsReq) ProtoMessage()

func (*DestroySnapshotsReq) ProtoReflect added in v0.4.0 

func (x *DestroySnapshotsReq) ProtoReflect() protoreflect.Message

func (*DestroySnapshotsReq) Reset 

func (x *DestroySnapshotsReq) Reset()

func (*DestroySnapshotsReq) String 

func (x *DestroySnapshotsReq) String() string

type DestroySnapshotsRes 

type DestroySnapshotsRes struct {
	Results []*DestroySnapshotRes `protobuf:"bytes,1,rep,name=Results,proto3" json:"Results,omitempty"`
	// contains filtered or unexported fields
}

func (*DestroySnapshotsRes) Descriptor deprecated 

func (*DestroySnapshotsRes) Descriptor() ([]byte, []int)

Deprecated: Use DestroySnapshotsRes.ProtoReflect.Descriptor instead.

func (*DestroySnapshotsRes) GetResults 

func (x *DestroySnapshotsRes) GetResults() []*DestroySnapshotRes

func (*DestroySnapshotsRes) ProtoMessage 

func (*DestroySnapshotsRes) ProtoMessage()

func (*DestroySnapshotsRes) ProtoReflect added in v0.4.0 

func (x *DestroySnapshotsRes) ProtoReflect() protoreflect.Message

func (*DestroySnapshotsRes) Reset 

func (x *DestroySnapshotsRes) Reset()

func (*DestroySnapshotsRes) String 

func (x *DestroySnapshotsRes) String() string

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"`
	// contains filtered or unexported fields
}

func (*Filesystem) Descriptor deprecated 

func (*Filesystem) Descriptor() ([]byte, []int)

Deprecated: Use Filesystem.ProtoReflect.Descriptor instead.

func (*Filesystem) GetIsPlaceholder 

func (x *Filesystem) GetIsPlaceholder() bool

func (*Filesystem) GetPath 

func (x *Filesystem) GetPath() string

func (*Filesystem) GetResumeToken 

func (x *Filesystem) GetResumeToken() string

func (*Filesystem) ProtoMessage 

func (*Filesystem) ProtoMessage()

func (*Filesystem) ProtoReflect added in v0.4.0 

func (x *Filesystem) ProtoReflect() protoreflect.Message

func (*Filesystem) Reset 

func (x *Filesystem) Reset()

func (*Filesystem) String 

func (x *Filesystem) String() string

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"` // RFC 3339
	// contains filtered or unexported fields
}

func FilesystemVersionFromZFS 

func FilesystemVersionFromZFS(fsv *zfs.FilesystemVersion) *FilesystemVersion

func (*FilesystemVersion) CreationAsTime 

func (v *FilesystemVersion) CreationAsTime() (time.Time, error)

func (*FilesystemVersion) Descriptor deprecated 

func (*FilesystemVersion) Descriptor() ([]byte, []int)

Deprecated: Use FilesystemVersion.ProtoReflect.Descriptor instead.

func (*FilesystemVersion) GetCreateTXG 

func (x *FilesystemVersion) GetCreateTXG() uint64

func (*FilesystemVersion) GetCreation 

func (x *FilesystemVersion) GetCreation() string

func (*FilesystemVersion) GetGuid 

func (x *FilesystemVersion) GetGuid() uint64

func (*FilesystemVersion) GetName 

func (x *FilesystemVersion) GetName() string

func (*FilesystemVersion) GetRelName added in v0.3.0 

func (v *FilesystemVersion) GetRelName() string

func (*FilesystemVersion) GetType 

func (x *FilesystemVersion) GetType() FilesystemVersion_VersionType

func (*FilesystemVersion) ProtoMessage 

func (*FilesystemVersion) ProtoMessage()

func (*FilesystemVersion) ProtoReflect added in v0.4.0 

func (x *FilesystemVersion) ProtoReflect() protoreflect.Message

func (*FilesystemVersion) RelName 

func (v *FilesystemVersion) RelName() string

func (*FilesystemVersion) Reset 

func (x *FilesystemVersion) Reset()

func (*FilesystemVersion) SnapshotTime 

func (v *FilesystemVersion) SnapshotTime() time.Time

implement fsfsm.FilesystemVersion

func (*FilesystemVersion) String 

func (x *FilesystemVersion) String() string

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) Descriptor added in v0.4.0 

func (FilesystemVersion_VersionType) Descriptor() protoreflect.EnumDescriptor

func (FilesystemVersion_VersionType) Enum added in v0.4.0 

func (x FilesystemVersion_VersionType) Enum() *FilesystemVersion_VersionType

func (FilesystemVersion_VersionType) EnumDescriptor deprecated 

func (FilesystemVersion_VersionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use FilesystemVersion_VersionType.Descriptor instead.

func (FilesystemVersion_VersionType) Number added in v0.4.0 

func (x FilesystemVersion_VersionType) Number() protoreflect.EnumNumber

func (FilesystemVersion_VersionType) String 

func (x FilesystemVersion_VersionType) String() string

func (FilesystemVersion_VersionType) Type added in v0.4.0 

func (FilesystemVersion_VersionType) Type() protoreflect.EnumType

func (FilesystemVersion_VersionType) ZFSVersionType 

func (v FilesystemVersion_VersionType) ZFSVersionType() zfs.VersionType

type ListFilesystemReq 

type ListFilesystemReq struct {
	// contains filtered or unexported fields
}

func (*ListFilesystemReq) Descriptor deprecated 

func (*ListFilesystemReq) Descriptor() ([]byte, []int)

Deprecated: Use ListFilesystemReq.ProtoReflect.Descriptor instead.

func (*ListFilesystemReq) ProtoMessage 

func (*ListFilesystemReq) ProtoMessage()

func (*ListFilesystemReq) ProtoReflect added in v0.4.0 

func (x *ListFilesystemReq) ProtoReflect() protoreflect.Message

func (*ListFilesystemReq) Reset 

func (x *ListFilesystemReq) Reset()

func (*ListFilesystemReq) String 

func (x *ListFilesystemReq) String() string

type ListFilesystemRes 

type ListFilesystemRes struct {
	Filesystems []*Filesystem `protobuf:"bytes,1,rep,name=Filesystems,proto3" json:"Filesystems,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFilesystemRes) Descriptor deprecated 

func (*ListFilesystemRes) Descriptor() ([]byte, []int)

Deprecated: Use ListFilesystemRes.ProtoReflect.Descriptor instead.

func (*ListFilesystemRes) GetFilesystems 

func (x *ListFilesystemRes) GetFilesystems() []*Filesystem

func (*ListFilesystemRes) ProtoMessage 

func (*ListFilesystemRes) ProtoMessage()

func (*ListFilesystemRes) ProtoReflect added in v0.4.0 

func (x *ListFilesystemRes) ProtoReflect() protoreflect.Message

func (*ListFilesystemRes) Reset 

func (x *ListFilesystemRes) Reset()

func (*ListFilesystemRes) String 

func (x *ListFilesystemRes) String() string

type ListFilesystemVersionsReq 

type ListFilesystemVersionsReq struct {
	Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFilesystemVersionsReq) Descriptor deprecated 

func (*ListFilesystemVersionsReq) Descriptor() ([]byte, []int)

Deprecated: Use ListFilesystemVersionsReq.ProtoReflect.Descriptor instead.

func (*ListFilesystemVersionsReq) GetFilesystem 

func (x *ListFilesystemVersionsReq) GetFilesystem() string

func (*ListFilesystemVersionsReq) ProtoMessage 

func (*ListFilesystemVersionsReq) ProtoMessage()

func (*ListFilesystemVersionsReq) ProtoReflect added in v0.4.0 

func (x *ListFilesystemVersionsReq) ProtoReflect() protoreflect.Message

func (*ListFilesystemVersionsReq) Reset 

func (x *ListFilesystemVersionsReq) Reset()

func (*ListFilesystemVersionsReq) String 

func (x *ListFilesystemVersionsReq) String() string

type ListFilesystemVersionsRes 

type ListFilesystemVersionsRes struct {
	Versions []*FilesystemVersion `protobuf:"bytes,1,rep,name=Versions,proto3" json:"Versions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFilesystemVersionsRes) Descriptor deprecated 

func (*ListFilesystemVersionsRes) Descriptor() ([]byte, []int)

Deprecated: Use ListFilesystemVersionsRes.ProtoReflect.Descriptor instead.

func (*ListFilesystemVersionsRes) GetVersions 

func (x *ListFilesystemVersionsRes) GetVersions() []*FilesystemVersion

func (*ListFilesystemVersionsRes) ProtoMessage 

func (*ListFilesystemVersionsRes) ProtoMessage()

func (*ListFilesystemVersionsRes) ProtoReflect added in v0.4.0 

func (x *ListFilesystemVersionsRes) ProtoReflect() protoreflect.Message

func (*ListFilesystemVersionsRes) Reset 

func (x *ListFilesystemVersionsRes) Reset()

func (*ListFilesystemVersionsRes) String 

func (x *ListFilesystemVersionsRes) String() string

type PingReq 

type PingReq struct {
	Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*PingReq) Descriptor deprecated 

func (*PingReq) Descriptor() ([]byte, []int)

Deprecated: Use PingReq.ProtoReflect.Descriptor instead.

func (*PingReq) GetMessage 

func (x *PingReq) GetMessage() string

func (*PingReq) ProtoMessage 

func (*PingReq) ProtoMessage()

func (*PingReq) ProtoReflect added in v0.4.0 

func (x *PingReq) ProtoReflect() protoreflect.Message

func (*PingReq) Reset 

func (x *PingReq) Reset()

func (*PingReq) String 

func (x *PingReq) String() string

type PingRes 

type PingRes struct {

	// Echo must be PingReq.Message
	Echo string `protobuf:"bytes,1,opt,name=Echo,proto3" json:"Echo,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRes) Descriptor deprecated 

func (*PingRes) Descriptor() ([]byte, []int)

Deprecated: Use PingRes.ProtoReflect.Descriptor instead.

func (*PingRes) GetEcho 

func (x *PingRes) GetEcho() string

func (*PingRes) ProtoMessage 

func (*PingRes) ProtoMessage()

func (*PingRes) ProtoReflect added in v0.4.0 

func (x *PingRes) ProtoReflect() protoreflect.Message

func (*PingRes) Reset 

func (x *PingRes) Reset()

func (*PingRes) String 

func (x *PingRes) String() string

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"`
	// contains filtered or unexported fields
}

func (*Property) Descriptor deprecated 

func (*Property) Descriptor() ([]byte, []int)

Deprecated: Use Property.ProtoReflect.Descriptor instead.

func (*Property) GetName 

func (x *Property) GetName() string

func (*Property) GetValue 

func (x *Property) GetValue() string

func (*Property) ProtoMessage 

func (*Property) ProtoMessage()

func (*Property) ProtoReflect added in v0.4.0 

func (x *Property) ProtoReflect() protoreflect.Message

func (*Property) Reset 

func (x *Property) Reset()

func (*Property) String 

func (x *Property) String() string

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"`
	// contains filtered or unexported fields
}

func (*ReceiveReq) Descriptor deprecated 

func (*ReceiveReq) Descriptor() ([]byte, []int)

Deprecated: Use ReceiveReq.ProtoReflect.Descriptor instead.

func (*ReceiveReq) GetClearResumeToken 

func (x *ReceiveReq) GetClearResumeToken() bool

func (*ReceiveReq) GetFilesystem 

func (x *ReceiveReq) GetFilesystem() string

func (*ReceiveReq) GetReplicationConfig added in v0.3.0 

func (x *ReceiveReq) GetReplicationConfig() *ReplicationConfig

func (*ReceiveReq) GetTo added in v0.3.0 

func (x *ReceiveReq) GetTo() *FilesystemVersion

func (*ReceiveReq) ProtoMessage 

func (*ReceiveReq) ProtoMessage()

func (*ReceiveReq) ProtoReflect added in v0.4.0 

func (x *ReceiveReq) ProtoReflect() protoreflect.Message

func (*ReceiveReq) Reset 

func (x *ReceiveReq) Reset()

func (*ReceiveReq) String 

func (x *ReceiveReq) String() string

type ReceiveRes 

type ReceiveRes struct {
	// contains filtered or unexported fields
}

func (*ReceiveRes) Descriptor deprecated 

func (*ReceiveRes) Descriptor() ([]byte, []int)

Deprecated: Use ReceiveRes.ProtoReflect.Descriptor instead.

func (*ReceiveRes) ProtoMessage 

func (*ReceiveRes) ProtoMessage()

func (*ReceiveRes) ProtoReflect added in v0.4.0 

func (x *ReceiveRes) ProtoReflect() protoreflect.Message

func (*ReceiveRes) Reset 

func (x *ReceiveRes) Reset()

func (*ReceiveRes) String 

func (x *ReceiveRes) String() string

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)
	SendDry(ctx context.Context, in *SendReq, opts ...grpc.CallOption) (*SendRes, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewReplicationClient 

func NewReplicationClient(cc grpc.ClientConnInterface) ReplicationClient

type ReplicationConfig added in v0.3.0 

type ReplicationConfig struct {
	Protection *ReplicationConfigProtection `protobuf:"bytes,1,opt,name=protection,proto3" json:"protection,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationConfig) Descriptor deprecated added in v0.3.0 

func (*ReplicationConfig) Descriptor() ([]byte, []int)

Deprecated: Use ReplicationConfig.ProtoReflect.Descriptor instead.

func (*ReplicationConfig) GetProtection added in v0.3.0 

func (x *ReplicationConfig) GetProtection() *ReplicationConfigProtection

func (*ReplicationConfig) ProtoMessage added in v0.3.0 

func (*ReplicationConfig) ProtoMessage()

func (*ReplicationConfig) ProtoReflect added in v0.4.0 

func (x *ReplicationConfig) ProtoReflect() protoreflect.Message

func (*ReplicationConfig) Reset added in v0.3.0 

func (x *ReplicationConfig) Reset()

func (*ReplicationConfig) String added in v0.3.0 

func (x *ReplicationConfig) String() string

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"`
	// contains filtered or unexported fields
}

func ReplicationConfigProtectionWithKind added in v0.3.0 

func ReplicationConfigProtectionWithKind(both ReplicationGuaranteeKind) *ReplicationConfigProtection

func (*ReplicationConfigProtection) Descriptor deprecated added in v0.3.0 

func (*ReplicationConfigProtection) Descriptor() ([]byte, []int)

Deprecated: Use ReplicationConfigProtection.ProtoReflect.Descriptor instead.

func (*ReplicationConfigProtection) GetIncremental added in v0.3.0 

func (x *ReplicationConfigProtection) GetIncremental() ReplicationGuaranteeKind

func (*ReplicationConfigProtection) GetInitial added in v0.3.0 

func (x *ReplicationConfigProtection) GetInitial() ReplicationGuaranteeKind

func (*ReplicationConfigProtection) ProtoMessage added in v0.3.0 

func (*ReplicationConfigProtection) ProtoMessage()

func (*ReplicationConfigProtection) ProtoReflect added in v0.4.0 

func (x *ReplicationConfigProtection) ProtoReflect() protoreflect.Message

func (*ReplicationConfigProtection) Reset added in v0.3.0 

func (x *ReplicationConfigProtection) Reset()

func (*ReplicationConfigProtection) String added in v0.3.0 

func (x *ReplicationConfigProtection) String() string

type ReplicationCursorReq 

type ReplicationCursorReq struct {
	Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicationCursorReq) Descriptor deprecated 

func (*ReplicationCursorReq) Descriptor() ([]byte, []int)

Deprecated: Use ReplicationCursorReq.ProtoReflect.Descriptor instead.

func (*ReplicationCursorReq) GetFilesystem 

func (x *ReplicationCursorReq) GetFilesystem() string

func (*ReplicationCursorReq) ProtoMessage 

func (*ReplicationCursorReq) ProtoMessage()

func (*ReplicationCursorReq) ProtoReflect added in v0.4.0 

func (x *ReplicationCursorReq) ProtoReflect() protoreflect.Message

func (*ReplicationCursorReq) Reset 

func (x *ReplicationCursorReq) Reset()

func (*ReplicationCursorReq) String 

func (x *ReplicationCursorReq) String() string

type ReplicationCursorRes 

type ReplicationCursorRes struct {

	// Types that are assignable to Result:
	//	*ReplicationCursorRes_Guid
	//	*ReplicationCursorRes_Notexist
	Result isReplicationCursorRes_Result `protobuf_oneof:"Result"`
	// contains filtered or unexported fields
}

func (*ReplicationCursorRes) Descriptor deprecated 

func (*ReplicationCursorRes) Descriptor() ([]byte, []int)

Deprecated: Use ReplicationCursorRes.ProtoReflect.Descriptor instead.

func (*ReplicationCursorRes) GetGuid 

func (x *ReplicationCursorRes) GetGuid() uint64

func (*ReplicationCursorRes) GetNotexist 

func (x *ReplicationCursorRes) GetNotexist() bool

func (*ReplicationCursorRes) GetResult 

func (m *ReplicationCursorRes) GetResult() isReplicationCursorRes_Result

func (*ReplicationCursorRes) ProtoMessage 

func (*ReplicationCursorRes) ProtoMessage()

func (*ReplicationCursorRes) ProtoReflect added in v0.4.0 

func (x *ReplicationCursorRes) ProtoReflect() protoreflect.Message

func (*ReplicationCursorRes) Reset 

func (x *ReplicationCursorRes) Reset()

func (*ReplicationCursorRes) String 

func (x *ReplicationCursorRes) String() string

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) Descriptor added in v0.4.0 

func (ReplicationGuaranteeKind) Descriptor() protoreflect.EnumDescriptor

func (ReplicationGuaranteeKind) Enum added in v0.4.0 

func (x ReplicationGuaranteeKind) Enum() *ReplicationGuaranteeKind

func (ReplicationGuaranteeKind) EnumDescriptor deprecated added in v0.3.0 

func (ReplicationGuaranteeKind) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReplicationGuaranteeKind.Descriptor instead.

func (ReplicationGuaranteeKind) Number added in v0.4.0 

func (x ReplicationGuaranteeKind) Number() protoreflect.EnumNumber

func (ReplicationGuaranteeKind) String added in v0.3.0 

func (x ReplicationGuaranteeKind) String() string

func (ReplicationGuaranteeKind) Type added in v0.4.0 

func (ReplicationGuaranteeKind) Type() protoreflect.EnumType

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)
	SendDry(context.Context, *SendReq) (*SendRes, error)
	SendCompleted(context.Context, *SendCompletedReq) (*SendCompletedRes, error)
	// contains filtered or unexported methods
}

ReplicationServer is the server API for Replication service. All implementations must embed UnimplementedReplicationServer for forward compatibility

type SendCompletedReq added in v0.3.0 

type SendCompletedReq struct {
	OriginalReq *SendReq `protobuf:"bytes,2,opt,name=OriginalReq,proto3" json:"OriginalReq,omitempty"`
	// contains filtered or unexported fields
}

func (*SendCompletedReq) Descriptor deprecated added in v0.3.0 

func (*SendCompletedReq) Descriptor() ([]byte, []int)

Deprecated: Use SendCompletedReq.ProtoReflect.Descriptor instead.

func (*SendCompletedReq) GetOriginalReq added in v0.3.0 

func (x *SendCompletedReq) GetOriginalReq() *SendReq

func (*SendCompletedReq) ProtoMessage added in v0.3.0 

func (*SendCompletedReq) ProtoMessage()

func (*SendCompletedReq) ProtoReflect added in v0.4.0 

func (x *SendCompletedReq) ProtoReflect() protoreflect.Message

func (*SendCompletedReq) Reset added in v0.3.0 

func (x *SendCompletedReq) Reset()

func (*SendCompletedReq) String added in v0.3.0 

func (x *SendCompletedReq) String() string

type SendCompletedRes added in v0.3.0 

type SendCompletedRes struct {
	// contains filtered or unexported fields
}

func (*SendCompletedRes) Descriptor deprecated added in v0.3.0 

func (*SendCompletedRes) Descriptor() ([]byte, []int)

Deprecated: Use SendCompletedRes.ProtoReflect.Descriptor instead.

func (*SendCompletedRes) ProtoMessage added in v0.3.0 

func (*SendCompletedRes) ProtoMessage()

func (*SendCompletedRes) ProtoReflect added in v0.4.0 

func (x *SendCompletedRes) ProtoReflect() protoreflect.Message

func (*SendCompletedRes) Reset added in v0.3.0 

func (x *SendCompletedRes) Reset()

func (*SendCompletedRes) String added in v0.3.0 

func (x *SendCompletedRes) String() string

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"`
	ReplicationConfig *ReplicationConfig `protobuf:"bytes,6,opt,name=ReplicationConfig,proto3" json:"ReplicationConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*SendReq) Descriptor deprecated 

func (*SendReq) Descriptor() ([]byte, []int)

Deprecated: Use SendReq.ProtoReflect.Descriptor instead.

func (*SendReq) GetFilesystem 

func (x *SendReq) GetFilesystem() string

func (*SendReq) GetFrom 

func (x *SendReq) GetFrom() *FilesystemVersion

func (*SendReq) GetReplicationConfig added in v0.3.0 

func (x *SendReq) GetReplicationConfig() *ReplicationConfig

func (*SendReq) GetResumeToken 

func (x *SendReq) GetResumeToken() string

func (*SendReq) GetTo 

func (x *SendReq) GetTo() *FilesystemVersion

func (*SendReq) ProtoMessage 

func (*SendReq) ProtoMessage()

func (*SendReq) ProtoReflect added in v0.4.0 

func (x *SendReq) ProtoReflect() protoreflect.Message

func (*SendReq) Reset 

func (x *SendReq) Reset()

func (*SendReq) String 

func (x *SendReq) String() string

type SendRes 

type SendRes struct {

	// Whether the resume token provided in the request has been used or not.
	// If the SendReq.ResumeToken == "", this field MUST be false.
	UsedResumeToken bool `protobuf:"varint,1,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 uint64 `protobuf:"varint,2,opt,name=ExpectedSize,proto3" json:"ExpectedSize,omitempty"`
	// contains filtered or unexported fields
}

func (*SendRes) Descriptor deprecated 

func (*SendRes) Descriptor() ([]byte, []int)

Deprecated: Use SendRes.ProtoReflect.Descriptor instead.

func (*SendRes) GetExpectedSize 

func (x *SendRes) GetExpectedSize() uint64

func (*SendRes) GetUsedResumeToken 

func (x *SendRes) GetUsedResumeToken() bool

func (*SendRes) ProtoMessage 

func (*SendRes) ProtoMessage()

func (*SendRes) ProtoReflect added in v0.4.0 

func (x *SendRes) ProtoReflect() protoreflect.Message

func (*SendRes) Reset 

func (x *SendRes) Reset()

func (*SendRes) String 

func (x *SendRes) String() string

type UnimplementedReplicationServer added in v0.4.0 

type UnimplementedReplicationServer struct {
}

UnimplementedReplicationServer must be embedded to have forward compatible implementations.

func (UnimplementedReplicationServer) DestroySnapshots added in v0.4.0 

func (UnimplementedReplicationServer) DestroySnapshots(context.Context, *DestroySnapshotsReq) (*DestroySnapshotsRes, error)

func (UnimplementedReplicationServer) ListFilesystemVersions added in v0.4.0 

func (UnimplementedReplicationServer) ListFilesystemVersions(context.Context, *ListFilesystemVersionsReq) (*ListFilesystemVersionsRes, error)

func (UnimplementedReplicationServer) ListFilesystems added in v0.4.0 

func (UnimplementedReplicationServer) ListFilesystems(context.Context, *ListFilesystemReq) (*ListFilesystemRes, error)

func (UnimplementedReplicationServer) Ping added in v0.4.0 

func (UnimplementedReplicationServer) Ping(context.Context, *PingReq) (*PingRes, error)

func (UnimplementedReplicationServer) ReplicationCursor added in v0.4.0 

func (UnimplementedReplicationServer) ReplicationCursor(context.Context, *ReplicationCursorReq) (*ReplicationCursorRes, error)

func (UnimplementedReplicationServer) SendCompleted added in v0.4.0 

func (UnimplementedReplicationServer) SendCompleted(context.Context, *SendCompletedReq) (*SendCompletedRes, error)

func (UnimplementedReplicationServer) SendDry added in v0.5.0 

func (UnimplementedReplicationServer) SendDry(context.Context, *SendReq) (*SendRes, error)

type UnsafeReplicationServer added in v0.4.0 

type UnsafeReplicationServer interface {
	// contains filtered or unexported methods
}

UnsafeReplicationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReplicationServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.