pdu

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Apr 6, 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 (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"`
	// If true, the receiver should clear the resume token before perfoming the zfs recv of the stream in the request
	ClearResumeToken     bool     `protobuf:"varint,2,opt,name=ClearResumeToken,proto3" json:"ClearResumeToken,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReceiveReq) Descriptor 

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

func (*ReceiveReq) GetClearResumeToken 

func (m *ReceiveReq) GetClearResumeToken() bool

func (*ReceiveReq) GetFilesystem 

func (m *ReceiveReq) GetFilesystem() string

func (*ReceiveReq) ProtoMessage 

func (*ReceiveReq) ProtoMessage()

func (*ReceiveReq) Reset 

func (m *ReceiveReq) Reset()

func (*ReceiveReq) String 

func (m *ReceiveReq) String() string

func (*ReceiveReq) XXX_DiscardUnknown 

func (m *ReceiveReq) XXX_DiscardUnknown()

func (*ReceiveReq) XXX_Marshal 

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

func (*ReceiveReq) XXX_Merge 

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

func (*ReceiveReq) XXX_Size 

func (m *ReceiveReq) XXX_Size() int

func (*ReceiveReq) XXX_Unmarshal 

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

type ReceiveRes 

type ReceiveRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReceiveRes) Descriptor 

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

func (*ReceiveRes) ProtoMessage 

func (*ReceiveRes) ProtoMessage()

func (*ReceiveRes) Reset 

func (m *ReceiveRes) Reset()

func (*ReceiveRes) String 

func (m *ReceiveRes) String() string

func (*ReceiveRes) XXX_DiscardUnknown 

func (m *ReceiveRes) XXX_DiscardUnknown()

func (*ReceiveRes) XXX_Marshal 

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

func (*ReceiveRes) XXX_Merge 

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

func (*ReceiveRes) XXX_Size 

func (m *ReceiveRes) XXX_Size() int

func (*ReceiveRes) XXX_Unmarshal 

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

type ReplicationClient 

type ReplicationClient interface {
	Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingRes, error)
	ListFilesystems(ctx context.Context, in *ListFilesystemReq, opts ...grpc.CallOption) (*ListFilesystemRes, error)
	ListFilesystemVersions(ctx context.Context, in *ListFilesystemVersionsReq, opts ...grpc.CallOption) (*ListFilesystemVersionsRes, error)
	DestroySnapshots(ctx context.Context, in *DestroySnapshotsReq, opts ...grpc.CallOption) (*DestroySnapshotsRes, error)
	ReplicationCursor(ctx context.Context, in *ReplicationCursorReq, opts ...grpc.CallOption) (*ReplicationCursorRes, error)
}

ReplicationClient is the client API for Replication service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewReplicationClient 

func NewReplicationClient(cc *grpc.ClientConn) ReplicationClient

type ReplicationCursorReq 

type ReplicationCursorReq struct {
	Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"`
	// Types that are valid to be assigned to Op:
	//	*ReplicationCursorReq_Get
	//	*ReplicationCursorReq_Set
	Op                   isReplicationCursorReq_Op `protobuf_oneof:"op"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ReplicationCursorReq) Descriptor 

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

func (*ReplicationCursorReq) GetFilesystem 

func (m *ReplicationCursorReq) GetFilesystem() string

func (*ReplicationCursorReq) GetGet 

func (m *ReplicationCursorReq) GetGet() *ReplicationCursorReq_GetOp

func (*ReplicationCursorReq) GetOp 

func (m *ReplicationCursorReq) GetOp() isReplicationCursorReq_Op

func (*ReplicationCursorReq) GetSet 

func (m *ReplicationCursorReq) GetSet() *ReplicationCursorReq_SetOp

func (*ReplicationCursorReq) ProtoMessage 

func (*ReplicationCursorReq) ProtoMessage()

func (*ReplicationCursorReq) Reset 

func (m *ReplicationCursorReq) Reset()

func (*ReplicationCursorReq) String 

func (m *ReplicationCursorReq) String() string

func (*ReplicationCursorReq) XXX_DiscardUnknown 

func (m *ReplicationCursorReq) XXX_DiscardUnknown()

func (*ReplicationCursorReq) XXX_Marshal 

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

func (*ReplicationCursorReq) XXX_Merge 

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

func (*ReplicationCursorReq) XXX_OneofFuncs 

func (*ReplicationCursorReq) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ReplicationCursorReq) XXX_Size 

func (m *ReplicationCursorReq) XXX_Size() int

func (*ReplicationCursorReq) XXX_Unmarshal 

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

type ReplicationCursorReq_Get 

type ReplicationCursorReq_Get struct {
	Get *ReplicationCursorReq_GetOp `protobuf:"bytes,2,opt,name=get,proto3,oneof"`
}

type ReplicationCursorReq_GetOp 

type ReplicationCursorReq_GetOp struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicationCursorReq_GetOp) Descriptor 

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

func (*ReplicationCursorReq_GetOp) ProtoMessage 

func (*ReplicationCursorReq_GetOp) ProtoMessage()

func (*ReplicationCursorReq_GetOp) Reset 

func (m *ReplicationCursorReq_GetOp) Reset()

func (*ReplicationCursorReq_GetOp) String 

func (m *ReplicationCursorReq_GetOp) String() string

func (*ReplicationCursorReq_GetOp) XXX_DiscardUnknown 

func (m *ReplicationCursorReq_GetOp) XXX_DiscardUnknown()

func (*ReplicationCursorReq_GetOp) XXX_Marshal 

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

func (*ReplicationCursorReq_GetOp) XXX_Merge 

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

func (*ReplicationCursorReq_GetOp) XXX_Size 

func (m *ReplicationCursorReq_GetOp) XXX_Size() int

func (*ReplicationCursorReq_GetOp) XXX_Unmarshal 

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

type ReplicationCursorReq_Set 

type ReplicationCursorReq_Set struct {
	Set *ReplicationCursorReq_SetOp `protobuf:"bytes,3,opt,name=set,proto3,oneof"`
}

type ReplicationCursorReq_SetOp 

type ReplicationCursorReq_SetOp struct {
	Snapshot             string   `protobuf:"bytes,2,opt,name=Snapshot,proto3" json:"Snapshot,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicationCursorReq_SetOp) Descriptor 

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

func (*ReplicationCursorReq_SetOp) GetSnapshot 

func (m *ReplicationCursorReq_SetOp) GetSnapshot() string

func (*ReplicationCursorReq_SetOp) ProtoMessage 

func (*ReplicationCursorReq_SetOp) ProtoMessage()

func (*ReplicationCursorReq_SetOp) Reset 

func (m *ReplicationCursorReq_SetOp) Reset()

func (*ReplicationCursorReq_SetOp) String 

func (m *ReplicationCursorReq_SetOp) String() string

func (*ReplicationCursorReq_SetOp) XXX_DiscardUnknown 

func (m *ReplicationCursorReq_SetOp) XXX_DiscardUnknown()

func (*ReplicationCursorReq_SetOp) XXX_Marshal 

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

func (*ReplicationCursorReq_SetOp) XXX_Merge 

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

func (*ReplicationCursorReq_SetOp) XXX_Size 

func (m *ReplicationCursorReq_SetOp) XXX_Size() int

func (*ReplicationCursorReq_SetOp) XXX_Unmarshal 

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

type ReplicationCursorRes 

type ReplicationCursorRes struct {
	// Types that are valid to be assigned to Result:
	//	*ReplicationCursorRes_Guid
	//	*ReplicationCursorRes_Notexist
	Result               isReplicationCursorRes_Result `protobuf_oneof:"Result"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*ReplicationCursorRes) Descriptor 

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

func (*ReplicationCursorRes) GetGuid 

func (m *ReplicationCursorRes) GetGuid() uint64

func (*ReplicationCursorRes) GetNotexist 

func (m *ReplicationCursorRes) GetNotexist() bool

func (*ReplicationCursorRes) GetResult 

func (m *ReplicationCursorRes) GetResult() isReplicationCursorRes_Result

func (*ReplicationCursorRes) ProtoMessage 

func (*ReplicationCursorRes) ProtoMessage()

func (*ReplicationCursorRes) Reset 

func (m *ReplicationCursorRes) Reset()

func (*ReplicationCursorRes) String 

func (m *ReplicationCursorRes) String() string

func (*ReplicationCursorRes) XXX_DiscardUnknown 

func (m *ReplicationCursorRes) XXX_DiscardUnknown()

func (*ReplicationCursorRes) XXX_Marshal 

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

func (*ReplicationCursorRes) XXX_Merge 

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

func (*ReplicationCursorRes) XXX_OneofFuncs 

func (*ReplicationCursorRes) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ReplicationCursorRes) XXX_Size 

func (m *ReplicationCursorRes) XXX_Size() int

func (*ReplicationCursorRes) XXX_Unmarshal 

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

type ReplicationCursorRes_Guid 

type ReplicationCursorRes_Guid struct {
	Guid uint64 `protobuf:"varint,1,opt,name=Guid,proto3,oneof"`
}

type ReplicationCursorRes_Notexist 

type ReplicationCursorRes_Notexist struct {
	Notexist bool `protobuf:"varint,2,opt,name=Notexist,proto3,oneof"`
}

type ReplicationServer 

type ReplicationServer interface {
	Ping(context.Context, *PingReq) (*PingRes, error)
	ListFilesystems(context.Context, *ListFilesystemReq) (*ListFilesystemRes, error)
	ListFilesystemVersions(context.Context, *ListFilesystemVersionsReq) (*ListFilesystemVersionsRes, error)
	DestroySnapshots(context.Context, *DestroySnapshotsReq) (*DestroySnapshotsRes, error)
	ReplicationCursor(context.Context, *ReplicationCursorReq) (*ReplicationCursorRes, error)
}

ReplicationServer is the server API for Replication service.

type SendReq 

type SendReq struct {
	Filesystem string `protobuf:"bytes,1,opt,name=Filesystem,proto3" json:"Filesystem,omitempty"`
	From       string `protobuf:"bytes,2,opt,name=From,proto3" json:"From,omitempty"`
	// May be empty / null to request a full transfer of From
	To string `protobuf:"bytes,3,opt,name=To,proto3" json:"To,omitempty"`
	// If ResumeToken is not empty, the resume token that CAN be tried for 'zfs send' by the sender.
	// The sender MUST indicate in SendRes.UsedResumeToken
	// If it does not work, the sender SHOULD clear the resume token on their side
	// and use From and To instead
	// If ResumeToken is not empty, the GUIDs of From and To
	// MUST correspond to those encoded in the ResumeToken.
	// Otherwise, the Sender MUST return an error.
	ResumeToken          string   `protobuf:"bytes,4,opt,name=ResumeToken,proto3" json:"ResumeToken,omitempty"`
	Compress             bool     `protobuf:"varint,5,opt,name=Compress,proto3" json:"Compress,omitempty"`
	Dedup                bool     `protobuf:"varint,6,opt,name=Dedup,proto3" json:"Dedup,omitempty"`
	DryRun               bool     `protobuf:"varint,7,opt,name=DryRun,proto3" json:"DryRun,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendReq) Descriptor 

func (*SendReq) 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

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.