filer_pb

package
v0.0.0-...-2206af0 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	OS_UID = uint32(os.Getuid())
	OS_GID = uint32(os.Getgid())
)
View Source 
var ErrNotFound = errors.New("filer: no entry is found in filer store")
View Source 
var File_filer_proto protoreflect.FileDescriptor

Functions

func AfterEntryDeserialization 

func AfterEntryDeserialization(chunks []*FileChunk)

func BeforeEntrySerialization 

func BeforeEntrySerialization(chunks []*FileChunk)

func CreateEntry 

func CreateEntry(client SeaweedFilerClient, request *CreateEntryRequest) error

func EnsureFid 

func EnsureFid(chunk *FileChunk)

func Exists 

func Exists(filerClient FilerClient, parentDirectoryPath string, entryName string, isDirectory bool) (exists bool, err error)

func List 

func List(filerClient FilerClient, parentDirectoryPath, prefix string, fn EachEntryFunciton, startFrom string, inclusive bool, limit uint32) (err error)

func MkFile 

func MkFile(filerClient FilerClient, parentDirectoryPath string, fileName string, chunks []*FileChunk) error

func Mkdir 

func Mkdir(filerClient FilerClient, parentDirectoryPath string, dirName string, fn func(entry *Entry)) error

func ReadDirAllEntries 

func ReadDirAllEntries(filerClient FilerClient, fullDirPath util.FullPath, prefix string, fn EachEntryFunciton) (err error)

func RegisterSeaweedFilerServer 

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

func Remove 

func Remove(filerClient FilerClient, parentDirectoryPath, name string, isDeleteData, isRecursive, ignoreRecursiveErr, isFromOtherCluster bool, signatures []int32) error

func TraverseBfs 

func TraverseBfs(filerClient FilerClient, parentPath util.FullPath, fn func(parentPath util.FullPath, entry *Entry)) (err error)

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"`
	// contains filtered or unexported fields
}

func (*AppendToEntryRequest) Descriptor deprecated 

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

Deprecated: Use AppendToEntryRequest.ProtoReflect.Descriptor instead.

func (*AppendToEntryRequest) GetChunks 

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

func (*AppendToEntryRequest) GetDirectory 

func (x *AppendToEntryRequest) GetDirectory() string

func (*AppendToEntryRequest) GetEntryName 

func (x *AppendToEntryRequest) GetEntryName() string

func (*AppendToEntryRequest) ProtoMessage 

func (*AppendToEntryRequest) ProtoMessage()

func (*AppendToEntryRequest) ProtoReflect 

func (x *AppendToEntryRequest) ProtoReflect() protoreflect.Message

func (*AppendToEntryRequest) Reset 

func (x *AppendToEntryRequest) Reset()

func (*AppendToEntryRequest) String 

func (x *AppendToEntryRequest) String() string

type AppendToEntryResponse 

type AppendToEntryResponse struct {
	// contains filtered or unexported fields
}

func (*AppendToEntryResponse) Descriptor deprecated 

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

Deprecated: Use AppendToEntryResponse.ProtoReflect.Descriptor instead.

func (*AppendToEntryResponse) ProtoMessage 

func (*AppendToEntryResponse) ProtoMessage()

func (*AppendToEntryResponse) ProtoReflect 

func (x *AppendToEntryResponse) ProtoReflect() protoreflect.Message

func (*AppendToEntryResponse) Reset 

func (x *AppendToEntryResponse) Reset()

func (*AppendToEntryResponse) String 

func (x *AppendToEntryResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*AssignVolumeRequest) Descriptor deprecated 

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

Deprecated: Use AssignVolumeRequest.ProtoReflect.Descriptor instead.

func (*AssignVolumeRequest) GetCollection 

func (x *AssignVolumeRequest) GetCollection() string

func (*AssignVolumeRequest) GetCount 

func (x *AssignVolumeRequest) GetCount() int32

func (*AssignVolumeRequest) GetDataCenter 

func (x *AssignVolumeRequest) GetDataCenter() string

func (*AssignVolumeRequest) GetParentPath 

func (x *AssignVolumeRequest) GetParentPath() string

func (*AssignVolumeRequest) GetReplication 

func (x *AssignVolumeRequest) GetReplication() string

func (*AssignVolumeRequest) GetTtlSec 

func (x *AssignVolumeRequest) GetTtlSec() int32

func (*AssignVolumeRequest) ProtoMessage 

func (*AssignVolumeRequest) ProtoMessage()

func (*AssignVolumeRequest) ProtoReflect 

func (x *AssignVolumeRequest) ProtoReflect() protoreflect.Message

func (*AssignVolumeRequest) Reset 

func (x *AssignVolumeRequest) Reset()

func (*AssignVolumeRequest) String 

func (x *AssignVolumeRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*AssignVolumeResponse) Descriptor deprecated 

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

Deprecated: Use AssignVolumeResponse.ProtoReflect.Descriptor instead.

func (*AssignVolumeResponse) GetAuth 

func (x *AssignVolumeResponse) GetAuth() string

func (*AssignVolumeResponse) GetCollection 

func (x *AssignVolumeResponse) GetCollection() string

func (*AssignVolumeResponse) GetCount 

func (x *AssignVolumeResponse) GetCount() int32

func (*AssignVolumeResponse) GetError 

func (x *AssignVolumeResponse) GetError() string

func (*AssignVolumeResponse) GetFileId 

func (x *AssignVolumeResponse) GetFileId() string

func (*AssignVolumeResponse) GetPublicUrl 

func (x *AssignVolumeResponse) GetPublicUrl() string

func (*AssignVolumeResponse) GetReplication 

func (x *AssignVolumeResponse) GetReplication() string

func (*AssignVolumeResponse) GetUrl 

