wire

package
Version: v0.0.0-...-810cf82 Latest Latest
Warning

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

Go to latest
Published: Dec 29, 2019 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var VolumeSyncPullItem_Error_name = map[int32]string{
	0: "SUCCESS",
	1: "NOT_A_DIRECTORY",
}
View Source
var VolumeSyncPullItem_Error_value = map[string]int32{
	"SUCCESS":         0,
	"NOT_A_DIRECTORY": 1,
}

Functions

func RegisterPeerServer

func RegisterPeerServer(s *grpc.Server, srv PeerServer)

Types

type Dir

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

func (*Dir) Descriptor

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

func (*Dir) ProtoMessage

func (*Dir) ProtoMessage()

func (*Dir) Reset

func (m *Dir) Reset()

func (*Dir) String

func (m *Dir) String() string

func (*Dir) XXX_DiscardUnknown

func (m *Dir) XXX_DiscardUnknown()

func (*Dir) XXX_Marshal

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

func (*Dir) XXX_Merge

func (m *Dir) XXX_Merge(src proto.Message)

func (*Dir) XXX_Size

func (m *Dir) XXX_Size() int

func (*Dir) XXX_Unmarshal

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

type Dirent

type Dirent struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Type:
	//	*Dirent_File
	//	*Dirent_Dir
	//	*Dirent_Tombstone
	Type                 isDirent_Type `protobuf_oneof:"type"`
	Clock                []byte        `protobuf:"bytes,4,opt,name=clock,proto3" json:"clock,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Dirent) Descriptor

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

func (*Dirent) GetClock

func (m *Dirent) GetClock() []byte

func (*Dirent) GetDir

func (m *Dirent) GetDir() *Dir

func (*Dirent) GetFile

func (m *Dirent) GetFile() *File

func (*Dirent) GetName

func (m *Dirent) GetName() string

func (*Dirent) GetTombstone

func (m *Dirent) GetTombstone() *Tombstone

func (*Dirent) GetType

func (m *Dirent) GetType() isDirent_Type

func (*Dirent) ProtoMessage

func (*Dirent) ProtoMessage()

func (*Dirent) Reset

func (m *Dirent) Reset()

func (*Dirent) String

func (m *Dirent) String() string

func (*Dirent) XXX_DiscardUnknown

func (m *Dirent) XXX_DiscardUnknown()

func (*Dirent) XXX_Marshal

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

func (*Dirent) XXX_Merge

func (m *Dirent) XXX_Merge(src proto.Message)

func (*Dirent) XXX_OneofWrappers

func (*Dirent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Dirent) XXX_Size

func (m *Dirent) XXX_Size() int

func (*Dirent) XXX_Unmarshal

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

type Dirent_Dir

type Dirent_Dir struct {
	Dir *Dir `protobuf:"bytes,3,opt,name=dir,proto3,oneof"`
}

type Dirent_File

type Dirent_File struct {
	File *File `protobuf:"bytes,2,opt,name=file,proto3,oneof"`
}

type Dirent_Tombstone

type Dirent_Tombstone struct {
	Tombstone *Tombstone `protobuf:"bytes,5,opt,name=tombstone,proto3,oneof"`
}

type File

type File struct {
	Manifest             *wire.Manifest `protobuf:"bytes,1,opt,name=manifest,proto3" json:"manifest,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*File) Descriptor

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

func (*File) GetManifest

func (m *File) GetManifest() *wire.Manifest

func (*File) ProtoMessage

func (*File) ProtoMessage()

func (*File) Reset

func (m *File) Reset()

func (*File) String

func (m *File) String() string

func (*File) XXX_DiscardUnknown

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal

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

func (*File) XXX_Merge

func (m *File) XXX_Merge(src proto.Message)

func (*File) XXX_Size

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal

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

type ObjectGetRequest

type ObjectGetRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObjectGetRequest) Descriptor

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

func (*ObjectGetRequest) GetKey

func (m *ObjectGetRequest) GetKey() []byte

func (*ObjectGetRequest) ProtoMessage

func (*ObjectGetRequest) ProtoMessage()

func (*ObjectGetRequest) Reset

func (m *ObjectGetRequest) Reset()

func (*ObjectGetRequest) String

func (m *ObjectGetRequest) String() string

func (*ObjectGetRequest) XXX_DiscardUnknown

func (m *ObjectGetRequest) XXX_DiscardUnknown()

func (*ObjectGetRequest) XXX_Marshal

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

func (*ObjectGetRequest) XXX_Merge

func (m *ObjectGetRequest) XXX_Merge(src proto.Message)

func (*ObjectGetRequest) XXX_Size

