wire

package
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 

type PeerServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	ObjectPut(Peer_ObjectPutServer) error
	ObjectGet(*ObjectGetRequest, Peer_ObjectGetServer) error
	VolumeConnect(context.Context, *VolumeConnectRequest) (*VolumeConnectResponse, error)
	VolumeSyncPull(*VolumeSyncPullRequest, Peer_VolumeSyncPullServer) error
}

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) ObjectGet(req *ObjectGetRequest, srv Peer_ObjectGetServer) error

func (*UnimplementedPeerServer) ObjectPut 

func (*UnimplementedPeerServer) ObjectPut(srv Peer_ObjectPutServer) error

func (*UnimplementedPeerServer) Ping 

func (*UnimplementedPeerServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error)

func (*UnimplementedPeerServer) VolumeConnect 

func (*UnimplementedPeerServer) VolumeConnect(ctx context.Context, req *VolumeConnectRequest) (*VolumeConnectResponse, error)

func (*UnimplementedPeerServer) VolumeSyncPull 

func (*UnimplementedPeerServer) VolumeSyncPull(req *VolumeSyncPullRequest, srv Peer_VolumeSyncPullServer) error

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 (m *VolumeSyncPullItem) GetError() VolumeSyncPullItem_Error

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

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.