func (x *AssignVolumeResponse) GetUrl() string

func (*AssignVolumeResponse) ProtoMessage 

func (*AssignVolumeResponse) ProtoMessage()

func (*AssignVolumeResponse) ProtoReflect 

func (x *AssignVolumeResponse) ProtoReflect() protoreflect.Message

func (*AssignVolumeResponse) Reset 

func (x *AssignVolumeResponse) Reset()

func (*AssignVolumeResponse) String 

func (x *AssignVolumeResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*AtomicRenameEntryRequest) Descriptor deprecated 

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

Deprecated: Use AtomicRenameEntryRequest.ProtoReflect.Descriptor instead.

func (*AtomicRenameEntryRequest) GetNewDirectory 

func (x *AtomicRenameEntryRequest) GetNewDirectory() string

func (*AtomicRenameEntryRequest) GetNewName 

func (x *AtomicRenameEntryRequest) GetNewName() string

func (*AtomicRenameEntryRequest) GetOldDirectory 

func (x *AtomicRenameEntryRequest) GetOldDirectory() string

func (*AtomicRenameEntryRequest) GetOldName 

func (x *AtomicRenameEntryRequest) GetOldName() string

func (*AtomicRenameEntryRequest) ProtoMessage 

func (*AtomicRenameEntryRequest) ProtoMessage()

func (*AtomicRenameEntryRequest) ProtoReflect 

func (x *AtomicRenameEntryRequest) ProtoReflect() protoreflect.Message

func (*AtomicRenameEntryRequest) Reset 

func (x *AtomicRenameEntryRequest) Reset()

func (*AtomicRenameEntryRequest) String 

func (x *AtomicRenameEntryRequest) String() string

type AtomicRenameEntryResponse 

type AtomicRenameEntryResponse struct {
	// contains filtered or unexported fields
}

func (*AtomicRenameEntryResponse) Descriptor deprecated 

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

Deprecated: Use AtomicRenameEntryResponse.ProtoReflect.Descriptor instead.

func (*AtomicRenameEntryResponse) ProtoMessage 

func (*AtomicRenameEntryResponse) ProtoMessage()

func (*AtomicRenameEntryResponse) ProtoReflect 

func (x *AtomicRenameEntryResponse) ProtoReflect() protoreflect.Message

func (*AtomicRenameEntryResponse) Reset 

func (x *AtomicRenameEntryResponse) Reset()

func (*AtomicRenameEntryResponse) String 

func (x *AtomicRenameEntryResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateEntryRequest) AddSignature 

func (r *CreateEntryRequest) AddSignature(sig int32)

func (*CreateEntryRequest) Descriptor deprecated 

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

Deprecated: Use CreateEntryRequest.ProtoReflect.Descriptor instead.

func (*CreateEntryRequest) GetDirectory 

func (x *CreateEntryRequest) GetDirectory() string

func (*CreateEntryRequest) GetEntry 

func (x *CreateEntryRequest) GetEntry() *Entry

func (*CreateEntryRequest) GetIsFromOtherCluster 

func (x *CreateEntryRequest) GetIsFromOtherCluster() bool

func (*CreateEntryRequest) GetOExcl 

func (x *CreateEntryRequest) GetOExcl() bool

func (*CreateEntryRequest) GetSignatures 

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

func (*CreateEntryRequest) HasSigned 

func (r *CreateEntryRequest) HasSigned(sig int32) bool

func (*CreateEntryRequest) ProtoMessage 

func (*CreateEntryRequest) ProtoMessage()

func (*CreateEntryRequest) ProtoReflect 

func (x *CreateEntryRequest) ProtoReflect() protoreflect.Message

func (*CreateEntryRequest) Reset 

func (x *CreateEntryRequest) Reset()

func (*CreateEntryRequest) String 

func (x *CreateEntryRequest) String() string

type CreateEntryResponse 

type CreateEntryResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateEntryResponse) Descriptor deprecated 

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

Deprecated: Use CreateEntryResponse.ProtoReflect.Descriptor instead.

func (*CreateEntryResponse) GetError 

func (x *CreateEntryResponse) GetError() string

func (*CreateEntryResponse) ProtoMessage 

func (*CreateEntryResponse) ProtoMessage()

func (*CreateEntryResponse) ProtoReflect 

func (x *CreateEntryResponse) ProtoReflect() protoreflect.Message

func (*CreateEntryResponse) Reset 

func (x *CreateEntryResponse) Reset()

func (*CreateEntryResponse) String 

func (x *CreateEntryResponse) String() string

type DeleteCollectionRequest 