func (m *ObjectGetRequest) XXX_Size() int

func (*ObjectGetRequest) XXX_Unmarshal

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

type ObjectGetResponse

type ObjectGetResponse struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObjectGetResponse) Descriptor

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

func (*ObjectGetResponse) GetData

func (m *ObjectGetResponse) GetData() []byte

func (*ObjectGetResponse) ProtoMessage

func (*ObjectGetResponse) ProtoMessage()

func (*ObjectGetResponse) Reset

func (m *ObjectGetResponse) Reset()

func (*ObjectGetResponse) String

func (m *ObjectGetResponse) String() string

func (*ObjectGetResponse) XXX_DiscardUnknown

func (m *ObjectGetResponse) XXX_DiscardUnknown()

func (*ObjectGetResponse) XXX_Marshal

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

func (*ObjectGetResponse) XXX_Merge

func (m *ObjectGetResponse) XXX_Merge(src proto.Message)

func (*ObjectGetResponse) XXX_Size

func (m *ObjectGetResponse) XXX_Size() int

func (*ObjectGetResponse) XXX_Unmarshal

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

type ObjectPutRequest

type ObjectPutRequest struct {
	// Only set in the first streamed message.
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObjectPutRequest) Descriptor

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

func (*ObjectPutRequest) GetData

func (m *ObjectPutRequest) GetData() []byte

func (*ObjectPutRequest) GetKey

func (m *ObjectPutRequest) GetKey() []byte

func (*ObjectPutRequest) ProtoMessage

func (*ObjectPutRequest) ProtoMessage()

func (*ObjectPutRequest) Reset

func (m *ObjectPutRequest) Reset()

func (*ObjectPutRequest) String

func (m *ObjectPutRequest) String() string

func (*ObjectPutRequest) XXX_DiscardUnknown

func (m *ObjectPutRequest) XXX_DiscardUnknown()

func (*ObjectPutRequest) XXX_Marshal

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

func (*ObjectPutRequest) XXX_Merge

func (m *ObjectPutRequest) XXX_Merge(src proto.Message)

func (*ObjectPutRequest) XXX_Size

func (m *ObjectPutRequest) XXX_Size() int

func (*ObjectPutRequest) XXX_Unmarshal

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

type ObjectPutResponse

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

func (*ObjectPutResponse) Descriptor

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

func (*ObjectPutResponse) ProtoMessage

func (*ObjectPutResponse) ProtoMessage()

func (*ObjectPutResponse) Reset

func (m *ObjectPutResponse) Reset()

func (*ObjectPutResponse) String

func (m *ObjectPutResponse) String() string

func (*ObjectPutResponse) XXX_DiscardUnknown

func (m *ObjectPutResponse) XXX_DiscardUnknown()

func (*ObjectPutResponse) XXX_Marshal

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

func (*ObjectPutResponse) XXX_Merge

func (m *ObjectPutResponse) XXX_Merge(src proto.Message)

func (*ObjectPutResponse) XXX_Size

func (m *ObjectPutResponse) XXX_Size() int

func (*ObjectPutResponse) XXX_Unmarshal

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

type PeerClient

type PeerClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	ObjectPut(ctx context.Context, opts ...grpc.CallOption) (Peer_ObjectPutClient, error)
	ObjectGet(ctx context.Context, in *ObjectGetRequest, opts ...grpc.CallOption) (Peer_ObjectGetClient, error)
	VolumeConnect(ctx context.Context, in *VolumeConnectRequest, opts ...grpc.CallOption) (*VolumeConnectResponse, error)
	VolumeSyncPull(ctx context.Context, in *VolumeSyncPullRequest, opts ...grpc.CallOption) (Peer_VolumeSyncPullClient, error)
}

PeerClient is the client API for Peer service.

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

func NewPeerClient

func NewPeerClient(cc *grpc.ClientConn) PeerClient

type PeerServer

PeerServer is the server API for Peer service.

type Peer_ObjectGetClient

type Peer_ObjectGetClient interface {
	Recv() (*ObjectGetResponse, error)
	grpc.ClientStream
}

type Peer_ObjectGetServer

type Peer_ObjectGetServer interface {
	Send(*ObjectGetResponse) error
	grpc.ServerStream
}

type Peer_ObjectPutClient

type Peer_ObjectPutClient interface {
	Send(*ObjectPutRequest) error
	CloseAndRecv() (*ObjectPutResponse, error)
	grpc.ClientStream
}

type Peer_ObjectPutServer

type Peer_ObjectPutServer interface {
	SendAndClose(*ObjectPutResponse) error
	Recv() (*ObjectPutRequest, error)
	grpc.ServerStream
}

