pdu

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Oct 10, 2019 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,
}

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"`
	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 (*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 (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"`
	// 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 (*ReplicationCursorReq) GetOp

func (m *ReplicationCursorReq) GetOp() isReplicationCursorReq_Op

func (*ReplicationCursorReq) GetSet

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

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

func (*SendReq) GetCompress

func (m *SendReq) GetCompress() bool

func (*SendReq) GetDedup

func (m *SendReq) GetDedup() bool

func (*SendReq) GetDryRun

func (m *SendReq) GetDryRun() bool

func (*SendReq) GetFilesystem

func (m *SendReq) GetFilesystem() string

func (*SendReq) GetFrom

func (m *SendReq) GetFrom() string

func (*SendReq) GetResumeToken

func (m *SendReq) GetResumeToken() string

func (*SendReq) GetTo

func (m *SendReq) GetTo() string

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.
	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

Jump to

Keyboard shortcuts

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