type DeleteCollectionRequest struct {
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCollectionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteCollectionRequest.ProtoReflect.Descriptor instead.

func (*DeleteCollectionRequest) GetCollection 

func (x *DeleteCollectionRequest) GetCollection() string

func (*DeleteCollectionRequest) ProtoMessage 

func (*DeleteCollectionRequest) ProtoMessage()

func (*DeleteCollectionRequest) ProtoReflect 

func (x *DeleteCollectionRequest) ProtoReflect() protoreflect.Message

func (*DeleteCollectionRequest) Reset 

func (x *DeleteCollectionRequest) Reset()

func (*DeleteCollectionRequest) String 

func (x *DeleteCollectionRequest) String() string

type DeleteCollectionResponse 

type DeleteCollectionResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteCollectionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteCollectionResponse.ProtoReflect.Descriptor instead.

func (*DeleteCollectionResponse) ProtoMessage 

func (*DeleteCollectionResponse) ProtoMessage()

func (*DeleteCollectionResponse) ProtoReflect 

func (x *DeleteCollectionResponse) ProtoReflect() protoreflect.Message

func (*DeleteCollectionResponse) Reset 

func (x *DeleteCollectionResponse) Reset()

func (*DeleteCollectionResponse) String 

func (x *DeleteCollectionResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteEntryRequest) Descriptor deprecated 

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

Deprecated: Use DeleteEntryRequest.ProtoReflect.Descriptor instead.

func (*DeleteEntryRequest) GetDirectory 

func (x *DeleteEntryRequest) GetDirectory() string

func (*DeleteEntryRequest) GetIgnoreRecursiveError 

func (x *DeleteEntryRequest) GetIgnoreRecursiveError() bool

func (*DeleteEntryRequest) GetIsDeleteData 

func (x *DeleteEntryRequest) GetIsDeleteData() bool

func (*DeleteEntryRequest) GetIsFromOtherCluster 

func (x *DeleteEntryRequest) GetIsFromOtherCluster() bool

func (*DeleteEntryRequest) GetIsRecursive 

func (x *DeleteEntryRequest) GetIsRecursive() bool

func (*DeleteEntryRequest) GetName 

func (x *DeleteEntryRequest) GetName() string

func (*DeleteEntryRequest) GetSignatures 

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

func (*DeleteEntryRequest) ProtoMessage 

func (*DeleteEntryRequest) ProtoMessage()

func (*DeleteEntryRequest) ProtoReflect 

func (x *DeleteEntryRequest) ProtoReflect() protoreflect.Message

func (*DeleteEntryRequest) Reset 

func (x *DeleteEntryRequest) Reset()

func (*DeleteEntryRequest) String 

func (x *DeleteEntryRequest) String() string

type DeleteEntryResponse 

type DeleteEntryResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteEntryResponse) Descriptor deprecated 

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

Deprecated: Use DeleteEntryResponse.ProtoReflect.Descriptor instead.

func (*DeleteEntryResponse) GetError 

func (x *DeleteEntryResponse) GetError() string

func (*DeleteEntryResponse) ProtoMessage 

func (*DeleteEntryResponse) ProtoMessage()

func (*DeleteEntryResponse) ProtoReflect 

func (x *DeleteEntryResponse) ProtoReflect() protoreflect.Message

func (*DeleteEntryResponse) Reset 

func (x *DeleteEntryResponse) Reset()

func (*DeleteEntryResponse) String 

func (x *DeleteEntryResponse) String() string

type EachEntryFunciton 

type EachEntryFunciton func(entry *Entry, isLast bool) 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 */
	// contains filtered or unexported fields
}

func GetEntry 

func GetEntry(filerClient FilerClient, fullFilePath util.FullPath) (entry *Entry, err error)

func (*Entry) Descriptor deprecated 

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetAttributes 

func (x *Entry) GetAttributes() *FuseAttributes

func (*Entry) GetChunks 

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

func (*Entry) GetExtended 

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

func (*Entry) GetIsDirectory 

func (x *Entry) GetIsDirectory() bool

func (*Entry) GetName 

func (x *Entry) GetName() string

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

func (x *Entry) ProtoReflect() protoreflect.Message

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) String 

func (x *Entry) String() string

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"`
	// contains filtered or unexported fields
}

func (*EventNotification) Descriptor deprecated 

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

Deprecated: Use EventNotification.ProtoReflect.Descriptor instead.

func (*EventNotification) GetDeleteChunks 

func (x *EventNotification) GetDeleteChunks() bool

func (*EventNotification) GetIsFromOtherCluster 

func (x *EventNotification) GetIsFromOtherCluster() bool

func (*EventNotification) GetNewEntry 

func (x *EventNotification) GetNewEntry() *Entry

func (*EventNotification) GetNewParentPath 

func (x *EventNotification) GetNewParentPath() string

func (*EventNotification) GetOldEntry 

func (x *EventNotification) GetOldEntry() *Entry

func (*EventNotification) GetSignatures 

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

func (*EventNotification) ProtoMessage 

func (*EventNotification) ProtoMessage()

func (*EventNotification) ProtoReflect 

func (x *EventNotification) ProtoReflect() protoreflect.Message

func (*EventNotification) Reset 

func (x *EventNotification) Reset()

func (*EventNotification) String 

func (x *EventNotification) String() string

type FileChunk 

type FileChunk struct {
	FileId          string  `protobuf:"bytes,1,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"` // to be deprecated
	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"` // to be deprecated
	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"` // content is a list of FileChunks
	// contains filtered or unexported fields
}

func (*FileChunk) Descriptor deprecated 

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

Deprecated: Use FileChunk.ProtoReflect.Descriptor instead.

func (*FileChunk) GetCipherKey 

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

func (*FileChunk) GetETag 

func (x *FileChunk) GetETag() string

func (*FileChunk) GetFid 

func (x *FileChunk) GetFid() *FileId

func (*FileChunk) GetFileId 

func (x *FileChunk) GetFileId() string

func (*FileChunk) GetFileIdString 

func (c *FileChunk) GetFileIdString() string

func (*FileChunk) GetIsChunkManifest 

func (x *FileChunk) GetIsChunkManifest() bool

func (*FileChunk) GetIsCompressed 

func (x *FileChunk) GetIsCompressed() bool

func (*FileChunk) GetMtime 

func (x *FileChunk) GetMtime() int64

func (*FileChunk) GetOffset 

func (x *FileChunk) GetOffset() int64

func (*FileChunk) GetSize 

func (x *FileChunk) GetSize() uint64

func (*FileChunk) GetSourceFid 

func (x *FileChunk) GetSourceFid() *FileId

func (*FileChunk) GetSourceFileId 

func (x *FileChunk) GetSourceFileId() string

func (*FileChunk) ProtoMessage 

func (*FileChunk) ProtoMessage()

func (*FileChunk) ProtoReflect 

func (x *FileChunk) ProtoReflect() protoreflect.Message

