pdu

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

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 FilesystemVersionCreation 

func FilesystemVersionCreation(t time.Time) string

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) Descriptor() ([]byte, []int)

func (*PingReq) GetMessage 

func (m *PingReq) GetMessage() string

func (*PingReq) ProtoMessage 

func (*PingReq) ProtoMessage()

func (*PingReq) Reset 

func (m *PingReq) Reset()

func (*PingReq) String 

func (m *PingReq) String() string

func (*PingReq) XXX_DiscardUnknown 

func (m *PingReq) XXX_DiscardUnknown()

func (*PingReq) XXX_Marshal 

func (m *PingReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingReq) XXX_Merge 

func (dst *PingReq) XXX_Merge(src proto.Message)

func (*PingReq) XXX_Size 

func (m *PingReq) XXX_Size() int

func (*PingReq) XXX_Unmarshal 

func (m *PingReq) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*PingRes) GetEcho 

func (m *PingRes) GetEcho() string

func (*PingRes) ProtoMessage 

func (*PingRes) ProtoMessage()

func (*PingRes) Reset 

func (m *PingRes) Reset()

func (*PingRes) String 

func (m *PingRes) String() string

func (*PingRes) XXX_DiscardUnknown 

func (m *PingRes) XXX_DiscardUnknown()

func (*PingRes) XXX_Marshal 

func (m *PingRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingRes) XXX_Merge 

func (dst *PingRes) XXX_Merge(src proto.Message)

func (*PingRes) XXX_Size 

func (m *PingRes) XXX_Size() int

func (*PingRes) XXX_Unmarshal 

func (m *PingRes) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Property) GetName 

func (m *Property) GetName() string

func (*Property) GetValue 

func (m *Property) GetValue() string

func (*Property) ProtoMessage 

func (*Property) ProtoMessage()

func (*Property) Reset 

func (m *Property) Reset()

func (*Property) String 

func (m *Property) String() string

func (*Property) XXX_DiscardUnknown 

func (m *Property) XXX_DiscardUnknown()

func (*Property) XXX_Marshal 

func (m *Property) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Property) XXX_Merge 

func (dst *Property) XXX_Merge(src proto.Message)

func (*Property) XXX_Size 

func (m *Property) XXX_Size() int

func (*Property) XXX_Unmarshal 

func (m *Property) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*SendReq) GetDryRun 

func (m *SendReq) GetDryRun() bool

func (*SendReq) GetEncrypted added in v0.3.0 

func (m *SendReq) GetEncrypted() Tri

func (*SendReq) GetFilesystem 

func (m *SendReq) GetFilesystem() string

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 (m *SendReq) GetResumeToken() string

func (*SendReq) GetTo 

func (m *SendReq) GetTo() *FilesystemVersion

func (*SendReq) ProtoMessage 

func (*SendReq) ProtoMessage()

func (*SendReq) Reset 

func (m *SendReq) Reset()

func (*SendReq) String 

func (m *SendReq) String() string

func (*SendReq) XXX_DiscardUnknown 

func (m *SendReq) XXX_DiscardUnknown()

func (*SendReq) XXX_Marshal 

func (m *SendReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendReq) XXX_Merge 

func (dst *SendReq) XXX_Merge(src proto.Message)

func (*SendReq) XXX_Size 

func (m *SendReq) XXX_Size() int

func (*SendReq) XXX_Unmarshal 

func (m *SendReq) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*SendRes) GetExpectedSize 

func (m *SendRes) GetExpectedSize() int64

func (*SendRes) GetProperties 

func (m *SendRes) GetProperties() []*Property

func (*SendRes) GetUsedResumeToken 

func (m *SendRes) GetUsedResumeToken() bool

func (*SendRes) ProtoMessage 

func (*SendRes) ProtoMessage()

func (*SendRes) Reset 

func (m *SendRes) Reset()

func (*SendRes) String 

func (m *SendRes) String() string

func (*SendRes) XXX_DiscardUnknown 

func (m *SendRes) XXX_DiscardUnknown()

func (*SendRes) XXX_Marshal 

func (m *SendRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendRes) XXX_Merge 

func (dst *SendRes) XXX_Merge(src proto.Message)

func (*SendRes) XXX_Size 

func (m *SendRes) XXX_Size() int

func (*SendRes) XXX_Unmarshal 

func (m *SendRes) XXX_Unmarshal(b []byte) error

type Tri added in v0.3.0 

type Tri int32
const (
	Tri_DontCare Tri = 0
	Tri_False    Tri = 1
	Tri_True     Tri = 2
)

func (Tri) EnumDescriptor added in v0.3.0 

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

func (Tri) String added in v0.3.0 

func (x Tri) String() string

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.