type Peer_VolumeSyncPullClient

type Peer_VolumeSyncPullClient interface {
	Recv() (*VolumeSyncPullItem, error)
	grpc.ClientStream
}

type Peer_VolumeSyncPullServer

type Peer_VolumeSyncPullServer interface {
	Send(*VolumeSyncPullItem) error
	grpc.ServerStream
}

type PingRequest

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

func (*PingRequest) Descriptor

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

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset

func (m *PingRequest) Reset()

func (*PingRequest) String

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal

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

func (*PingRequest) XXX_Merge

func (m *PingRequest) XXX_Merge(src proto.Message)

func (*PingRequest) XXX_Size

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal

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

type PingResponse

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

func (*PingResponse) Descriptor

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

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset

func (m *PingResponse) Reset()

func (*PingResponse) String

func (m *PingResponse) String() string

func (*PingResponse) XXX_DiscardUnknown

func (m *PingResponse) XXX_DiscardUnknown()

func (*PingResponse) XXX_Marshal

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

func (*PingResponse) XXX_Merge

func (m *PingResponse) XXX_Merge(src proto.Message)

func (*PingResponse) XXX_Size

func (m *PingResponse) XXX_Size() int

func (*PingResponse) XXX_Unmarshal

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

type Tombstone

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

func (*Tombstone) Descriptor

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

func (*Tombstone) ProtoMessage

func (*Tombstone) ProtoMessage()

func (*Tombstone) Reset

func (m *Tombstone) Reset()

func (*Tombstone) String

func (m *Tombstone) String() string

func (*Tombstone) XXX_DiscardUnknown

func (m *Tombstone) XXX_DiscardUnknown()

func (*Tombstone) XXX_Marshal

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

func (*Tombstone) XXX_Merge

func (m *Tombstone) XXX_Merge(src proto.Message)

func (*Tombstone) XXX_Size

func (m *Tombstone) XXX_Size() int

func (*Tombstone) XXX_Unmarshal

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

type UnimplementedPeerServer

type UnimplementedPeerServer struct {
}

UnimplementedPeerServer can be embedded to have forward compatible implementations.

func (*UnimplementedPeerServer) ObjectGet

func (*UnimplementedPeerServer) ObjectPut

func (*UnimplementedPeerServer) Ping

func (*UnimplementedPeerServer) VolumeConnect

func (*UnimplementedPeerServer) VolumeSyncPull

type VolumeConnectRequest