func (*FileChunk) Reset 

func (x *FileChunk) Reset()

func (*FileChunk) String 

func (x *FileChunk) String() string

type FileChunkManifest 

type FileChunkManifest struct {
	Chunks []*FileChunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"`
	// contains filtered or unexported fields
}

func (*FileChunkManifest) Descriptor deprecated 

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

Deprecated: Use FileChunkManifest.ProtoReflect.Descriptor instead.

func (*FileChunkManifest) GetChunks 

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

func (*FileChunkManifest) ProtoMessage 

func (*FileChunkManifest) ProtoMessage()

func (*FileChunkManifest) ProtoReflect 

func (x *FileChunkManifest) ProtoReflect() protoreflect.Message

func (*FileChunkManifest) Reset 

func (x *FileChunkManifest) Reset()

func (*FileChunkManifest) String 

func (x *FileChunkManifest) String() string

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"`
	// contains filtered or unexported fields
}

func ToFileIdObject 

func ToFileIdObject(fileIdStr string) (*FileId, error)

func (*FileId) Descriptor deprecated 

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

Deprecated: Use FileId.ProtoReflect.Descriptor instead.

func (*FileId) GetCookie 

func (x *FileId) GetCookie() uint32

func (*FileId) GetFileKey 

func (x *FileId) GetFileKey() uint64

func (*FileId) GetVolumeId 

func (x *FileId) GetVolumeId() uint32

func (*FileId) ProtoMessage 

func (*FileId) ProtoMessage()

func (*FileId) ProtoReflect 

func (x *FileId) ProtoReflect() protoreflect.Message

func (*FileId) Reset 

func (x *FileId) Reset()

func (*FileId) String 

func (x *FileId) String() string

type FilerClient 

type FilerClient interface {
	WithFilerClient(fn func(SeaweedFilerClient) error) error
	AdjustedUrl(hostAndPort string) string
}

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"`
	// contains filtered or unexported fields
}

func (*FullEntry) Descriptor deprecated 

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

Deprecated: Use FullEntry.ProtoReflect.Descriptor instead.

func (*FullEntry) GetDir 

func (x *FullEntry) GetDir() string

func (*FullEntry) GetEntry 

func (x *FullEntry) GetEntry() *Entry

func (*FullEntry) ProtoMessage 

func (*FullEntry) ProtoMessage()

func (*FullEntry) ProtoReflect 

func (x *FullEntry) ProtoReflect() protoreflect.Message

func (*FullEntry) Reset 

func (x *FullEntry) Reset()

func (*FullEntry) String 

func (x *FullEntry) String() string

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"` // unix time in seconds
	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"` // unix time in seconds
	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"`    // for hdfs
	GroupName     []string `protobuf:"bytes,12,rep,name=group_name,json=groupName,proto3" json:"group_name,omitempty"` // for hdfs
	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"`
	// contains filtered or unexported fields
}

func (*FuseAttributes) Descriptor deprecated 

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

Deprecated: Use FuseAttributes.ProtoReflect.Descriptor instead.

func (*FuseAttributes) GetCollection 

func (x *FuseAttributes) GetCollection() string

func (*FuseAttributes) GetCrtime 

func (x *FuseAttributes) GetCrtime() int64

func (*FuseAttributes) GetFileMode 

func (x *FuseAttributes) GetFileMode() uint32

func (*FuseAttributes) GetFileSize 

func (x *FuseAttributes) GetFileSize() uint64

func (*FuseAttributes) GetGid 

func (x *FuseAttributes) GetGid() uint32

func (*FuseAttributes) GetGroupName 

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

func (*FuseAttributes) GetMd5 

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

func (*FuseAttributes) GetMime 

func (x *FuseAttributes) GetMime() string

func (*FuseAttributes) GetMtime 

func (x *FuseAttributes) GetMtime() int64

func (*FuseAttributes) GetReplication 

func (x *FuseAttributes) GetReplication() string

func (*FuseAttributes) GetSymlinkTarget 

func (x *FuseAttributes) GetSymlinkTarget() string

func (*FuseAttributes) GetTtlSec 

func (x *FuseAttributes) GetTtlSec() int32

func (*FuseAttributes) GetUid 

func (x *FuseAttributes) GetUid() uint32

func (*FuseAttributes) GetUserName 

func (x *FuseAttributes) GetUserName() string

func (*FuseAttributes) ProtoMessage 

func (*FuseAttributes) ProtoMessage()

func (*FuseAttributes) ProtoReflect 

func (x *FuseAttributes) ProtoReflect() protoreflect.Message

func (*FuseAttributes) Reset 

func (x *FuseAttributes) Reset()

func (*FuseAttributes) String 

func (x *FuseAttributes) String() string

type GetFilerConfigurationRequest 

type GetFilerConfigurationRequest struct {
	// contains filtered or unexported fields
}

func (*GetFilerConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use GetFilerConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetFilerConfigurationRequest) ProtoMessage 

func (*GetFilerConfigurationRequest) ProtoMessage()

func (*GetFilerConfigurationRequest) ProtoReflect 

func (x *GetFilerConfigurationRequest) ProtoReflect() protoreflect.Message

func (*GetFilerConfigurationRequest) Reset 

func (x *GetFilerConfigurationRequest) Reset()

func (*GetFilerConfigurationRequest) String 

