seaweedrpc

package
v0.1.9 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2021 License: CC0-1.0, CC0-1.0, CC0-1.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSeaweedFilerServer 

func RegisterSeaweedFilerServer(s *grpc.Server, srv SeaweedFilerServer)

Types

type AppendToEntryRequest 

type AppendToEntryRequest struct {
	Directory            string       `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	EntryName            string       `protobuf:"bytes,2,opt,name=entry_name,json=entryName,proto3" json:"entry_name,omitempty"`
	Chunks               []*FileChunk `protobuf:"bytes,3,rep,name=chunks,proto3" json:"chunks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*AppendToEntryRequest) Descriptor 

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

func (*AppendToEntryRequest) GetChunks 

func (m *AppendToEntryRequest) GetChunks() []*FileChunk

func (*AppendToEntryRequest) GetDirectory 

func (m *AppendToEntryRequest) GetDirectory() string

func (*AppendToEntryRequest) GetEntryName 

func (m *AppendToEntryRequest) GetEntryName() string

func (*AppendToEntryRequest) ProtoMessage 

func (*AppendToEntryRequest) ProtoMessage()

func (*AppendToEntryRequest) Reset 

func (m *AppendToEntryRequest) Reset()

func (*AppendToEntryRequest) String 

func (m *AppendToEntryRequest) String() string

func (*AppendToEntryRequest) XXX_DiscardUnknown 

func (m *AppendToEntryRequest) XXX_DiscardUnknown()

func (*AppendToEntryRequest) XXX_Marshal 

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

func (*AppendToEntryRequest) XXX_Merge 

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

func (*AppendToEntryRequest) XXX_Size 

func (m *AppendToEntryRequest) XXX_Size() int

func (*AppendToEntryRequest) XXX_Unmarshal 

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

type AppendToEntryResponse 

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

func (*AppendToEntryResponse) Descriptor 

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

func (*AppendToEntryResponse) ProtoMessage 

func (*AppendToEntryResponse) ProtoMessage()

func (*AppendToEntryResponse) Reset 

func (m *AppendToEntryResponse) Reset()

func (*AppendToEntryResponse) String 

func (m *AppendToEntryResponse) String() string

func (*AppendToEntryResponse) XXX_DiscardUnknown 

func (m *AppendToEntryResponse) XXX_DiscardUnknown()

func (*AppendToEntryResponse) XXX_Marshal 

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

func (*AppendToEntryResponse) XXX_Merge 

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

func (*AppendToEntryResponse) XXX_Size 

func (m *AppendToEntryResponse) XXX_Size() int

func (*AppendToEntryResponse) XXX_Unmarshal 

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

type AssignVolumeRequest 

type AssignVolumeRequest struct {
	Count                int32    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Collection           string   `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Replication          string   `protobuf:"bytes,3,opt,name=replication,proto3" json:"replication,omitempty"`
	TtlSec               int32    `protobuf:"varint,4,opt,name=ttl_sec,json=ttlSec,proto3" json:"ttl_sec,omitempty"`
	DataCenter           string   `protobuf:"bytes,5,opt,name=data_center,json=dataCenter,proto3" json:"data_center,omitempty"`
	ParentPath           string   `protobuf:"bytes,6,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AssignVolumeRequest) Descriptor 

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

func (*AssignVolumeRequest) GetCollection 

func (m *AssignVolumeRequest) GetCollection() string

func (*AssignVolumeRequest) GetCount 

func (m *AssignVolumeRequest) GetCount() int32

func (*AssignVolumeRequest) GetDataCenter 

func (m *AssignVolumeRequest) GetDataCenter() string

func (*AssignVolumeRequest) GetParentPath 

func (m *AssignVolumeRequest) GetParentPath() string

func (*AssignVolumeRequest) GetReplication 

func (m *AssignVolumeRequest) GetReplication() string

func (*AssignVolumeRequest) GetTtlSec 

func (m *AssignVolumeRequest) GetTtlSec() int32

func (*AssignVolumeRequest) ProtoMessage 

func (*AssignVolumeRequest) ProtoMessage()

func (*AssignVolumeRequest) Reset 

func (m *AssignVolumeRequest) Reset()

func (*AssignVolumeRequest) String 

func (m *AssignVolumeRequest) String() string

func (*AssignVolumeRequest) XXX_DiscardUnknown 

func (m *AssignVolumeRequest) XXX_DiscardUnknown()

func (*AssignVolumeRequest) XXX_Marshal 

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

func (*AssignVolumeRequest) XXX_Merge 

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

func (*AssignVolumeRequest) XXX_Size 

func (m *AssignVolumeRequest) XXX_Size() int

func (*AssignVolumeRequest) XXX_Unmarshal 

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

type AssignVolumeResponse 

type AssignVolumeResponse struct {
	FileId               string   `protobuf:"bytes,1,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"`
	Url                  string   `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	PublicUrl            string   `protobuf:"bytes,3,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"`
	Count                int32    `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	Auth                 string   `protobuf:"bytes,5,opt,name=auth,proto3" json:"auth,omitempty"`
	Collection           string   `protobuf:"bytes,6,opt,name=collection,proto3" json:"collection,omitempty"`
	Replication          string   `protobuf:"bytes,7,opt,name=replication,proto3" json:"replication,omitempty"`
	Error                string   `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AssignVolumeResponse) Descriptor 

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

func (*AssignVolumeResponse) GetAuth 

func (m *AssignVolumeResponse) GetAuth() string

func (*AssignVolumeResponse) GetCollection 

func (m *AssignVolumeResponse) GetCollection() string

func (*AssignVolumeResponse) GetCount 

func (m *AssignVolumeResponse) GetCount() int32

func (*AssignVolumeResponse) GetError 

func (m *AssignVolumeResponse) GetError() string

func (*AssignVolumeResponse) GetFileId 

func (m *AssignVolumeResponse) GetFileId() string

func (*AssignVolumeResponse) GetPublicUrl 

func (m *AssignVolumeResponse) GetPublicUrl() string

func (*AssignVolumeResponse) GetReplication 

func (m *AssignVolumeResponse) GetReplication() string

func (*AssignVolumeResponse) GetUrl 

func (m *AssignVolumeResponse) GetUrl() string

func (*AssignVolumeResponse) ProtoMessage 

func (*AssignVolumeResponse) ProtoMessage()

func (*AssignVolumeResponse) Reset 

func (m *AssignVolumeResponse) Reset()

func (*AssignVolumeResponse) String 

func (m *AssignVolumeResponse) String() string

func (*AssignVolumeResponse) XXX_DiscardUnknown 

func (m *AssignVolumeResponse) XXX_DiscardUnknown()

func (*AssignVolumeResponse) XXX_Marshal 

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

func (*AssignVolumeResponse) XXX_Merge 

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

func (*AssignVolumeResponse) XXX_Size 

func (m *AssignVolumeResponse) XXX_Size() int

func (*AssignVolumeResponse) XXX_Unmarshal 

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

type AtomicRenameEntryRequest 

type AtomicRenameEntryRequest struct {
	OldDirectory         string   `protobuf:"bytes,1,opt,name=old_directory,json=oldDirectory,proto3" json:"old_directory,omitempty"`
	OldName              string   `protobuf:"bytes,2,opt,name=old_name,json=oldName,proto3" json:"old_name,omitempty"`
	NewDirectory         string   `protobuf:"bytes,3,opt,name=new_directory,json=newDirectory,proto3" json:"new_directory,omitempty"`
	NewName              string   `protobuf:"bytes,4,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AtomicRenameEntryRequest) Descriptor 

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

func (*AtomicRenameEntryRequest) GetNewDirectory 

func (m *AtomicRenameEntryRequest) GetNewDirectory() string

func (*AtomicRenameEntryRequest) GetNewName 

func (m *AtomicRenameEntryRequest) GetNewName() string

func (*AtomicRenameEntryRequest) GetOldDirectory 

func (m *AtomicRenameEntryRequest) GetOldDirectory() string

func (*AtomicRenameEntryRequest) GetOldName 

func (m *AtomicRenameEntryRequest) GetOldName() string

func (*AtomicRenameEntryRequest) ProtoMessage 

func (*AtomicRenameEntryRequest) ProtoMessage()

func (*AtomicRenameEntryRequest) Reset 

func (m *AtomicRenameEntryRequest) Reset()

func (*AtomicRenameEntryRequest) String 

func (m *AtomicRenameEntryRequest) String() string

func (*AtomicRenameEntryRequest) XXX_DiscardUnknown 

func (m *AtomicRenameEntryRequest) XXX_DiscardUnknown()

func (*AtomicRenameEntryRequest) XXX_Marshal 

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

func (*AtomicRenameEntryRequest) XXX_Merge 

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

func (*AtomicRenameEntryRequest) XXX_Size 

func (m *AtomicRenameEntryRequest) XXX_Size() int

func (*AtomicRenameEntryRequest) XXX_Unmarshal 

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

type AtomicRenameEntryResponse 

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

func (*AtomicRenameEntryResponse) Descriptor 

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

func (*AtomicRenameEntryResponse) ProtoMessage 

func (*AtomicRenameEntryResponse) ProtoMessage()

func (*AtomicRenameEntryResponse) Reset 

func (m *AtomicRenameEntryResponse) Reset()

func (*AtomicRenameEntryResponse) String 

func (m *AtomicRenameEntryResponse) String() string

func (*AtomicRenameEntryResponse) XXX_DiscardUnknown 

func (m *AtomicRenameEntryResponse) XXX_DiscardUnknown()

func (*AtomicRenameEntryResponse) XXX_Marshal 

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

func (*AtomicRenameEntryResponse) XXX_Merge 

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

func (*AtomicRenameEntryResponse) XXX_Size 

func (m *AtomicRenameEntryResponse) XXX_Size() int

func (*AtomicRenameEntryResponse) XXX_Unmarshal 

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

type CreateEntryRequest 

type CreateEntryRequest struct {
	Directory            string   `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	Entry                *Entry   `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
	OExcl                bool     `protobuf:"varint,3,opt,name=o_excl,json=oExcl,proto3" json:"o_excl,omitempty"`
	IsFromOtherCluster   bool     `protobuf:"varint,4,opt,name=is_from_other_cluster,json=isFromOtherCluster,proto3" json:"is_from_other_cluster,omitempty"`
	Signatures           []int32  `protobuf:"varint,5,rep,packed,name=signatures,proto3" json:"signatures,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateEntryRequest) Descriptor 

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

func (*CreateEntryRequest) GetDirectory 

func (m *CreateEntryRequest) GetDirectory() string

func (*CreateEntryRequest) GetEntry 

func (m *CreateEntryRequest) GetEntry() *Entry

func (*CreateEntryRequest) GetIsFromOtherCluster 

func (m *CreateEntryRequest) GetIsFromOtherCluster() bool

func (*CreateEntryRequest) GetOExcl 

func (m *CreateEntryRequest) GetOExcl() bool

func (*CreateEntryRequest) GetSignatures 

func (m *CreateEntryRequest) GetSignatures() []int32

func (*CreateEntryRequest) ProtoMessage 

func (*CreateEntryRequest) ProtoMessage()

func (*CreateEntryRequest) Reset 

func (m *CreateEntryRequest) Reset()

func (*CreateEntryRequest) String 

func (m *CreateEntryRequest) String() string

func (*CreateEntryRequest) XXX_DiscardUnknown 

func (m *CreateEntryRequest) XXX_DiscardUnknown()

func (*CreateEntryRequest) XXX_Marshal 

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

func (*CreateEntryRequest) XXX_Merge 

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

func (*CreateEntryRequest) XXX_Size 

func (m *CreateEntryRequest) XXX_Size() int

func (*CreateEntryRequest) XXX_Unmarshal 

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

type CreateEntryResponse 

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

func (*CreateEntryResponse) Descriptor 

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

func (*CreateEntryResponse) GetError 

func (m *CreateEntryResponse) GetError() string

func (*CreateEntryResponse) ProtoMessage 

func (*CreateEntryResponse) ProtoMessage()

func (*CreateEntryResponse) Reset 

func (m *CreateEntryResponse) Reset()

func (*CreateEntryResponse) String 

func (m *CreateEntryResponse) String() string

func (*CreateEntryResponse) XXX_DiscardUnknown 

func (m *CreateEntryResponse) XXX_DiscardUnknown()

func (*CreateEntryResponse) XXX_Marshal 

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

func (*CreateEntryResponse) XXX_Merge 

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

func (*CreateEntryResponse) XXX_Size 

func (m *CreateEntryResponse) XXX_Size() int

func (*CreateEntryResponse) XXX_Unmarshal 

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

type DeleteCollectionRequest 

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

func (*DeleteCollectionRequest) Descriptor 

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

func (*DeleteCollectionRequest) GetCollection 

func (m *DeleteCollectionRequest) GetCollection() string

func (*DeleteCollectionRequest) ProtoMessage 

func (*DeleteCollectionRequest) ProtoMessage()

func (*DeleteCollectionRequest) Reset 

func (m *DeleteCollectionRequest) Reset()

func (*DeleteCollectionRequest) String 

func (m *DeleteCollectionRequest) String() string

func (*DeleteCollectionRequest) XXX_DiscardUnknown 

func (m *DeleteCollectionRequest) XXX_DiscardUnknown()

func (*DeleteCollectionRequest) XXX_Marshal 

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

func (*DeleteCollectionRequest) XXX_Merge 

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

func (*DeleteCollectionRequest) XXX_Size 

func (m *DeleteCollectionRequest) XXX_Size() int

func (*DeleteCollectionRequest) XXX_Unmarshal 

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

type DeleteCollectionResponse 

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

func (*DeleteCollectionResponse) Descriptor 

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

func (*DeleteCollectionResponse) ProtoMessage 

func (*DeleteCollectionResponse) ProtoMessage()

func (*DeleteCollectionResponse) Reset 

func (m *DeleteCollectionResponse) Reset()

func (*DeleteCollectionResponse) String 

func (m *DeleteCollectionResponse) String() string

func (*DeleteCollectionResponse) XXX_DiscardUnknown 

func (m *DeleteCollectionResponse) XXX_DiscardUnknown()

func (*DeleteCollectionResponse) XXX_Marshal 

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

func (*DeleteCollectionResponse) XXX_Merge 

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

func (*DeleteCollectionResponse) XXX_Size 

func (m *DeleteCollectionResponse) XXX_Size() int

func (*DeleteCollectionResponse) XXX_Unmarshal 

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

type DeleteEntryRequest 

type DeleteEntryRequest struct {
	Directory string `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// bool is_directory = 3;
	IsDeleteData         bool     `protobuf:"varint,4,opt,name=is_delete_data,json=isDeleteData,proto3" json:"is_delete_data,omitempty"`
	IsRecursive          bool     `protobuf:"varint,5,opt,name=is_recursive,json=isRecursive,proto3" json:"is_recursive,omitempty"`
	IgnoreRecursiveError bool     `protobuf:"varint,6,opt,name=ignore_recursive_error,json=ignoreRecursiveError,proto3" json:"ignore_recursive_error,omitempty"`
	IsFromOtherCluster   bool     `protobuf:"varint,7,opt,name=is_from_other_cluster,json=isFromOtherCluster,proto3" json:"is_from_other_cluster,omitempty"`
	Signatures           []int32  `protobuf:"varint,8,rep,packed,name=signatures,proto3" json:"signatures,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteEntryRequest) Descriptor 

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

func (*DeleteEntryRequest) GetDirectory 

func (m *DeleteEntryRequest) GetDirectory() string

func (*DeleteEntryRequest) GetIgnoreRecursiveError 

func (m *DeleteEntryRequest) GetIgnoreRecursiveError() bool

func (*DeleteEntryRequest) GetIsDeleteData 

func (m *DeleteEntryRequest) GetIsDeleteData() bool

func (*DeleteEntryRequest) GetIsFromOtherCluster 

func (m *DeleteEntryRequest) GetIsFromOtherCluster() bool

func (*DeleteEntryRequest) GetIsRecursive 

func (m *DeleteEntryRequest) GetIsRecursive() bool

func (*DeleteEntryRequest) GetName 

func (m *DeleteEntryRequest) GetName() string

func (*DeleteEntryRequest) GetSignatures 

func (m *DeleteEntryRequest) GetSignatures() []int32

func (*DeleteEntryRequest) ProtoMessage 

func (*DeleteEntryRequest) ProtoMessage()

func (*DeleteEntryRequest) Reset 

func (m *DeleteEntryRequest) Reset()

func (*DeleteEntryRequest) String 

func (m *DeleteEntryRequest) String() string

func (*DeleteEntryRequest) XXX_DiscardUnknown 

func (m *DeleteEntryRequest) XXX_DiscardUnknown()

func (*DeleteEntryRequest) XXX_Marshal 

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

func (*DeleteEntryRequest) XXX_Merge 

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

func (*DeleteEntryRequest) XXX_Size 

func (m *DeleteEntryRequest) XXX_Size() int

func (*DeleteEntryRequest) XXX_Unmarshal 

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

type DeleteEntryResponse 

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

func (*DeleteEntryResponse) Descriptor 

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

func (*DeleteEntryResponse) GetError 

func (m *DeleteEntryResponse) GetError() string

func (*DeleteEntryResponse) ProtoMessage 

func (*DeleteEntryResponse) ProtoMessage()

func (*DeleteEntryResponse) Reset 

func (m *DeleteEntryResponse) Reset()

func (*DeleteEntryResponse) String 

func (m *DeleteEntryResponse) String() string

func (*DeleteEntryResponse) XXX_DiscardUnknown 

func (m *DeleteEntryResponse) XXX_DiscardUnknown()

func (*DeleteEntryResponse) XXX_Marshal 

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

func (*DeleteEntryResponse) XXX_Merge 

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

func (*DeleteEntryResponse) XXX_Size 

func (m *DeleteEntryResponse) XXX_Size() int

func (*DeleteEntryResponse) XXX_Unmarshal 

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

type Entry 

type Entry struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IsDirectory          bool              `protobuf:"varint,2,opt,name=is_directory,json=isDirectory,proto3" json:"is_directory,omitempty"`
	Chunks               []*FileChunk      `protobuf:"bytes,3,rep,name=chunks,proto3" json:"chunks,omitempty"`
	Attributes           *FuseAttributes   `protobuf:"bytes,4,opt,name=attributes,proto3" json:"attributes,omitempty"`
	Extended             map[string][]byte `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Entry) Descriptor 

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

func (*Entry) GetAttributes 

func (m *Entry) GetAttributes() *FuseAttributes

func (*Entry) GetChunks 

func (m *Entry) GetChunks() []*FileChunk

func (*Entry) GetExtended 

func (m *Entry) GetExtended() map[string][]byte

func (*Entry) GetIsDirectory 

func (m *Entry) GetIsDirectory() bool

func (*Entry) GetName 

func (m *Entry) GetName() string

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) String 

func (m *Entry) String() string

func (*Entry) XXX_DiscardUnknown 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal 

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

func (*Entry) XXX_Merge 

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

func (*Entry) XXX_Size 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal 

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

type EventNotification 

type EventNotification struct {
	OldEntry             *Entry   `protobuf:"bytes,1,opt,name=old_entry,json=oldEntry,proto3" json:"old_entry,omitempty"`
	NewEntry             *Entry   `protobuf:"bytes,2,opt,name=new_entry,json=newEntry,proto3" json:"new_entry,omitempty"`
	DeleteChunks         bool     `protobuf:"varint,3,opt,name=delete_chunks,json=deleteChunks,proto3" json:"delete_chunks,omitempty"`
	NewParentPath        string   `protobuf:"bytes,4,opt,name=new_parent_path,json=newParentPath,proto3" json:"new_parent_path,omitempty"`
	IsFromOtherCluster   bool     `protobuf:"varint,5,opt,name=is_from_other_cluster,json=isFromOtherCluster,proto3" json:"is_from_other_cluster,omitempty"`
	Signatures           []int32  `protobuf:"varint,6,rep,packed,name=signatures,proto3" json:"signatures,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventNotification) Descriptor 

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

func (*EventNotification) GetDeleteChunks 

func (m *EventNotification) GetDeleteChunks() bool

func (*EventNotification) GetIsFromOtherCluster 

func (m *EventNotification) GetIsFromOtherCluster() bool

func (*EventNotification) GetNewEntry 

func (m *EventNotification) GetNewEntry() *Entry

func (*EventNotification) GetNewParentPath 

func (m *EventNotification) GetNewParentPath() string

func (*EventNotification) GetOldEntry 

func (m *EventNotification) GetOldEntry() *Entry

func (*EventNotification) GetSignatures 

func (m *EventNotification) GetSignatures() []int32

func (*EventNotification) ProtoMessage 

func (*EventNotification) ProtoMessage()

func (*EventNotification) Reset 

func (m *EventNotification) Reset()

func (*EventNotification) String 

func (m *EventNotification) String() string

func (*EventNotification) XXX_DiscardUnknown 

func (m *EventNotification) XXX_DiscardUnknown()

func (*EventNotification) XXX_Marshal 

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

func (*EventNotification) XXX_Merge 

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

func (*EventNotification) XXX_Size 

func (m *EventNotification) XXX_Size() int

func (*EventNotification) XXX_Unmarshal 

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

type FileChunk 

type FileChunk struct {
	FileId               string   `protobuf:"bytes,1,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"`
	Offset               int64    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Size                 uint64   `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Mtime                int64    `protobuf:"varint,4,opt,name=mtime,proto3" json:"mtime,omitempty"`
	ETag                 string   `protobuf:"bytes,5,opt,name=e_tag,json=eTag,proto3" json:"e_tag,omitempty"`
	SourceFileId         string   `protobuf:"bytes,6,opt,name=source_file_id,json=sourceFileId,proto3" json:"source_file_id,omitempty"`
	Fid                  *FileId  `protobuf:"bytes,7,opt,name=fid,proto3" json:"fid,omitempty"`
	SourceFid            *FileId  `protobuf:"bytes,8,opt,name=source_fid,json=sourceFid,proto3" json:"source_fid,omitempty"`
	CipherKey            []byte   `protobuf:"bytes,9,opt,name=cipher_key,json=cipherKey,proto3" json:"cipher_key,omitempty"`
	IsCompressed         bool     `protobuf:"varint,10,opt,name=is_compressed,json=isCompressed,proto3" json:"is_compressed,omitempty"`
	IsChunkManifest      bool     `protobuf:"varint,11,opt,name=is_chunk_manifest,json=isChunkManifest,proto3" json:"is_chunk_manifest,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FileChunk) Descriptor 

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

func (*FileChunk) GetCipherKey 

func (m *FileChunk) GetCipherKey() []byte

func (*FileChunk) GetETag 

func (m *FileChunk) GetETag() string

func (*FileChunk) GetFid 

func (m *FileChunk) GetFid() *FileId

func (*FileChunk) GetFileId 

func (m *FileChunk) GetFileId() string

func (*FileChunk) GetIsChunkManifest 

func (m *FileChunk) GetIsChunkManifest() bool

func (*FileChunk) GetIsCompressed 

func (m *FileChunk) GetIsCompressed() bool

func (*FileChunk) GetMtime 

func (m *FileChunk) GetMtime() int64

func (*FileChunk) GetOffset 

func (m *FileChunk) GetOffset() int64

func (*FileChunk) GetSize 

func (m *FileChunk) GetSize() uint64

func (*FileChunk) GetSourceFid 

func (m *FileChunk) GetSourceFid() *FileId

func (*FileChunk) GetSourceFileId 

func (m *FileChunk) GetSourceFileId() string

func (*FileChunk) ProtoMessage 

func (*FileChunk) ProtoMessage()

func (*FileChunk) Reset 

func (m *FileChunk) Reset()

func (*FileChunk) String 

func (m *FileChunk) String() string

func (*FileChunk) XXX_DiscardUnknown 

func (m *FileChunk) XXX_DiscardUnknown()

func (*FileChunk) XXX_Marshal 

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

func (*FileChunk) XXX_Merge 

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

func (*FileChunk) XXX_Size 

func (m *FileChunk) XXX_Size() int

func (*FileChunk) XXX_Unmarshal 

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

type FileChunkManifest 

type FileChunkManifest struct {
	Chunks               []*FileChunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*FileChunkManifest) Descriptor 

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

func (*FileChunkManifest) GetChunks 

func (m *FileChunkManifest) GetChunks() []*FileChunk

func (*FileChunkManifest) ProtoMessage 

func (*FileChunkManifest) ProtoMessage()

func (*FileChunkManifest) Reset 

func (m *FileChunkManifest) Reset()

func (*FileChunkManifest) String 

func (m *FileChunkManifest) String() string

func (*FileChunkManifest) XXX_DiscardUnknown 

func (m *FileChunkManifest) XXX_DiscardUnknown()

func (*FileChunkManifest) XXX_Marshal 

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

func (*FileChunkManifest) XXX_Merge 

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

func (*FileChunkManifest) XXX_Size 

func (m *FileChunkManifest) XXX_Size() int

func (*FileChunkManifest) XXX_Unmarshal 

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

type FileId 

type FileId struct {
	VolumeId             uint32   `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	FileKey              uint64   `protobuf:"varint,2,opt,name=file_key,json=fileKey,proto3" json:"file_key,omitempty"`
	Cookie               uint32   `protobuf:"fixed32,3,opt,name=cookie,proto3" json:"cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FileId) Descriptor 

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

func (*FileId) GetCookie 

func (m *FileId) GetCookie() uint32

func (*FileId) GetFileKey 

func (m *FileId) GetFileKey() uint64

func (*FileId) GetVolumeId 

func (m *FileId) GetVolumeId() uint32

func (*FileId) ProtoMessage 

func (*FileId) ProtoMessage()

func (*FileId) Reset 

func (m *FileId) Reset()

func (*FileId) String 

func (m *FileId) String() string

func (*FileId) XXX_DiscardUnknown 

func (m *FileId) XXX_DiscardUnknown()

func (*FileId) XXX_Marshal 

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

func (*FileId) XXX_Merge 

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

func (*FileId) XXX_Size 

func (m *FileId) XXX_Size() int

func (*FileId) XXX_Unmarshal 

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

type FullEntry 

type FullEntry struct {
	Dir                  string   `protobuf:"bytes,1,opt,name=dir,proto3" json:"dir,omitempty"`
	Entry                *Entry   `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FullEntry) Descriptor 

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

func (*FullEntry) GetDir 

func (m *FullEntry) GetDir() string

func (*FullEntry) GetEntry 

func (m *FullEntry) GetEntry() *Entry

func (*FullEntry) ProtoMessage 

func (*FullEntry) ProtoMessage()

func (*FullEntry) Reset 

func (m *FullEntry) Reset()

func (*FullEntry) String 

func (m *FullEntry) String() string

func (*FullEntry) XXX_DiscardUnknown 

func (m *FullEntry) XXX_DiscardUnknown()

func (*FullEntry) XXX_Marshal 

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

func (*FullEntry) XXX_Merge 

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

func (*FullEntry) XXX_Size 

func (m *FullEntry) XXX_Size() int

func (*FullEntry) XXX_Unmarshal 

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

type FuseAttributes 

type FuseAttributes struct {
	FileSize             uint64   `protobuf:"varint,1,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	Mtime                int64    `protobuf:"varint,2,opt,name=mtime,proto3" json:"mtime,omitempty"`
	FileMode             uint32   `protobuf:"varint,3,opt,name=file_mode,json=fileMode,proto3" json:"file_mode,omitempty"`
	Uid                  uint32   `protobuf:"varint,4,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid                  uint32   `protobuf:"varint,5,opt,name=gid,proto3" json:"gid,omitempty"`
	Crtime               int64    `protobuf:"varint,6,opt,name=crtime,proto3" json:"crtime,omitempty"`
	Mime                 string   `protobuf:"bytes,7,opt,name=mime,proto3" json:"mime,omitempty"`
	Replication          string   `protobuf:"bytes,8,opt,name=replication,proto3" json:"replication,omitempty"`
	Collection           string   `protobuf:"bytes,9,opt,name=collection,proto3" json:"collection,omitempty"`
	TtlSec               int32    `protobuf:"varint,10,opt,name=ttl_sec,json=ttlSec,proto3" json:"ttl_sec,omitempty"`
	UserName             string   `protobuf:"bytes,11,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	GroupName            []string `protobuf:"bytes,12,rep,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	SymlinkTarget        string   `protobuf:"bytes,13,opt,name=symlink_target,json=symlinkTarget,proto3" json:"symlink_target,omitempty"`
	Md5                  []byte   `protobuf:"bytes,14,opt,name=md5,proto3" json:"md5,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FuseAttributes) Descriptor 

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

func (*FuseAttributes) GetCollection 

func (m *FuseAttributes) GetCollection() string

func (*FuseAttributes) GetCrtime 

func (m *FuseAttributes) GetCrtime() int64

func (*FuseAttributes) GetFileMode 

func (m *FuseAttributes) GetFileMode() uint32

func (*FuseAttributes) GetFileSize 

func (m *FuseAttributes) GetFileSize() uint64

func (*FuseAttributes) GetGid 

func (m *FuseAttributes) GetGid() uint32

func (*FuseAttributes) GetGroupName 

func (m *FuseAttributes) GetGroupName() []string

func (*FuseAttributes) GetMd5 

func (m *FuseAttributes) GetMd5() []byte

func (*FuseAttributes) GetMime 

func (m *FuseAttributes) GetMime() string

func (*FuseAttributes) GetMtime 

func (m *FuseAttributes) GetMtime() int64

func (*FuseAttributes) GetReplication 

func (m *FuseAttributes) GetReplication() string

func (*FuseAttributes) GetSymlinkTarget 

func (m *FuseAttributes) GetSymlinkTarget() string

func (*FuseAttributes) GetTtlSec 

func (m *FuseAttributes) GetTtlSec() int32

func (*FuseAttributes) GetUid 

func (m *FuseAttributes) GetUid() uint32

func (*FuseAttributes) GetUserName 

func (m *FuseAttributes) GetUserName() string

func (*FuseAttributes) ProtoMessage 

func (*FuseAttributes) ProtoMessage()

func (*FuseAttributes) Reset 

func (m *FuseAttributes) Reset()

func (*FuseAttributes) String 

func (m *FuseAttributes) String() string

func (*FuseAttributes) XXX_DiscardUnknown 

func (m *FuseAttributes) XXX_DiscardUnknown()

func (*FuseAttributes) XXX_Marshal 

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

func (*FuseAttributes) XXX_Merge 

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

func (*FuseAttributes) XXX_Size 

func (m *FuseAttributes) XXX_Size() int

func (*FuseAttributes) XXX_Unmarshal 

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

type GetFilerConfigurationRequest 

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

func (*GetFilerConfigurationRequest) Descriptor 

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

func (*GetFilerConfigurationRequest) ProtoMessage 

func (*GetFilerConfigurationRequest) ProtoMessage()

func (*GetFilerConfigurationRequest) Reset 

func (m *GetFilerConfigurationRequest) Reset()

func (*GetFilerConfigurationRequest) String 

func (m *GetFilerConfigurationRequest) String() string

func (*GetFilerConfigurationRequest) XXX_DiscardUnknown 

func (m *GetFilerConfigurationRequest) XXX_DiscardUnknown()

func (*GetFilerConfigurationRequest) XXX_Marshal 

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

func (*GetFilerConfigurationRequest) XXX_Merge 

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

func (*GetFilerConfigurationRequest) XXX_Size 

func (m *GetFilerConfigurationRequest) XXX_Size() int

func (*GetFilerConfigurationRequest) XXX_Unmarshal 

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

type GetFilerConfigurationResponse 

type GetFilerConfigurationResponse struct {
	Masters              []string `protobuf:"bytes,1,rep,name=masters,proto3" json:"masters,omitempty"`
	Replication          string   `protobuf:"bytes,2,opt,name=replication,proto3" json:"replication,omitempty"`
	Collection           string   `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"`
	MaxMb                uint32   `protobuf:"varint,4,opt,name=max_mb,json=maxMb,proto3" json:"max_mb,omitempty"`
	DirBuckets           string   `protobuf:"bytes,5,opt,name=dir_buckets,json=dirBuckets,proto3" json:"dir_buckets,omitempty"`
	Cipher               bool     `protobuf:"varint,7,opt,name=cipher,proto3" json:"cipher,omitempty"`
	Signature            int32    `protobuf:"varint,8,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFilerConfigurationResponse) Descriptor 

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

func (*GetFilerConfigurationResponse) GetCipher 

func (m *GetFilerConfigurationResponse) GetCipher() bool

func (*GetFilerConfigurationResponse) GetCollection 

func (m *GetFilerConfigurationResponse) GetCollection() string

func (*GetFilerConfigurationResponse) GetDirBuckets 

func (m *GetFilerConfigurationResponse) GetDirBuckets() string

func (*GetFilerConfigurationResponse) GetMasters 

func (m *GetFilerConfigurationResponse) GetMasters() []string

func (*GetFilerConfigurationResponse) GetMaxMb 

func (m *GetFilerConfigurationResponse) GetMaxMb() uint32

func (*GetFilerConfigurationResponse) GetReplication 

func (m *GetFilerConfigurationResponse) GetReplication() string

func (*GetFilerConfigurationResponse) GetSignature 

func (m *GetFilerConfigurationResponse) GetSignature() int32

func (*GetFilerConfigurationResponse) ProtoMessage 

func (*GetFilerConfigurationResponse) ProtoMessage()

func (*GetFilerConfigurationResponse) Reset 

func (m *GetFilerConfigurationResponse) Reset()

func (*GetFilerConfigurationResponse) String 

func (m *GetFilerConfigurationResponse) String() string

func (*GetFilerConfigurationResponse) XXX_DiscardUnknown 

func (m *GetFilerConfigurationResponse) XXX_DiscardUnknown()

func (*GetFilerConfigurationResponse) XXX_Marshal 

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

func (*GetFilerConfigurationResponse) XXX_Merge 

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

func (*GetFilerConfigurationResponse) XXX_Size 

func (m *GetFilerConfigurationResponse) XXX_Size() int

func (*GetFilerConfigurationResponse) XXX_Unmarshal 

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

type KeepConnectedRequest 

type KeepConnectedRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	GrpcPort             uint32   `protobuf:"varint,2,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
	Resources            []string `protobuf:"bytes,3,rep,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeepConnectedRequest) Descriptor 

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

func (*KeepConnectedRequest) GetGrpcPort 

func (m *KeepConnectedRequest) GetGrpcPort() uint32

func (*KeepConnectedRequest) GetName 

func (m *KeepConnectedRequest) GetName() string

func (*KeepConnectedRequest) GetResources 

func (m *KeepConnectedRequest) GetResources() []string

func (*KeepConnectedRequest) ProtoMessage 

func (*KeepConnectedRequest) ProtoMessage()

func (*KeepConnectedRequest) Reset 

func (m *KeepConnectedRequest) Reset()

func (*KeepConnectedRequest) String 

func (m *KeepConnectedRequest) String() string

func (*KeepConnectedRequest) XXX_DiscardUnknown 

func (m *KeepConnectedRequest) XXX_DiscardUnknown()

func (*KeepConnectedRequest) XXX_Marshal 

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

func (*KeepConnectedRequest) XXX_Merge 

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

func (*KeepConnectedRequest) XXX_Size 

func (m *KeepConnectedRequest) XXX_Size() int

func (*KeepConnectedRequest) XXX_Unmarshal 

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

type KeepConnectedResponse 

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

func (*KeepConnectedResponse) Descriptor 

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

func (*KeepConnectedResponse) ProtoMessage 

func (*KeepConnectedResponse) ProtoMessage()

func (*KeepConnectedResponse) Reset 

func (m *KeepConnectedResponse) Reset()

func (*KeepConnectedResponse) String 

func (m *KeepConnectedResponse) String() string

func (*KeepConnectedResponse) XXX_DiscardUnknown 

func (m *KeepConnectedResponse) XXX_DiscardUnknown()

func (*KeepConnectedResponse) XXX_Marshal 

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

func (*KeepConnectedResponse) XXX_Merge 

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

func (*KeepConnectedResponse) XXX_Size 

func (m *KeepConnectedResponse) XXX_Size() int

func (*KeepConnectedResponse) XXX_Unmarshal 

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

type KvGetRequest 

type KvGetRequest 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:"-"`
}

Key-Value operations

func (*KvGetRequest) Descriptor 

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

func (*KvGetRequest) GetKey 

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

func (*KvGetRequest) ProtoMessage 

func (*KvGetRequest) ProtoMessage()

func (*KvGetRequest) Reset 

func (m *KvGetRequest) Reset()

func (*KvGetRequest) String 

func (m *KvGetRequest) String() string

func (*KvGetRequest) XXX_DiscardUnknown 

func (m *KvGetRequest) XXX_DiscardUnknown()

func (*KvGetRequest) XXX_Marshal 

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

func (*KvGetRequest) XXX_Merge 

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

func (*KvGetRequest) XXX_Size 

func (m *KvGetRequest) XXX_Size() int

func (*KvGetRequest) XXX_Unmarshal 

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

type KvGetResponse 

type KvGetResponse struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,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 (*KvGetResponse) Descriptor 

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

func (*KvGetResponse) GetError 

func (m *KvGetResponse) GetError() string

func (*KvGetResponse) GetValue 

func (m *KvGetResponse) GetValue() []byte

func (*KvGetResponse) ProtoMessage 

func (*KvGetResponse) ProtoMessage()

func (*KvGetResponse) Reset 

func (m *KvGetResponse) Reset()

func (*KvGetResponse) String 

func (m *KvGetResponse) String() string

func (*KvGetResponse) XXX_DiscardUnknown 

func (m *KvGetResponse) XXX_DiscardUnknown()

func (*KvGetResponse) XXX_Marshal 

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

func (*KvGetResponse) XXX_Merge 

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

func (*KvGetResponse) XXX_Size 

func (m *KvGetResponse) XXX_Size() int

func (*KvGetResponse) XXX_Unmarshal 

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

type KvPutRequest 

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

func (*KvPutRequest) Descriptor 

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

func (*KvPutRequest) GetKey 

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

func (*KvPutRequest) GetValue 

func (m *KvPutRequest) GetValue() []byte

func (*KvPutRequest) ProtoMessage 

func (*KvPutRequest) ProtoMessage()

func (*KvPutRequest) Reset 

func (m *KvPutRequest) Reset()

func (*KvPutRequest) String 

func (m *KvPutRequest) String() string

func (*KvPutRequest) XXX_DiscardUnknown 

func (m *KvPutRequest) XXX_DiscardUnknown()

func (*KvPutRequest) XXX_Marshal 

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

func (*KvPutRequest) XXX_Merge 

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

func (*KvPutRequest) XXX_Size 

func (m *KvPutRequest) XXX_Size() int

func (*KvPutRequest) XXX_Unmarshal 

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

type KvPutResponse 

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

func (*KvPutResponse) Descriptor 

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

func (*KvPutResponse) GetError 

func (m *KvPutResponse) GetError() string

func (*KvPutResponse) ProtoMessage 

func (*KvPutResponse) ProtoMessage()

func (*KvPutResponse) Reset 

func (m *KvPutResponse) Reset()

func (*KvPutResponse) String 

func (m *KvPutResponse) String() string

func (*KvPutResponse) XXX_DiscardUnknown 

func (m *KvPutResponse) XXX_DiscardUnknown()

func (*KvPutResponse) XXX_Marshal 

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

func (*KvPutResponse) XXX_Merge 

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

func (*KvPutResponse) XXX_Size 

func (m *KvPutResponse) XXX_Size() int

func (*KvPutResponse) XXX_Unmarshal 

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

type ListEntriesRequest 

type ListEntriesRequest struct {
	Directory            string   `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	Prefix               string   `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	StartFromFileName    string   `protobuf:"bytes,3,opt,name=startFromFileName,proto3" json:"startFromFileName,omitempty"`
	InclusiveStartFrom   bool     `protobuf:"varint,4,opt,name=inclusiveStartFrom,proto3" json:"inclusiveStartFrom,omitempty"`
	Limit                uint32   `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListEntriesRequest) Descriptor 

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

func (*ListEntriesRequest) GetDirectory 

func (m *ListEntriesRequest) GetDirectory() string

func (*ListEntriesRequest) GetInclusiveStartFrom 

func (m *ListEntriesRequest) GetInclusiveStartFrom() bool

func (*ListEntriesRequest) GetLimit 

func (m *ListEntriesRequest) GetLimit() uint32

func (*ListEntriesRequest) GetPrefix 

func (m *ListEntriesRequest) GetPrefix() string

func (*ListEntriesRequest) GetStartFromFileName 

func (m *ListEntriesRequest) GetStartFromFileName() string

func (*ListEntriesRequest) ProtoMessage 

func (*ListEntriesRequest) ProtoMessage()

func (*ListEntriesRequest) Reset 

func (m *ListEntriesRequest) Reset()

func (*ListEntriesRequest) String 

func (m *ListEntriesRequest) String() string

func (*ListEntriesRequest) XXX_DiscardUnknown 

func (m *ListEntriesRequest) XXX_DiscardUnknown()

func (*ListEntriesRequest) XXX_Marshal 

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

func (*ListEntriesRequest) XXX_Merge 

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

func (*ListEntriesRequest) XXX_Size 

func (m *ListEntriesRequest) XXX_Size() int

func (*ListEntriesRequest) XXX_Unmarshal 

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

type ListEntriesResponse 

type ListEntriesResponse struct {
	Entry                *Entry   `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListEntriesResponse) Descriptor 

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

func (*ListEntriesResponse) GetEntry 

func (m *ListEntriesResponse) GetEntry() *Entry

func (*ListEntriesResponse) ProtoMessage 

func (*ListEntriesResponse) ProtoMessage()

func (*ListEntriesResponse) Reset 

func (m *ListEntriesResponse) Reset()

func (*ListEntriesResponse) String 

func (m *ListEntriesResponse) String() string

func (*ListEntriesResponse) XXX_DiscardUnknown 

func (m *ListEntriesResponse) XXX_DiscardUnknown()

func (*ListEntriesResponse) XXX_Marshal 

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

func (*ListEntriesResponse) XXX_Merge 

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

func (*ListEntriesResponse) XXX_Size 

func (m *ListEntriesResponse) XXX_Size() int

func (*ListEntriesResponse) XXX_Unmarshal 

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

type LocateBrokerRequest 

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

func (*LocateBrokerRequest) Descriptor 

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

func (*LocateBrokerRequest) GetResource 

func (m *LocateBrokerRequest) GetResource() string

func (*LocateBrokerRequest) ProtoMessage 

func (*LocateBrokerRequest) ProtoMessage()

func (*LocateBrokerRequest) Reset 

func (m *LocateBrokerRequest) Reset()

func (*LocateBrokerRequest) String 

func (m *LocateBrokerRequest) String() string

func (*LocateBrokerRequest) XXX_DiscardUnknown 

func (m *LocateBrokerRequest) XXX_DiscardUnknown()

func (*LocateBrokerRequest) XXX_Marshal 

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

func (*LocateBrokerRequest) XXX_Merge 

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

func (*LocateBrokerRequest) XXX_Size 

func (m *LocateBrokerRequest) XXX_Size() int

func (*LocateBrokerRequest) XXX_Unmarshal 

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

type LocateBrokerResponse 

type LocateBrokerResponse struct {
	Found                bool                             `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
	Resources            []*LocateBrokerResponse_Resource `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*LocateBrokerResponse) Descriptor 

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

func (*LocateBrokerResponse) GetFound 

func (m *LocateBrokerResponse) GetFound() bool

func (*LocateBrokerResponse) GetResources 

func (m *LocateBrokerResponse) GetResources() []*LocateBrokerResponse_Resource

func (*LocateBrokerResponse) ProtoMessage 

func (*LocateBrokerResponse) ProtoMessage()

func (*LocateBrokerResponse) Reset 

func (m *LocateBrokerResponse) Reset()

func (*LocateBrokerResponse) String 

func (m *LocateBrokerResponse) String() string

func (*LocateBrokerResponse) XXX_DiscardUnknown 

func (m *LocateBrokerResponse) XXX_DiscardUnknown()

func (*LocateBrokerResponse) XXX_Marshal 

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

func (*LocateBrokerResponse) XXX_Merge 

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

func (*LocateBrokerResponse) XXX_Size 

func (m *LocateBrokerResponse) XXX_Size() int

func (*LocateBrokerResponse) XXX_Unmarshal 

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

type LocateBrokerResponse_Resource 

type LocateBrokerResponse_Resource struct {
	GrpcAddresses        string   `protobuf:"bytes,1,opt,name=grpc_addresses,json=grpcAddresses,proto3" json:"grpc_addresses,omitempty"`
	ResourceCount        int32    `protobuf:"varint,2,opt,name=resource_count,json=resourceCount,proto3" json:"resource_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

if found, send the exact address if not found, send the full list of existing brokers

func (*LocateBrokerResponse_Resource) Descriptor 

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

func (*LocateBrokerResponse_Resource) GetGrpcAddresses 

func (m *LocateBrokerResponse_Resource) GetGrpcAddresses() string

func (*LocateBrokerResponse_Resource) GetResourceCount 

func (m *LocateBrokerResponse_Resource) GetResourceCount() int32

func (*LocateBrokerResponse_Resource) ProtoMessage 

func (*LocateBrokerResponse_Resource) ProtoMessage()

func (*LocateBrokerResponse_Resource) Reset 

func (m *LocateBrokerResponse_Resource) Reset()

func (*LocateBrokerResponse_Resource) String 

func (m *LocateBrokerResponse_Resource) String() string

func (*LocateBrokerResponse_Resource) XXX_DiscardUnknown 

func (m *LocateBrokerResponse_Resource) XXX_DiscardUnknown()

func (*LocateBrokerResponse_Resource) XXX_Marshal 

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

func (*LocateBrokerResponse_Resource) XXX_Merge 

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

func (*LocateBrokerResponse_Resource) XXX_Size 

func (m *LocateBrokerResponse_Resource) XXX_Size() int

func (*LocateBrokerResponse_Resource) XXX_Unmarshal 

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

type Location 

type Location struct {
	Url                  string   `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	PublicUrl            string   `protobuf:"bytes,2,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Location) Descriptor 

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

func (*Location) GetPublicUrl 

func (m *Location) GetPublicUrl() string

func (*Location) GetUrl 

func (m *Location) GetUrl() string

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

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

func (*Location) XXX_Merge 

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

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

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

type Locations 

type Locations struct {
	Locations            []*Location `protobuf:"bytes,1,rep,name=locations,proto3" json:"locations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Locations) Descriptor 

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

func (*Locations) GetLocations 

func (m *Locations) GetLocations() []*Location

func (*Locations) ProtoMessage 

func (*Locations) ProtoMessage()

func (*Locations) Reset 

func (m *Locations) Reset()

func (*Locations) String 

func (m *Locations) String() string

func (*Locations) XXX_DiscardUnknown 

func (m *Locations) XXX_DiscardUnknown()

func (*Locations) XXX_Marshal 

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

func (*Locations) XXX_Merge 

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

func (*Locations) XXX_Size 

func (m *Locations) XXX_Size() int

func (*Locations) XXX_Unmarshal 

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

type LogEntry 

type LogEntry struct {
	TsNs                 int64    `protobuf:"varint,1,opt,name=ts_ns,json=tsNs,proto3" json:"ts_ns,omitempty"`
	PartitionKeyHash     int32    `protobuf:"varint,2,opt,name=partition_key_hash,json=partitionKeyHash,proto3" json:"partition_key_hash,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetData 

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

func (*LogEntry) GetPartitionKeyHash 

func (m *LogEntry) GetPartitionKeyHash() int32

func (*LogEntry) GetTsNs 

func (m *LogEntry) GetTsNs() int64

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

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

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

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

type LookupDirectoryEntryRequest 

type LookupDirectoryEntryRequest struct {
	Directory            string   `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookupDirectoryEntryRequest) Descriptor 

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

func (*LookupDirectoryEntryRequest) GetDirectory 

func (m *LookupDirectoryEntryRequest) GetDirectory() string

func (*LookupDirectoryEntryRequest) GetName 

func (m *LookupDirectoryEntryRequest) GetName() string

func (*LookupDirectoryEntryRequest) ProtoMessage 

func (*LookupDirectoryEntryRequest) ProtoMessage()

func (*LookupDirectoryEntryRequest) Reset 

func (m *LookupDirectoryEntryRequest) Reset()

func (*LookupDirectoryEntryRequest) String 

func (m *LookupDirectoryEntryRequest) String() string

func (*LookupDirectoryEntryRequest) XXX_DiscardUnknown 

func (m *LookupDirectoryEntryRequest) XXX_DiscardUnknown()

func (*LookupDirectoryEntryRequest) XXX_Marshal 

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

func (*LookupDirectoryEntryRequest) XXX_Merge 

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

func (*LookupDirectoryEntryRequest) XXX_Size 

func (m *LookupDirectoryEntryRequest) XXX_Size() int

func (*LookupDirectoryEntryRequest) XXX_Unmarshal 

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

type LookupDirectoryEntryResponse 

type LookupDirectoryEntryResponse struct {
	Entry                *Entry   `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookupDirectoryEntryResponse) Descriptor 

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

func (*LookupDirectoryEntryResponse) GetEntry 

func (m *LookupDirectoryEntryResponse) GetEntry() *Entry

func (*LookupDirectoryEntryResponse) ProtoMessage 

func (*LookupDirectoryEntryResponse) ProtoMessage()

func (*LookupDirectoryEntryResponse) Reset 

func (m *LookupDirectoryEntryResponse) Reset()

func (*LookupDirectoryEntryResponse) String 

func (m *LookupDirectoryEntryResponse) String() string

func (*LookupDirectoryEntryResponse) XXX_DiscardUnknown 

func (m *LookupDirectoryEntryResponse) XXX_DiscardUnknown()

func (*LookupDirectoryEntryResponse) XXX_Marshal 

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

func (*LookupDirectoryEntryResponse) XXX_Merge 

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

func (*LookupDirectoryEntryResponse) XXX_Size 

func (m *LookupDirectoryEntryResponse) XXX_Size() int

func (*LookupDirectoryEntryResponse) XXX_Unmarshal 

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

type LookupVolumeRequest 

type LookupVolumeRequest struct {
	VolumeIds            []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds,proto3" json:"volume_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookupVolumeRequest) Descriptor 

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

func (*LookupVolumeRequest) GetVolumeIds 

func (m *LookupVolumeRequest) GetVolumeIds() []string

func (*LookupVolumeRequest) ProtoMessage 

func (*LookupVolumeRequest) ProtoMessage()

func (*LookupVolumeRequest) Reset 

func (m *LookupVolumeRequest) Reset()

func (*LookupVolumeRequest) String 

func (m *LookupVolumeRequest) String() string

func (*LookupVolumeRequest) XXX_DiscardUnknown 

func (m *LookupVolumeRequest) XXX_DiscardUnknown()

func (*LookupVolumeRequest) XXX_Marshal 

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

func (*LookupVolumeRequest) XXX_Merge 

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

func (*LookupVolumeRequest) XXX_Size 

func (m *LookupVolumeRequest) XXX_Size() int

func (*LookupVolumeRequest) XXX_Unmarshal 

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

type LookupVolumeResponse 

type LookupVolumeResponse struct {
	LocationsMap         map[string]*Locations `` /* 185-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*LookupVolumeResponse) Descriptor 

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

func (*LookupVolumeResponse) GetLocationsMap 

func (m *LookupVolumeResponse) GetLocationsMap() map[string]*Locations

func (*LookupVolumeResponse) ProtoMessage 

func (*LookupVolumeResponse) ProtoMessage()

func (*LookupVolumeResponse) Reset 

func (m *LookupVolumeResponse) Reset()

func (*LookupVolumeResponse) String 

func (m *LookupVolumeResponse) String() string

func (*LookupVolumeResponse) XXX_DiscardUnknown 

func (m *LookupVolumeResponse) XXX_DiscardUnknown()

func (*LookupVolumeResponse) XXX_Marshal 

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

func (*LookupVolumeResponse) XXX_Merge 

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

func (*LookupVolumeResponse) XXX_Size 

func (m *LookupVolumeResponse) XXX_Size() int

func (*LookupVolumeResponse) XXX_Unmarshal 

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

type SeaweedFilerClient 

type SeaweedFilerClient interface {
	LookupDirectoryEntry(ctx context.Context, in *LookupDirectoryEntryRequest, opts ...grpc.CallOption) (*LookupDirectoryEntryResponse, error)
	ListEntries(ctx context.Context, in *ListEntriesRequest, opts ...grpc.CallOption) (SeaweedFiler_ListEntriesClient, error)
	CreateEntry(ctx context.Context, in *CreateEntryRequest, opts ...grpc.CallOption) (*CreateEntryResponse, error)
	UpdateEntry(ctx context.Context, in *UpdateEntryRequest, opts ...grpc.CallOption) (*UpdateEntryResponse, error)
	AppendToEntry(ctx context.Context, in *AppendToEntryRequest, opts ...grpc.CallOption) (*AppendToEntryResponse, error)
	DeleteEntry(ctx context.Context, in *DeleteEntryRequest, opts ...grpc.CallOption) (*DeleteEntryResponse, error)
	AtomicRenameEntry(ctx context.Context, in *AtomicRenameEntryRequest, opts ...grpc.CallOption) (*AtomicRenameEntryResponse, error)
	AssignVolume(ctx context.Context, in *AssignVolumeRequest, opts ...grpc.CallOption) (*AssignVolumeResponse, error)
	LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error)
	DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error)
	Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error)
	GetFilerConfiguration(ctx context.Context, in *GetFilerConfigurationRequest, opts ...grpc.CallOption) (*GetFilerConfigurationResponse, error)
	SubscribeMetadata(ctx context.Context, in *SubscribeMetadataRequest, opts ...grpc.CallOption) (SeaweedFiler_SubscribeMetadataClient, error)
	SubscribeLocalMetadata(ctx context.Context, in *SubscribeMetadataRequest, opts ...grpc.CallOption) (SeaweedFiler_SubscribeLocalMetadataClient, error)
	KeepConnected(ctx context.Context, opts ...grpc.CallOption) (SeaweedFiler_KeepConnectedClient, error)
	LocateBroker(ctx context.Context, in *LocateBrokerRequest, opts ...grpc.CallOption) (*LocateBrokerResponse, error)
	KvGet(ctx context.Context, in *KvGetRequest, opts ...grpc.CallOption) (*KvGetResponse, error)
	KvPut(ctx context.Context, in *KvPutRequest, opts ...grpc.CallOption) (*KvPutResponse, error)
}

SeaweedFilerClient is the client API for SeaweedFiler service.

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

func NewSeaweedFilerClient 

func NewSeaweedFilerClient(cc *grpc.ClientConn) SeaweedFilerClient

type SeaweedFilerServer 

type SeaweedFilerServer interface {
	LookupDirectoryEntry(context.Context, *LookupDirectoryEntryRequest) (*LookupDirectoryEntryResponse, error)
	ListEntries(*ListEntriesRequest, SeaweedFiler_ListEntriesServer) error
	CreateEntry(context.Context, *CreateEntryRequest) (*CreateEntryResponse, error)
	UpdateEntry(context.Context, *UpdateEntryRequest) (*UpdateEntryResponse, error)
	AppendToEntry(context.Context, *AppendToEntryRequest) (*AppendToEntryResponse, error)
	DeleteEntry(context.Context, *DeleteEntryRequest) (*DeleteEntryResponse, error)
	AtomicRenameEntry(context.Context, *AtomicRenameEntryRequest) (*AtomicRenameEntryResponse, error)
	AssignVolume(context.Context, *AssignVolumeRequest) (*AssignVolumeResponse, error)
	LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error)
	DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
	Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
	GetFilerConfiguration(context.Context, *GetFilerConfigurationRequest) (*GetFilerConfigurationResponse, error)
	SubscribeMetadata(*SubscribeMetadataRequest, SeaweedFiler_SubscribeMetadataServer) error
	SubscribeLocalMetadata(*SubscribeMetadataRequest, SeaweedFiler_SubscribeLocalMetadataServer) error
	KeepConnected(SeaweedFiler_KeepConnectedServer) error
	LocateBroker(context.Context, *LocateBrokerRequest) (*LocateBrokerResponse, error)
	KvGet(context.Context, *KvGetRequest) (*KvGetResponse, error)
	KvPut(context.Context, *KvPutRequest) (*KvPutResponse, error)
}

SeaweedFilerServer is the server API for SeaweedFiler service.

type SeaweedFiler_KeepConnectedClient 

type SeaweedFiler_KeepConnectedClient interface {
	Send(*KeepConnectedRequest) error
	Recv() (*KeepConnectedResponse, error)
	grpc.ClientStream
}

type SeaweedFiler_KeepConnectedServer 

type SeaweedFiler_KeepConnectedServer interface {
	Send(*KeepConnectedResponse) error
	Recv() (*KeepConnectedRequest, error)
	grpc.ServerStream
}

type SeaweedFiler_ListEntriesClient 

type SeaweedFiler_ListEntriesClient interface {
	Recv() (*ListEntriesResponse, error)
	grpc.ClientStream
}

type SeaweedFiler_ListEntriesServer 

type SeaweedFiler_ListEntriesServer interface {
	Send(*ListEntriesResponse) error
	grpc.ServerStream
}

type SeaweedFiler_SubscribeLocalMetadataClient 

type SeaweedFiler_SubscribeLocalMetadataClient interface {
	Recv() (*SubscribeMetadataResponse, error)
	grpc.ClientStream
}

type SeaweedFiler_SubscribeLocalMetadataServer 

type SeaweedFiler_SubscribeLocalMetadataServer interface {
	Send(*SubscribeMetadataResponse) error
	grpc.ServerStream
}

type SeaweedFiler_SubscribeMetadataClient 

type SeaweedFiler_SubscribeMetadataClient interface {
	Recv() (*SubscribeMetadataResponse, error)
	grpc.ClientStream
}

type SeaweedFiler_SubscribeMetadataServer 

type SeaweedFiler_SubscribeMetadataServer interface {
	Send(*SubscribeMetadataResponse) error
	grpc.ServerStream
}

type StatisticsRequest 

type StatisticsRequest struct {
	Replication          string   `protobuf:"bytes,1,opt,name=replication,proto3" json:"replication,omitempty"`
	Collection           string   `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Ttl                  string   `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatisticsRequest) Descriptor 

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

func (*StatisticsRequest) GetCollection 

func (m *StatisticsRequest) GetCollection() string

func (*StatisticsRequest) GetReplication 

func (m *StatisticsRequest) GetReplication() string

func (*StatisticsRequest) GetTtl 

func (m *StatisticsRequest) GetTtl() string

func (*StatisticsRequest) ProtoMessage 

func (*StatisticsRequest) ProtoMessage()

func (*StatisticsRequest) Reset 

func (m *StatisticsRequest) Reset()

func (*StatisticsRequest) String 

func (m *StatisticsRequest) String() string

func (*StatisticsRequest) XXX_DiscardUnknown 

func (m *StatisticsRequest) XXX_DiscardUnknown()

func (*StatisticsRequest) XXX_Marshal 

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

func (*StatisticsRequest) XXX_Merge 

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

func (*StatisticsRequest) XXX_Size 

func (m *StatisticsRequest) XXX_Size() int

func (*StatisticsRequest) XXX_Unmarshal 

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

type StatisticsResponse 

type StatisticsResponse struct {
	Replication          string   `protobuf:"bytes,1,opt,name=replication,proto3" json:"replication,omitempty"`
	Collection           string   `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Ttl                  string   `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	TotalSize            uint64   `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	UsedSize             uint64   `protobuf:"varint,5,opt,name=used_size,json=usedSize,proto3" json:"used_size,omitempty"`
	FileCount            uint64   `protobuf:"varint,6,opt,name=file_count,json=fileCount,proto3" json:"file_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatisticsResponse) Descriptor 

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

func (*StatisticsResponse) GetCollection 

func (m *StatisticsResponse) GetCollection() string

func (*StatisticsResponse) GetFileCount 

func (m *StatisticsResponse) GetFileCount() uint64

func (*StatisticsResponse) GetReplication 

func (m *StatisticsResponse) GetReplication() string

func (*StatisticsResponse) GetTotalSize 

func (m *StatisticsResponse) GetTotalSize() uint64

func (*StatisticsResponse) GetTtl 

func (m *StatisticsResponse) GetTtl() string

func (*StatisticsResponse) GetUsedSize 

func (m *StatisticsResponse) GetUsedSize() uint64

func (*StatisticsResponse) ProtoMessage 

func (*StatisticsResponse) ProtoMessage()

func (*StatisticsResponse) Reset 

func (m *StatisticsResponse) Reset()

func (*StatisticsResponse) String 

func (m *StatisticsResponse) String() string

func (*StatisticsResponse) XXX_DiscardUnknown 

func (m *StatisticsResponse) XXX_DiscardUnknown()

func (*StatisticsResponse) XXX_Marshal 

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

func (*StatisticsResponse) XXX_Merge 

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

func (*StatisticsResponse) XXX_Size 

func (m *StatisticsResponse) XXX_Size() int

func (*StatisticsResponse) XXX_Unmarshal 

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

type SubscribeMetadataRequest 

type SubscribeMetadataRequest struct {
	ClientName           string   `protobuf:"bytes,1,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"`
	PathPrefix           string   `protobuf:"bytes,2,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	SinceNs              int64    `protobuf:"varint,3,opt,name=since_ns,json=sinceNs,proto3" json:"since_ns,omitempty"`
	Signature            int32    `protobuf:"varint,4,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeMetadataRequest) Descriptor 

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

func (*SubscribeMetadataRequest) GetClientName 

func (m *SubscribeMetadataRequest) GetClientName() string

func (*SubscribeMetadataRequest) GetPathPrefix 

func (m *SubscribeMetadataRequest) GetPathPrefix() string

func (*SubscribeMetadataRequest) GetSignature 

func (m *SubscribeMetadataRequest) GetSignature() int32

func (*SubscribeMetadataRequest) GetSinceNs 

func (m *SubscribeMetadataRequest) GetSinceNs() int64

func (*SubscribeMetadataRequest) ProtoMessage 

func (*SubscribeMetadataRequest) ProtoMessage()

func (*SubscribeMetadataRequest) Reset 

func (m *SubscribeMetadataRequest) Reset()

func (*SubscribeMetadataRequest) String 

func (m *SubscribeMetadataRequest) String() string

func (*SubscribeMetadataRequest) XXX_DiscardUnknown 

func (m *SubscribeMetadataRequest) XXX_DiscardUnknown()

func (*SubscribeMetadataRequest) XXX_Marshal 

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

func (*SubscribeMetadataRequest) XXX_Merge 

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

func (*SubscribeMetadataRequest) XXX_Size 

func (m *SubscribeMetadataRequest) XXX_Size() int

func (*SubscribeMetadataRequest) XXX_Unmarshal 

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

type SubscribeMetadataResponse 

type SubscribeMetadataResponse struct {
	Directory            string             `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	EventNotification    *EventNotification `protobuf:"bytes,2,opt,name=event_notification,json=eventNotification,proto3" json:"event_notification,omitempty"`
	TsNs                 int64              `protobuf:"varint,3,opt,name=ts_ns,json=tsNs,proto3" json:"ts_ns,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*SubscribeMetadataResponse) Descriptor 

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

func (*SubscribeMetadataResponse) GetDirectory 

func (m *SubscribeMetadataResponse) GetDirectory() string

func (*SubscribeMetadataResponse) GetEventNotification 

func (m *SubscribeMetadataResponse) GetEventNotification() *EventNotification

func (*SubscribeMetadataResponse) GetTsNs 

func (m *SubscribeMetadataResponse) GetTsNs() int64

func (*SubscribeMetadataResponse) ProtoMessage 

func (*SubscribeMetadataResponse) ProtoMessage()

func (*SubscribeMetadataResponse) Reset 

func (m *SubscribeMetadataResponse) Reset()

func (*SubscribeMetadataResponse) String 

func (m *SubscribeMetadataResponse) String() string

func (*SubscribeMetadataResponse) XXX_DiscardUnknown 

func (m *SubscribeMetadataResponse) XXX_DiscardUnknown()

func (*SubscribeMetadataResponse) XXX_Marshal 

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

func (*SubscribeMetadataResponse) XXX_Merge 

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

func (*SubscribeMetadataResponse) XXX_Size 

func (m *SubscribeMetadataResponse) XXX_Size() int

func (*SubscribeMetadataResponse) XXX_Unmarshal 

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

type UnimplementedSeaweedFilerServer 

type UnimplementedSeaweedFilerServer struct {
}

UnimplementedSeaweedFilerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSeaweedFilerServer) AppendToEntry 

func (*UnimplementedSeaweedFilerServer) AppendToEntry(ctx context.Context, req *AppendToEntryRequest) (*AppendToEntryResponse, error)

func (*UnimplementedSeaweedFilerServer) AssignVolume 

func (*UnimplementedSeaweedFilerServer) AssignVolume(ctx context.Context, req *AssignVolumeRequest) (*AssignVolumeResponse, error)

func (*UnimplementedSeaweedFilerServer) AtomicRenameEntry 

func (*UnimplementedSeaweedFilerServer) AtomicRenameEntry(ctx context.Context, req *AtomicRenameEntryRequest) (*AtomicRenameEntryResponse, error)

func (*UnimplementedSeaweedFilerServer) CreateEntry 

func (*UnimplementedSeaweedFilerServer) CreateEntry(ctx context.Context, req *CreateEntryRequest) (*CreateEntryResponse, error)

func (*UnimplementedSeaweedFilerServer) DeleteCollection 

func (*UnimplementedSeaweedFilerServer) DeleteCollection(ctx context.Context, req *DeleteCollectionRequest) (*DeleteCollectionResponse, error)

func (*UnimplementedSeaweedFilerServer) DeleteEntry 

func (*UnimplementedSeaweedFilerServer) DeleteEntry(ctx context.Context, req *DeleteEntryRequest) (*DeleteEntryResponse, error)

func (*UnimplementedSeaweedFilerServer) GetFilerConfiguration 

func (*UnimplementedSeaweedFilerServer) GetFilerConfiguration(ctx context.Context, req *GetFilerConfigurationRequest) (*GetFilerConfigurationResponse, error)

func (*UnimplementedSeaweedFilerServer) KeepConnected 

func (*UnimplementedSeaweedFilerServer) KeepConnected(srv SeaweedFiler_KeepConnectedServer) error

func (*UnimplementedSeaweedFilerServer) KvGet 

func (*UnimplementedSeaweedFilerServer) KvGet(ctx context.Context, req *KvGetRequest) (*KvGetResponse, error)

func (*UnimplementedSeaweedFilerServer) KvPut 

func (*UnimplementedSeaweedFilerServer) KvPut(ctx context.Context, req *KvPutRequest) (*KvPutResponse, error)

func (*UnimplementedSeaweedFilerServer) ListEntries 

func (*UnimplementedSeaweedFilerServer) ListEntries(req *ListEntriesRequest, srv SeaweedFiler_ListEntriesServer) error

func (*UnimplementedSeaweedFilerServer) LocateBroker 

func (*UnimplementedSeaweedFilerServer) LocateBroker(ctx context.Context, req *LocateBrokerRequest) (*LocateBrokerResponse, error)

func (*UnimplementedSeaweedFilerServer) LookupDirectoryEntry 

func (*UnimplementedSeaweedFilerServer) LookupDirectoryEntry(ctx context.Context, req *LookupDirectoryEntryRequest) (*LookupDirectoryEntryResponse, error)

func (*UnimplementedSeaweedFilerServer) LookupVolume 

func (*UnimplementedSeaweedFilerServer) LookupVolume(ctx context.Context, req *LookupVolumeRequest) (*LookupVolumeResponse, error)

func (*UnimplementedSeaweedFilerServer) Statistics 

func (*UnimplementedSeaweedFilerServer) Statistics(ctx context.Context, req *StatisticsRequest) (*StatisticsResponse, error)

func (*UnimplementedSeaweedFilerServer) SubscribeLocalMetadata 

func (*UnimplementedSeaweedFilerServer) SubscribeLocalMetadata(req *SubscribeMetadataRequest, srv SeaweedFiler_SubscribeLocalMetadataServer) error

func (*UnimplementedSeaweedFilerServer) SubscribeMetadata 

func (*UnimplementedSeaweedFilerServer) SubscribeMetadata(req *SubscribeMetadataRequest, srv SeaweedFiler_SubscribeMetadataServer) error

func (*UnimplementedSeaweedFilerServer) UpdateEntry 

func (*UnimplementedSeaweedFilerServer) UpdateEntry(ctx context.Context, req *UpdateEntryRequest) (*UpdateEntryResponse, error)

type UpdateEntryRequest 

type UpdateEntryRequest struct {
	Directory            string   `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	Entry                *Entry   `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
	IsFromOtherCluster   bool     `protobuf:"varint,3,opt,name=is_from_other_cluster,json=isFromOtherCluster,proto3" json:"is_from_other_cluster,omitempty"`
	Signatures           []int32  `protobuf:"varint,4,rep,packed,name=signatures,proto3" json:"signatures,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateEntryRequest) Descriptor 

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

func (*UpdateEntryRequest) GetDirectory 

func (m *UpdateEntryRequest) GetDirectory() string

func (*UpdateEntryRequest) GetEntry 

func (m *UpdateEntryRequest) GetEntry() *Entry

func (*UpdateEntryRequest) GetIsFromOtherCluster 

func (m *UpdateEntryRequest) GetIsFromOtherCluster() bool

func (*UpdateEntryRequest) GetSignatures 

func (m *UpdateEntryRequest) GetSignatures() []int32

func (*UpdateEntryRequest) ProtoMessage 

func (*UpdateEntryRequest) ProtoMessage()

func (*UpdateEntryRequest) Reset 

func (m *UpdateEntryRequest) Reset()

func (*UpdateEntryRequest) String 

func (m *UpdateEntryRequest) String() string

func (*UpdateEntryRequest) XXX_DiscardUnknown 

func (m *UpdateEntryRequest) XXX_DiscardUnknown()

func (*UpdateEntryRequest) XXX_Marshal 

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

func (*UpdateEntryRequest) XXX_Merge 

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

func (*UpdateEntryRequest) XXX_Size 

func (m *UpdateEntryRequest) XXX_Size() int

func (*UpdateEntryRequest) XXX_Unmarshal 

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

type UpdateEntryResponse 

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

func (*UpdateEntryResponse) Descriptor 

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

func (*UpdateEntryResponse) ProtoMessage 

func (*UpdateEntryResponse) ProtoMessage()

func (*UpdateEntryResponse) Reset 

func (m *UpdateEntryResponse) Reset()

func (*UpdateEntryResponse) String 

func (m *UpdateEntryResponse) String() string

func (*UpdateEntryResponse) XXX_DiscardUnknown 

func (m *UpdateEntryResponse) XXX_DiscardUnknown()

func (*UpdateEntryResponse) XXX_Marshal 

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

func (*UpdateEntryResponse) XXX_Merge 

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

func (*UpdateEntryResponse) XXX_Size 

func (m *UpdateEntryResponse) XXX_Size() int

func (*UpdateEntryResponse) XXX_Unmarshal 

func (m *UpdateEntryResponse) 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.