type VolumeConnectRequest struct {
	VolumeName           string   `protobuf:"bytes,1,opt,name=volumeName,proto3" json:"volumeName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeConnectRequest) Descriptor

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

func (*VolumeConnectRequest) GetVolumeName

func (m *VolumeConnectRequest) GetVolumeName() string

func (*VolumeConnectRequest) ProtoMessage

func (*VolumeConnectRequest) ProtoMessage()

func (*VolumeConnectRequest) Reset

func (m *VolumeConnectRequest) Reset()

func (*VolumeConnectRequest) String

func (m *VolumeConnectRequest) String() string

func (*VolumeConnectRequest) XXX_DiscardUnknown

func (m *VolumeConnectRequest) XXX_DiscardUnknown()

func (*VolumeConnectRequest) XXX_Marshal

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

func (*VolumeConnectRequest) XXX_Merge

func (m *VolumeConnectRequest) XXX_Merge(src proto.Message)

func (*VolumeConnectRequest) XXX_Size

func (m *VolumeConnectRequest) XXX_Size() int

func (*VolumeConnectRequest) XXX_Unmarshal

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

type VolumeConnectResponse

type VolumeConnectResponse struct {
	VolumeID             []byte   `protobuf:"bytes,1,opt,name=volumeID,proto3" json:"volumeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeConnectResponse) Descriptor

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

func (*VolumeConnectResponse) GetVolumeID

func (m *VolumeConnectResponse) GetVolumeID() []byte

func (*VolumeConnectResponse) ProtoMessage

func (*VolumeConnectResponse) ProtoMessage()

func (*VolumeConnectResponse) Reset

func (m *VolumeConnectResponse) Reset()

func (*VolumeConnectResponse) String

func (m *VolumeConnectResponse) String() string

func (*VolumeConnectResponse) XXX_DiscardUnknown

func (m *VolumeConnectResponse) XXX_DiscardUnknown()

func (*VolumeConnectResponse) XXX_Marshal

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

func (*VolumeConnectResponse) XXX_Merge

func (m *VolumeConnectResponse) XXX_Merge(src proto.Message)

func (*VolumeConnectResponse) XXX_Size

func (m *VolumeConnectResponse) XXX_Size() int

func (*VolumeConnectResponse) XXX_Unmarshal

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

type VolumeSyncPullItem

type VolumeSyncPullItem struct {
	// This is used to work around gRPC fixed error codes and error
	// strings.
	//
	// It can only be present in the first streamed message.
	// All other fields are to be ignored.
	Error VolumeSyncPullItem_Error `protobuf:"varint,1,opt,name=error,proto3,enum=bazil.peer.VolumeSyncPullItem_Error" json:"error,omitempty"`
	// Logical clocks in Dirents use small integers to identify peers.
	// This map connects those identifiers to globally unique peer
	// public keys.
	//
	// This can only be present in the first streamed message.
	Peers map[uint32][]byte `` /* 152-byte string literal not displayed */
	// Logical clock for the directory itself.
	//
	// This can only be present in the first streamed message.
	DirClock []byte `protobuf:"bytes,4,opt,name=dirClock,proto3" json:"dirClock,omitempty"`
	// Directory entries. More entries may follow in later streamed
	// messages. The entries are required to be in lexicographical
	// (bytewise) order, across all messages.
	Children             []*Dirent `protobuf:"bytes,3,rep,name=children,proto3" json:"children,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*VolumeSyncPullItem) Descriptor

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

func (*VolumeSyncPullItem) GetChildren

func (m *VolumeSyncPullItem) GetChildren() []*Dirent

func (*VolumeSyncPullItem) GetDirClock

func (m *VolumeSyncPullItem) GetDirClock() []byte

func (*VolumeSyncPullItem) GetError

func (*VolumeSyncPullItem) GetPeers

func (m *VolumeSyncPullItem) GetPeers() map[uint32][]byte

func (*VolumeSyncPullItem) ProtoMessage

func (*VolumeSyncPullItem) ProtoMessage()

func (*VolumeSyncPullItem) Reset

func (m *VolumeSyncPullItem) Reset()

func (*VolumeSyncPullItem) String

func (m *VolumeSyncPullItem) String() string

func (*VolumeSyncPullItem) XXX_DiscardUnknown

func (m *VolumeSyncPullItem) XXX_DiscardUnknown()

func (*VolumeSyncPullItem) XXX_Marshal

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

func (*VolumeSyncPullItem) XXX_Merge

func (m *VolumeSyncPullItem) XXX_Merge(src proto.Message)

func (*VolumeSyncPullItem) XXX_Size

func (m *VolumeSyncPullItem) XXX_Size() int

func (*VolumeSyncPullItem) XXX_Unmarshal

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

type VolumeSyncPullItem_Error

type VolumeSyncPullItem_Error int32
const (
	VolumeSyncPullItem_SUCCESS VolumeSyncPullItem_Error = 0
	// The path in the request did not refer to a directory.
	VolumeSyncPullItem_NOT_A_DIRECTORY VolumeSyncPullItem_Error = 1
)

func (VolumeSyncPullItem_Error) EnumDescriptor

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

func (VolumeSyncPullItem_Error) String

func (x VolumeSyncPullItem_Error) String() string

type VolumeSyncPullRequest

type VolumeSyncPullRequest struct {
	VolumeID             []byte   `protobuf:"bytes,1,opt,name=volumeID,proto3" json:"volumeID,omitempty"`
	Path                 string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeSyncPullRequest) Descriptor

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

func (*VolumeSyncPullRequest) GetPath

func (m *VolumeSyncPullRequest) GetPath() string

func (*VolumeSyncPullRequest) GetVolumeID

func (m *VolumeSyncPullRequest) GetVolumeID() []byte

func (*VolumeSyncPullRequest) ProtoMessage

func (*VolumeSyncPullRequest) ProtoMessage()

func (*VolumeSyncPullRequest) Reset

func (m *VolumeSyncPullRequest) Reset()

func (*VolumeSyncPullRequest) String

func (m *VolumeSyncPullRequest) String() string

func (*VolumeSyncPullRequest) XXX_DiscardUnknown

func (m *VolumeSyncPullRequest) XXX_DiscardUnknown()

func (*VolumeSyncPullRequest) XXX_Marshal

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

func (*VolumeSyncPullRequest) XXX_Merge

func (m *VolumeSyncPullRequest) XXX_Merge(src proto.Message)

func (*VolumeSyncPullRequest) XXX_Size

func (m *VolumeSyncPullRequest) XXX_Size() int

func (*VolumeSyncPullRequest) XXX_Unmarshal

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

Source Files

Jump to

Keyboard shortcuts

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