func (x *GetFilerConfigurationRequest) String() string

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"`
	MetricsAddress     string   `protobuf:"bytes,9,opt,name=metrics_address,json=metricsAddress,proto3" json:"metrics_address,omitempty"`
	MetricsIntervalSec int32    `protobuf:"varint,10,opt,name=metrics_interval_sec,json=metricsIntervalSec,proto3" json:"metrics_interval_sec,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFilerConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use GetFilerConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetFilerConfigurationResponse) GetCipher 

func (x *GetFilerConfigurationResponse) GetCipher() bool

func (*GetFilerConfigurationResponse) GetCollection 

func (x *GetFilerConfigurationResponse) GetCollection() string

func (*GetFilerConfigurationResponse) GetDirBuckets 

func (x *GetFilerConfigurationResponse) GetDirBuckets() string

func (*GetFilerConfigurationResponse) GetMasters 

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

func (*GetFilerConfigurationResponse) GetMaxMb 

func (x *GetFilerConfigurationResponse) GetMaxMb() uint32

func (*GetFilerConfigurationResponse) GetMetricsAddress 

func (x *GetFilerConfigurationResponse) GetMetricsAddress() string

func (*GetFilerConfigurationResponse) GetMetricsIntervalSec 

func (x *GetFilerConfigurationResponse) GetMetricsIntervalSec() int32

func (*GetFilerConfigurationResponse) GetReplication 

func (x *GetFilerConfigurationResponse) GetReplication() string

func (*GetFilerConfigurationResponse) GetSignature 

func (x *GetFilerConfigurationResponse) GetSignature() int32

func (*GetFilerConfigurationResponse) ProtoMessage 

func (*GetFilerConfigurationResponse) ProtoMessage()

func (*GetFilerConfigurationResponse) ProtoReflect 

func (x *GetFilerConfigurationResponse) ProtoReflect() protoreflect.Message

func (*GetFilerConfigurationResponse) Reset 

func (x *GetFilerConfigurationResponse) Reset()

func (*GetFilerConfigurationResponse) String 

func (x *GetFilerConfigurationResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*KeepConnectedRequest) Descriptor deprecated 

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

Deprecated: Use KeepConnectedRequest.ProtoReflect.Descriptor instead.

func (*KeepConnectedRequest) GetGrpcPort 

func (x *KeepConnectedRequest) GetGrpcPort() uint32

func (*KeepConnectedRequest) GetName 

func (x *KeepConnectedRequest) GetName() string

func (*KeepConnectedRequest) GetResources 

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

func (*KeepConnectedRequest) ProtoMessage 

func (*KeepConnectedRequest) ProtoMessage()

func (*KeepConnectedRequest) ProtoReflect 

func (x *KeepConnectedRequest) ProtoReflect() protoreflect.Message

func (*KeepConnectedRequest) Reset 

func (x *KeepConnectedRequest) Reset()

func (*KeepConnectedRequest) String 

func (x *KeepConnectedRequest) String() string

type KeepConnectedResponse 

type KeepConnectedResponse struct {
	// contains filtered or unexported fields
}

func (*KeepConnectedResponse) Descriptor deprecated 

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

Deprecated: Use KeepConnectedResponse.ProtoReflect.Descriptor instead.

func (*KeepConnectedResponse) ProtoMessage 

func (*KeepConnectedResponse) ProtoMessage()

func (*KeepConnectedResponse) ProtoReflect 

func (x *KeepConnectedResponse) ProtoReflect() protoreflect.Message

func (*KeepConnectedResponse) Reset 

func (x *KeepConnectedResponse) Reset()

func (*KeepConnectedResponse) String 

func (x *KeepConnectedResponse) String() string

type KvGetRequest 

type KvGetRequest struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Key-Value operations

func (*KvGetRequest) Descriptor deprecated 

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

Deprecated: Use KvGetRequest.ProtoReflect.Descriptor instead.

func (*KvGetRequest) GetKey 

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

func (*KvGetRequest) ProtoMessage 

func (*KvGetRequest) ProtoMessage()

func (*KvGetRequest) ProtoReflect 

func (x *KvGetRequest) ProtoReflect() protoreflect.Message

func (*KvGetRequest) Reset 

func (x *KvGetRequest) Reset()

func (*KvGetRequest) String 

func (x *KvGetRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*KvGetResponse) Descriptor deprecated 

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

Deprecated: Use KvGetResponse.ProtoReflect.Descriptor instead.

func (*KvGetResponse) GetError 

func (x *KvGetResponse) GetError() string

func (*KvGetResponse) GetValue 

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

func (*KvGetResponse) ProtoMessage 

func (*KvGetResponse) ProtoMessage()

func (*KvGetResponse) ProtoReflect 

func (x *KvGetResponse) ProtoReflect() protoreflect.Message

func (*KvGetResponse) Reset 

func (x *KvGetResponse) Reset()

func (*KvGetResponse) String 

func (x *KvGetResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*KvPutRequest) Descriptor deprecated 

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

Deprecated: Use KvPutRequest.ProtoReflect.Descriptor instead.

func (*KvPutRequest) GetKey 

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

func (*KvPutRequest) GetValue 

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

func (*KvPutRequest) ProtoMessage 

func (*KvPutRequest) ProtoMessage()

func (*KvPutRequest) ProtoReflect 

func (x *KvPutRequest) ProtoReflect() protoreflect.Message

func (*KvPutRequest) Reset 

func (x *KvPutRequest) Reset()

func (*KvPutRequest) String 

func (x *KvPutRequest) String() string

type KvPutResponse 

type KvPutResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*KvPutResponse) Descriptor deprecated 

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

Deprecated: Use KvPutResponse.ProtoReflect.Descriptor instead.

func (*KvPutResponse) GetError 

func (x *KvPutResponse) GetError() string

func (*KvPutResponse) ProtoMessage 

func (*KvPutResponse) ProtoMessage()

func (*KvPutResponse) ProtoReflect 

func (x *KvPutResponse) ProtoReflect() protoreflect.Message

func (*KvPutResponse) Reset 

func (x *KvPutResponse) Reset()

func (*KvPutResponse) String 

func (x *KvPutResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListEntriesRequest) Descriptor deprecated 

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

Deprecated: Use ListEntriesRequest.ProtoReflect.Descriptor instead.

func (*ListEntriesRequest) GetDirectory 

func (x *ListEntriesRequest) GetDirectory() string

func (*ListEntriesRequest) GetInclusiveStartFrom 

func (x *ListEntriesRequest) GetInclusiveStartFrom() bool

func (*ListEntriesRequest) GetLimit 

func (x *ListEntriesRequest) GetLimit() uint32

func (*ListEntriesRequest) GetPrefix 

func (x *ListEntriesRequest) GetPrefix() string

func (*ListEntriesRequest) GetStartFromFileName 

func (x *ListEntriesRequest) GetStartFromFileName() string

func (*ListEntriesRequest) ProtoMessage 

func (*ListEntriesRequest) ProtoMessage()

func (*ListEntriesRequest) ProtoReflect 

func (x *ListEntriesRequest) ProtoReflect() protoreflect.Message

func (*ListEntriesRequest) Reset 

func (x *ListEntriesRequest) Reset()

func (*ListEntriesRequest) String 

func (x *ListEntriesRequest) String() string

type ListEntriesResponse 

type ListEntriesResponse struct {
	Entry *Entry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEntriesResponse) Descriptor deprecated 

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

Deprecated: Use ListEntriesResponse.ProtoReflect.Descriptor instead.

func (*ListEntriesResponse) GetEntry 

func (x *ListEntriesResponse) GetEntry() *Entry

func (*ListEntriesResponse) ProtoMessage 

func (*ListEntriesResponse) ProtoMessage()

func (*ListEntriesResponse) ProtoReflect 

func (x *ListEntriesResponse) ProtoReflect() protoreflect.Message

func (*ListEntriesResponse) Reset 

func (x *ListEntriesResponse) Reset()

func (*ListEntriesResponse) String 

func (x *ListEntriesResponse) String() string

type LocateBrokerRequest 

type LocateBrokerRequest struct {
	Resource string `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*LocateBrokerRequest) Descriptor deprecated 

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

Deprecated: Use LocateBrokerRequest.ProtoReflect.Descriptor instead.

func (*LocateBrokerRequest) GetResource 

func (x *LocateBrokerRequest) GetResource() string

func (*LocateBrokerRequest) ProtoMessage 

func (*LocateBrokerRequest) ProtoMessage()

func (*LocateBrokerRequest) ProtoReflect 

func (x *LocateBrokerRequest) ProtoReflect() protoreflect.Message

func (*LocateBrokerRequest) Reset 

func (x *LocateBrokerRequest) Reset()

func (*LocateBrokerRequest) String 

func (x *LocateBrokerRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*LocateBrokerResponse) Descriptor deprecated 

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

Deprecated: Use LocateBrokerResponse.ProtoReflect.Descriptor instead.

func (*LocateBrokerResponse) GetFound 

func (x *LocateBrokerResponse) GetFound() bool

func (*LocateBrokerResponse) GetResources 

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

func (*LocateBrokerResponse) ProtoMessage 

func (*LocateBrokerResponse) ProtoMessage()

func (*LocateBrokerResponse) ProtoReflect 

func (x *LocateBrokerResponse) ProtoReflect() protoreflect.Message

func (*LocateBrokerResponse) Reset 

func (x *LocateBrokerResponse) Reset()

func (*LocateBrokerResponse) String 

func (x *LocateBrokerResponse) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*LocateBrokerResponse_Resource) Descriptor deprecated 

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

Deprecated: Use LocateBrokerResponse_Resource.ProtoReflect.Descriptor instead.

func (*LocateBrokerResponse_Resource) GetGrpcAddresses 

func (x *LocateBrokerResponse_Resource) GetGrpcAddresses() string

func (*LocateBrokerResponse_Resource) GetResourceCount 

func (x *LocateBrokerResponse_Resource) GetResourceCount() int32

func (*LocateBrokerResponse_Resource) ProtoMessage 

func (*LocateBrokerResponse_Resource) ProtoMessage()

func (*LocateBrokerResponse_Resource) ProtoReflect 

func (x *LocateBrokerResponse_Resource) ProtoReflect() protoreflect.Message

func (*LocateBrokerResponse_Resource) Reset 

func (x *LocateBrokerResponse_Resource) Reset()

func (*LocateBrokerResponse_Resource) String 

func (x *LocateBrokerResponse_Resource) String() string

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"`
	// contains filtered or unexported fields
}

func (*Location) Descriptor deprecated 

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

Deprecated: Use Location.ProtoReflect.Descriptor instead.

func (*Location) GetPublicUrl 

func (x *Location) GetPublicUrl() string

func (*Location) GetUrl 

func (x *Location) GetUrl() string

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) ProtoReflect 

func (x *Location) ProtoReflect() protoreflect.Message

func (*Location) Reset 

func (x *Location) Reset()

func (*Location) String 

func (x *Location) String() string

type Locations 

type Locations struct {
	Locations []*Location `protobuf:"bytes,1,rep,name=locations,proto3" json:"locations,omitempty"`
	// contains filtered or unexported fields
}

func (*Locations) Descriptor deprecated 

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

Deprecated: Use Locations.ProtoReflect.Descriptor instead.

func (*Locations) GetLocations 

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

func (*Locations) ProtoMessage 

func (*Locations) ProtoMessage()

func (*Locations) ProtoReflect 

func (x *Locations) ProtoReflect() protoreflect.Message

func (*Locations) Reset 

func (x *Locations) Reset()

func (*Locations) String 

func (x *Locations) String() string

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"`
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetData 

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

func (*LogEntry) GetPartitionKeyHash 

func (x *LogEntry) GetPartitionKeyHash() int32

func (*LogEntry) GetTsNs 

func (x *LogEntry) GetTsNs() int64

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

func (x *LogEntry) ProtoReflect() protoreflect.Message

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

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"`
	// contains filtered or unexported fields
}

func (*LookupDirectoryEntryRequest) Descriptor deprecated 

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

Deprecated: Use LookupDirectoryEntryRequest.ProtoReflect.Descriptor instead.

func (*LookupDirectoryEntryRequest) GetDirectory 

func (x *LookupDirectoryEntryRequest) GetDirectory() string

func (*LookupDirectoryEntryRequest) GetName 

func (x *LookupDirectoryEntryRequest) GetName() string

func (*LookupDirectoryEntryRequest) ProtoMessage 

func (*LookupDirectoryEntryRequest) ProtoMessage()

func (*LookupDirectoryEntryRequest) ProtoReflect 

func (x *LookupDirectoryEntryRequest) ProtoReflect() protoreflect.Message

func (*LookupDirectoryEntryRequest) Reset 

func (x *LookupDirectoryEntryRequest) Reset()

func (*LookupDirectoryEntryRequest) String 

func (x *LookupDirectoryEntryRequest) String() string

type LookupDirectoryEntryResponse 

type LookupDirectoryEntryResponse struct {
	Entry *Entry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func LookupEntry 

func LookupEntry(client SeaweedFilerClient, request *LookupDirectoryEntryRequest) (*LookupDirectoryEntryResponse, error)

func (*LookupDirectoryEntryResponse) Descriptor deprecated 

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

Deprecated: Use LookupDirectoryEntryResponse.ProtoReflect.Descriptor instead.

func (*LookupDirectoryEntryResponse) GetEntry 

func (x *LookupDirectoryEntryResponse) GetEntry() *Entry

func (*LookupDirectoryEntryResponse) ProtoMessage 

func (*LookupDirectoryEntryResponse) ProtoMessage()

func (*LookupDirectoryEntryResponse) ProtoReflect 

func (x *LookupDirectoryEntryResponse) ProtoReflect() protoreflect.Message

func (*LookupDirectoryEntryResponse) Reset 

func (x *LookupDirectoryEntryResponse) Reset()

func (*LookupDirectoryEntryResponse) String 

func (x *LookupDirectoryEntryResponse) String() string

type LookupVolumeRequest 

type LookupVolumeRequest struct {
	VolumeIds []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds,proto3" json:"volume_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupVolumeRequest) Descriptor deprecated 

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

Deprecated: Use LookupVolumeRequest.ProtoReflect.Descriptor instead.

func (*LookupVolumeRequest) GetVolumeIds 

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

func (*LookupVolumeRequest) ProtoMessage 

func (*LookupVolumeRequest) ProtoMessage()

func (*LookupVolumeRequest) ProtoReflect 

func (x *LookupVolumeRequest) ProtoReflect() protoreflect.Message

func (*LookupVolumeRequest) Reset 

func (x *LookupVolumeRequest) Reset()

func (*LookupVolumeRequest) String 

func (x *LookupVolumeRequest) String() string

type LookupVolumeResponse 

type LookupVolumeResponse struct {
	LocationsMap map[string]*Locations `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LookupVolumeResponse) Descriptor deprecated 

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

Deprecated: Use LookupVolumeResponse.ProtoReflect.Descriptor instead.

func (*LookupVolumeResponse) GetLocationsMap 

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

func (*LookupVolumeResponse) ProtoMessage 

func (*LookupVolumeResponse) ProtoMessage()

func (*LookupVolumeResponse) ProtoReflect 

func (x *LookupVolumeResponse) ProtoReflect() protoreflect.Message

func (*LookupVolumeResponse) Reset 

func (x *LookupVolumeResponse) Reset()

func (*LookupVolumeResponse) String 

func (x *LookupVolumeResponse) String() string

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.ClientConnInterface) 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"`
	// contains filtered or unexported fields
}

func (*StatisticsRequest) Descriptor deprecated 

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

Deprecated: Use StatisticsRequest.ProtoReflect.Descriptor instead.

func (*StatisticsRequest) GetCollection 

func (x *StatisticsRequest) GetCollection() string

func (*StatisticsRequest) GetReplication 

func (x *StatisticsRequest) GetReplication() string

func (*StatisticsRequest) GetTtl 

func (x *StatisticsRequest) GetTtl() string

func (*StatisticsRequest) ProtoMessage 

func (*StatisticsRequest) ProtoMessage()

func (*StatisticsRequest) ProtoReflect 

func (x *StatisticsRequest) ProtoReflect() protoreflect.Message

func (*StatisticsRequest) Reset 

func (x *StatisticsRequest) Reset()

func (*StatisticsRequest) String 

func (x *StatisticsRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*StatisticsResponse) Descriptor deprecated 

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

Deprecated: Use StatisticsResponse.ProtoReflect.Descriptor instead.

func (*StatisticsResponse) GetCollection 

func (x *StatisticsResponse) GetCollection() string

func (*StatisticsResponse) GetFileCount 

func (x *StatisticsResponse) GetFileCount() uint64

func (*StatisticsResponse) GetReplication 

func (x *StatisticsResponse) GetReplication() string

func (*StatisticsResponse) GetTotalSize 

func (x *StatisticsResponse) GetTotalSize() uint64

func (*StatisticsResponse) GetTtl 

func (x *StatisticsResponse) GetTtl() string

func (*StatisticsResponse) GetUsedSize 

func (x *StatisticsResponse) GetUsedSize() uint64

func (*StatisticsResponse) ProtoMessage 

func (*StatisticsResponse) ProtoMessage()

func (*StatisticsResponse) ProtoReflect 

func (x *StatisticsResponse) ProtoReflect() protoreflect.Message

func (*StatisticsResponse) Reset 

func (x *StatisticsResponse) Reset()

func (*StatisticsResponse) String 

func (x *StatisticsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*SubscribeMetadataRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeMetadataRequest.ProtoReflect.Descriptor instead.

func (*SubscribeMetadataRequest) GetClientName 

func (x *SubscribeMetadataRequest) GetClientName() string

func (*SubscribeMetadataRequest) GetPathPrefix 

func (x *SubscribeMetadataRequest) GetPathPrefix() string

func (*SubscribeMetadataRequest) GetSignature 

func (x *SubscribeMetadataRequest) GetSignature() int32

func (*SubscribeMetadataRequest) GetSinceNs 

func (x *SubscribeMetadataRequest) GetSinceNs() int64

func (*SubscribeMetadataRequest) ProtoMessage 

func (*SubscribeMetadataRequest) ProtoMessage()

func (*SubscribeMetadataRequest) ProtoReflect 

func (x *SubscribeMetadataRequest) ProtoReflect() protoreflect.Message

func (*SubscribeMetadataRequest) Reset 

func (x *SubscribeMetadataRequest) Reset()

func (*SubscribeMetadataRequest) String 

func (x *SubscribeMetadataRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*SubscribeMetadataResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeMetadataResponse.ProtoReflect.Descriptor instead.

func (*SubscribeMetadataResponse) GetDirectory 

func (x *SubscribeMetadataResponse) GetDirectory() string

func (*SubscribeMetadataResponse) GetEventNotification 

func (x *SubscribeMetadataResponse) GetEventNotification() *EventNotification

func (*SubscribeMetadataResponse) GetTsNs 

func (x *SubscribeMetadataResponse) GetTsNs() int64

func (*SubscribeMetadataResponse) ProtoMessage 

func (*SubscribeMetadataResponse) ProtoMessage()

func (*SubscribeMetadataResponse) ProtoReflect 

func (x *SubscribeMetadataResponse) ProtoReflect() protoreflect.Message

func (*SubscribeMetadataResponse) Reset 

func (x *SubscribeMetadataResponse) Reset()

func (*SubscribeMetadataResponse) String 

func (x *SubscribeMetadataResponse) String() string

type UnimplementedSeaweedFilerServer 

type UnimplementedSeaweedFilerServer struct {
}

UnimplementedSeaweedFilerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSeaweedFilerServer) AppendToEntry 

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

func (*UnimplementedSeaweedFilerServer) AssignVolume 

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

func (*UnimplementedSeaweedFilerServer) AtomicRenameEntry 

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

func (*UnimplementedSeaweedFilerServer) CreateEntry 

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

func (*UnimplementedSeaweedFilerServer) DeleteCollection 

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

func (*UnimplementedSeaweedFilerServer) DeleteEntry 

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

func (*UnimplementedSeaweedFilerServer) GetFilerConfiguration 

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

func (*UnimplementedSeaweedFilerServer) KeepConnected 

func (*UnimplementedSeaweedFilerServer) KeepConnected(SeaweedFiler_KeepConnectedServer) error

func (*UnimplementedSeaweedFilerServer) KvGet 

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

func (*UnimplementedSeaweedFilerServer) KvPut 

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

func (*UnimplementedSeaweedFilerServer) ListEntries 

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

func (*UnimplementedSeaweedFilerServer) LocateBroker 

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

func (*UnimplementedSeaweedFilerServer) LookupDirectoryEntry 

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

func (*UnimplementedSeaweedFilerServer) LookupVolume 

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

func (*UnimplementedSeaweedFilerServer) Statistics 

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

func (*UnimplementedSeaweedFilerServer) SubscribeLocalMetadata 

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

func (*UnimplementedSeaweedFilerServer) SubscribeMetadata 

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

func (*UnimplementedSeaweedFilerServer) UpdateEntry 

func (*UnimplementedSeaweedFilerServer) UpdateEntry(context.Context, *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"`
	// contains filtered or unexported fields
}

func (*UpdateEntryRequest) Descriptor deprecated 

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

Deprecated: Use UpdateEntryRequest.ProtoReflect.Descriptor instead.

func (*UpdateEntryRequest) GetDirectory 

func (x *UpdateEntryRequest) GetDirectory() string

func (*UpdateEntryRequest) GetEntry 

func (x *UpdateEntryRequest) GetEntry() *Entry

func (*UpdateEntryRequest) GetIsFromOtherCluster 

func (x *UpdateEntryRequest) GetIsFromOtherCluster() bool

func (*UpdateEntryRequest) GetSignatures 

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

func (*UpdateEntryRequest) ProtoMessage 

func (*UpdateEntryRequest) ProtoMessage()

func (*UpdateEntryRequest) ProtoReflect 

func (x *UpdateEntryRequest) ProtoReflect() protoreflect.Message

func (*UpdateEntryRequest) Reset 

func (x *UpdateEntryRequest) Reset()

func (*UpdateEntryRequest) String 

func (x *UpdateEntryRequest) String() string

type UpdateEntryResponse 

type UpdateEntryResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateEntryResponse) Descriptor deprecated 

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

Deprecated: Use UpdateEntryResponse.ProtoReflect.Descriptor instead.

func (*UpdateEntryResponse) ProtoMessage 

func (*UpdateEntryResponse) ProtoMessage()

func (*UpdateEntryResponse) ProtoReflect 

func (x *UpdateEntryResponse) ProtoReflect() protoreflect.Message

func (*UpdateEntryResponse) Reset 

func (x *UpdateEntryResponse) Reset()

func (*UpdateEntryResponse) String 

func (x *UpdateEntryResponse) String() string

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.