filer_pb

package
v0.0.0-...-0b345dd Latest Latest
Warning

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

 Go to latest Published: May 6, 2022 License: Apache-2.0 Imports: 20 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
View Source 
var SeaweedFiler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "filer_pb.SeaweedFiler",
	HandlerType: (*SeaweedFilerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LookupDirectoryEntry",
			Handler:    _SeaweedFiler_LookupDirectoryEntry_Handler,
		},
		{
			MethodName: "CreateEntry",
			Handler:    _SeaweedFiler_CreateEntry_Handler,
		},
		{
			MethodName: "UpdateEntry",
			Handler:    _SeaweedFiler_UpdateEntry_Handler,
		},
		{
			MethodName: "AppendToEntry",
			Handler:    _SeaweedFiler_AppendToEntry_Handler,
		},
		{
			MethodName: "DeleteEntry",
			Handler:    _SeaweedFiler_DeleteEntry_Handler,
		},
		{
			MethodName: "AtomicRenameEntry",
			Handler:    _SeaweedFiler_AtomicRenameEntry_Handler,
		},
		{
			MethodName: "AssignVolume",
			Handler:    _SeaweedFiler_AssignVolume_Handler,
		},
		{
			MethodName: "LookupVolume",
			Handler:    _SeaweedFiler_LookupVolume_Handler,
		},
		{
			MethodName: "CollectionList",
			Handler:    _SeaweedFiler_CollectionList_Handler,
		},
		{
			MethodName: "DeleteCollection",
			Handler:    _SeaweedFiler_DeleteCollection_Handler,
		},
		{
			MethodName: "Statistics",
			Handler:    _SeaweedFiler_Statistics_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _SeaweedFiler_Ping_Handler,
		},
		{
			MethodName: "GetFilerConfiguration",
			Handler:    _SeaweedFiler_GetFilerConfiguration_Handler,
		},
		{
			MethodName: "LocateBroker",
			Handler:    _SeaweedFiler_LocateBroker_Handler,
		},
		{
			MethodName: "KvGet",
			Handler:    _SeaweedFiler_KvGet_Handler,
		},
		{
			MethodName: "KvPut",
			Handler:    _SeaweedFiler_KvPut_Handler,
		},
		{
			MethodName: "CacheRemoteObjectToLocalCluster",
			Handler:    _SeaweedFiler_CacheRemoteObjectToLocalCluster_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListEntries",
			Handler:       _SeaweedFiler_ListEntries_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamRenameEntry",
			Handler:       _SeaweedFiler_StreamRenameEntry_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMetadata",
			Handler:       _SeaweedFiler_SubscribeMetadata_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeLocalMetadata",
			Handler:       _SeaweedFiler_SubscribeLocalMetadata_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "KeepConnected",
			Handler:       _SeaweedFiler_KeepConnected_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "filer.proto",
}

SeaweedFiler_ServiceDesc is the grpc.ServiceDesc for SeaweedFiler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func AfterEntryDeserialization 

func AfterEntryDeserialization(chunks []*FileChunk)

func BeforeEntrySerialization 

func BeforeEntrySerialization(chunks []*FileChunk)

func CreateEntry 

func CreateEntry(client SeaweedFilerClient, request *CreateEntryRequest) error

func DoMkdir 

func DoMkdir(client SeaweedFilerClient, parentDirectoryPath string, dirName string, fn func(entry *Entry)) error

func DoRemove 

func DoRemove(client SeaweedFilerClient, parentDirectoryPath string, name string, isDeleteData bool, isRecursive bool, ignoreRecursiveErr bool, isFromOtherCluster bool, signatures []int32) error

func EnsureFid 

func EnsureFid(chunk *FileChunk)

func Exists 

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

func IsCreate 

func IsCreate(event *SubscribeMetadataResponse) bool

func IsDelete 

func IsDelete(event *SubscribeMetadataResponse) bool

func IsEmpty 

func IsEmpty(event *SubscribeMetadataResponse) bool

func IsRename 

func IsRename(event *SubscribeMetadataResponse) bool

func IsUpdate 

func IsUpdate(event *SubscribeMetadataResponse) bool

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, fn func(entry *Entry)) 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.ServiceRegistrar, srv SeaweedFilerServer)

func Remove 

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

func SeaweedList 

func SeaweedList(client SeaweedFilerClient, parentDirectoryPath, prefix string, fn EachEntryFunciton, startFrom string, inclusive bool, limit uint32) (err error)

func Touch 

func Touch(filerClient FilerClient, parentDirectoryPath string, entryName string, entry *Entry) (err error)

func TraverseBfs 

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

func UpdateEntry 

func UpdateEntry(client SeaweedFilerClient, request *UpdateEntryRequest) 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"`
	Path        string `protobuf:"bytes,6,opt,name=path,proto3" json:"path,omitempty"`
	Rack        string `protobuf:"bytes,7,opt,name=rack,proto3" json:"rack,omitempty"`
	DataNode    string `protobuf:"bytes,9,opt,name=data_node,json=dataNode,proto3" json:"data_node,omitempty"`
	DiskType    string `protobuf:"bytes,8,opt,name=disk_type,json=diskType,proto3" json:"disk_type,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) GetDataNode 

func (x *AssignVolumeRequest) GetDataNode() string

func (*AssignVolumeRequest) GetDiskType 

func (x *AssignVolumeRequest) GetDiskType() string

func (*AssignVolumeRequest) GetPath 

func (x *AssignVolumeRequest) GetPath() string

func (*AssignVolumeRequest) GetRack 

func (x *AssignVolumeRequest) GetRack() 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"`
	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"`
	Location    *Location `protobuf:"bytes,9,opt,name=location,proto3" json:"location,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) GetLocation 

func (x *AssignVolumeResponse) GetLocation() *Location

func (*AssignVolumeResponse) GetReplication 

func (x *AssignVolumeResponse) GetReplication() 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"`
	Signatures   []int32 `protobuf:"varint,5,rep,packed,name=signatures,proto3" json:"signatures,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) GetSignatures 

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

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 CacheRemoteObjectToLocalClusterRequest 

type CacheRemoteObjectToLocalClusterRequest 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
}

/////////////////////// Remote Storage related ///////////////////////

func (*CacheRemoteObjectToLocalClusterRequest) Descriptor deprecated 

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

Deprecated: Use CacheRemoteObjectToLocalClusterRequest.ProtoReflect.Descriptor instead.

func (*CacheRemoteObjectToLocalClusterRequest) GetDirectory 

func (x *CacheRemoteObjectToLocalClusterRequest) GetDirectory() string

func (*CacheRemoteObjectToLocalClusterRequest) GetName 

func (x *CacheRemoteObjectToLocalClusterRequest) GetName() string

func (*CacheRemoteObjectToLocalClusterRequest) ProtoMessage 

func (*CacheRemoteObjectToLocalClusterRequest) ProtoMessage()

func (*CacheRemoteObjectToLocalClusterRequest) ProtoReflect 

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

func (*CacheRemoteObjectToLocalClusterRequest) Reset 

func (x *CacheRemoteObjectToLocalClusterRequest) Reset()

func (*CacheRemoteObjectToLocalClusterRequest) String 

func (x *CacheRemoteObjectToLocalClusterRequest) String() string

type CacheRemoteObjectToLocalClusterResponse 

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

func (*CacheRemoteObjectToLocalClusterResponse) Descriptor deprecated 

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

Deprecated: Use CacheRemoteObjectToLocalClusterResponse.ProtoReflect.Descriptor instead.

func (*CacheRemoteObjectToLocalClusterResponse) GetEntry 

func (x *CacheRemoteObjectToLocalClusterResponse) GetEntry() *Entry

func (*CacheRemoteObjectToLocalClusterResponse) ProtoMessage 

func (*CacheRemoteObjectToLocalClusterResponse) ProtoMessage()

func (*CacheRemoteObjectToLocalClusterResponse) ProtoReflect 

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

func (*CacheRemoteObjectToLocalClusterResponse) Reset 

func (x *CacheRemoteObjectToLocalClusterResponse) Reset()

func (*CacheRemoteObjectToLocalClusterResponse) String 

func (x *CacheRemoteObjectToLocalClusterResponse) String() string

type Collection 

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

func (*Collection) Descriptor deprecated 

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

Deprecated: Use Collection.ProtoReflect.Descriptor instead.

func (*Collection) GetName 

func (x *Collection) GetName() string

func (*Collection) ProtoMessage 

func (*Collection) ProtoMessage()

func (*Collection) ProtoReflect 

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

func (*Collection) Reset 

func (x *Collection) Reset()

func (*Collection) String 

func (x *Collection) String() string

type CollectionListRequest 

type CollectionListRequest struct {
	IncludeNormalVolumes bool `protobuf:"varint,1,opt,name=include_normal_volumes,json=includeNormalVolumes,proto3" json:"include_normal_volumes,omitempty"`
	IncludeEcVolumes     bool `protobuf:"varint,2,opt,name=include_ec_volumes,json=includeEcVolumes,proto3" json:"include_ec_volumes,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionListRequest) Descriptor deprecated 

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

Deprecated: Use CollectionListRequest.ProtoReflect.Descriptor instead.

func (*CollectionListRequest) GetIncludeEcVolumes 

func (x *CollectionListRequest) GetIncludeEcVolumes() bool

func (*CollectionListRequest) GetIncludeNormalVolumes 

func (x *CollectionListRequest) GetIncludeNormalVolumes() bool

func (*CollectionListRequest) ProtoMessage 

func (*CollectionListRequest) ProtoMessage()

func (*CollectionListRequest) ProtoReflect 

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

func (*CollectionListRequest) Reset 

func (x *CollectionListRequest) Reset()

func (*CollectionListRequest) String 

func (x *CollectionListRequest) String() string

type CollectionListResponse 

type CollectionListResponse struct {
	Collections []*Collection `protobuf:"bytes,1,rep,name=collections,proto3" json:"collections,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectionListResponse) Descriptor deprecated 

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

Deprecated: Use CollectionListResponse.ProtoReflect.Descriptor instead.

func (*CollectionListResponse) GetCollections 

func (x *CollectionListResponse) GetCollections() []*Collection

func (*CollectionListResponse) ProtoMessage 

func (*CollectionListResponse) ProtoMessage()

func (*CollectionListResponse) ProtoReflect 

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

func (*CollectionListResponse) Reset 

func (x *CollectionListResponse) Reset()

func (*CollectionListResponse) String 

func (x *CollectionListResponse) 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"`
	SkipCheckParentDirectory bool    `` /* 138-byte string literal not displayed */
	// 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) GetSkipCheckParentDirectory 

func (x *CreateEntryRequest) GetSkipCheckParentDirectory() bool

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 */
	HardLinkId      []byte            `protobuf:"bytes,7,opt,name=hard_link_id,json=hardLinkId,proto3" json:"hard_link_id,omitempty"`
	HardLinkCounter int32             `protobuf:"varint,8,opt,name=hard_link_counter,json=hardLinkCounter,proto3" json:"hard_link_counter,omitempty"` // only exists in hard link meta data
	Content         []byte            `protobuf:"bytes,9,opt,name=content,proto3" json:"content,omitempty"`                                           // if not empty, the file content
	RemoteEntry     *RemoteEntry      `protobuf:"bytes,10,opt,name=remote_entry,json=remoteEntry,proto3" json:"remote_entry,omitempty"`
	Quota           int64             `protobuf:"varint,11,opt,name=quota,proto3" json:"quota,omitempty"` // for bucket only. Positive/Negative means enabled/disabled.
	// 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) FileMode 

func (entry *Entry) FileMode() (fileMode os.FileMode)

func (*Entry) GetAttributes 

func (x *Entry) GetAttributes() *FuseAttributes

func (*Entry) GetChunks 

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

func (*Entry) GetContent 

func (x *Entry) GetContent() []byte

func (*Entry) GetExtended 

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

func (*Entry) GetHardLinkCounter 

func (x *Entry) GetHardLinkCounter() int32

func (*Entry) GetHardLinkId 

func (x *Entry) GetHardLinkId() []byte

func (*Entry) GetIsDirectory 

func (x *Entry) GetIsDirectory() bool

func (*Entry) GetName 

func (x *Entry) GetName() string

func (*Entry) GetQuota 

func (x *Entry) GetQuota() int64

func (*Entry) GetRemoteEntry 

func (x *Entry) GetRemoteEntry() *RemoteEntry

func (*Entry) IsInRemoteOnly 

func (entry *Entry) IsInRemoteOnly() bool

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(streamingMode bool, fn func(SeaweedFilerClient) error) error
	AdjustedUrl(location *Location) string
}

type FilerConf 

type FilerConf struct {
	Version   int32                 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Locations []*FilerConf_PathConf `protobuf:"bytes,2,rep,name=locations,proto3" json:"locations,omitempty"`
	// contains filtered or unexported fields
}

/////////////////////// path-based configurations ///////////////////////

func (*FilerConf) Descriptor deprecated 

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

Deprecated: Use FilerConf.ProtoReflect.Descriptor instead.

func (*FilerConf) GetLocations 

func (x *FilerConf) GetLocations() []*FilerConf_PathConf

func (*FilerConf) GetVersion 

func (x *FilerConf) GetVersion() int32

func (*FilerConf) ProtoMessage 

func (*FilerConf) ProtoMessage()

func (*FilerConf) ProtoReflect 

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

func (*FilerConf) Reset 

func (x *FilerConf) Reset()

func (*FilerConf) String 

func (x *FilerConf) String() string

type FilerConf_PathConf 

type FilerConf_PathConf struct {
	LocationPrefix    string `protobuf:"bytes,1,opt,name=location_prefix,json=locationPrefix,proto3" json:"location_prefix,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"`
	Ttl               string `protobuf:"bytes,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	DiskType          string `protobuf:"bytes,5,opt,name=disk_type,json=diskType,proto3" json:"disk_type,omitempty"`
	Fsync             bool   `protobuf:"varint,6,opt,name=fsync,proto3" json:"fsync,omitempty"`
	VolumeGrowthCount uint32 `protobuf:"varint,7,opt,name=volume_growth_count,json=volumeGrowthCount,proto3" json:"volume_growth_count,omitempty"`
	ReadOnly          bool   `protobuf:"varint,8,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	DataCenter        string `protobuf:"bytes,9,opt,name=data_center,json=dataCenter,proto3" json:"data_center,omitempty"`
	Rack              string `protobuf:"bytes,10,opt,name=rack,proto3" json:"rack,omitempty"`
	DataNode          string `protobuf:"bytes,11,opt,name=data_node,json=dataNode,proto3" json:"data_node,omitempty"`
	// contains filtered or unexported fields
}

func (*FilerConf_PathConf) Descriptor deprecated 

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

Deprecated: Use FilerConf_PathConf.ProtoReflect.Descriptor instead.

func (*FilerConf_PathConf) GetCollection 

func (x *FilerConf_PathConf) GetCollection() string

func (*FilerConf_PathConf) GetDataCenter 

func (x *FilerConf_PathConf) GetDataCenter() string

func (*FilerConf_PathConf) GetDataNode 

func (x *FilerConf_PathConf) GetDataNode() string

func (*FilerConf_PathConf) GetDiskType 

func (x *FilerConf_PathConf) GetDiskType() string

func (*FilerConf_PathConf) GetFsync 

func (x *FilerConf_PathConf) GetFsync() bool

func (*FilerConf_PathConf) GetLocationPrefix 

func (x *FilerConf_PathConf) GetLocationPrefix() string

func (*FilerConf_PathConf) GetRack 

func (x *FilerConf_PathConf) GetRack() string

func (*FilerConf_PathConf) GetReadOnly 

func (x *FilerConf_PathConf) GetReadOnly() bool

func (*FilerConf_PathConf) GetReplication 

func (x *FilerConf_PathConf) GetReplication() string

func (*FilerConf_PathConf) GetTtl 

func (x *FilerConf_PathConf) GetTtl() string

func (*FilerConf_PathConf) GetVolumeGrowthCount 

func (x *FilerConf_PathConf) GetVolumeGrowthCount() uint32

func (*FilerConf_PathConf) Key 

func (fp *FilerConf_PathConf) Key() interface{}

func (*FilerConf_PathConf) ProtoMessage 

func (*FilerConf_PathConf) ProtoMessage()

func (*FilerConf_PathConf) ProtoReflect 

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

func (*FilerConf_PathConf) Reset 

func (x *FilerConf_PathConf) Reset()

func (*FilerConf_PathConf) String 

func (x *FilerConf_PathConf) 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"`
	DiskType      string   `protobuf:"bytes,15,opt,name=disk_type,json=diskType,proto3" json:"disk_type,omitempty"`
	Rdev          uint32   `protobuf:"varint,16,opt,name=rdev,proto3" json:"rdev,omitempty"`
	Inode         uint64   `protobuf:"varint,17,opt,name=inode,proto3" json:"inode,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) GetDiskType 

func (x *FuseAttributes) GetDiskType() string

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) GetInode 

func (x *FuseAttributes) GetInode() uint64

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) GetRdev 

func (x *FuseAttributes) GetRdev() uint32

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"`
	Version            string   `protobuf:"bytes,11,opt,name=version,proto3" json:"version,omitempty"`
	ClusterId          string   `protobuf:"bytes,12,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,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) GetClusterId 

func (x *GetFilerConfigurationResponse) GetClusterId() string

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) GetVersion 

func (x *GetFilerConfigurationResponse) GetVersion() string

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"`
	GrpcPort  uint32 `protobuf:"varint,3,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
	// contains filtered or unexported fields
}

func (*Location) Descriptor deprecated 

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

Deprecated: Use Location.ProtoReflect.Descriptor instead.

func (*Location) GetGrpcPort 

func (x *Location) GetGrpcPort() uint32

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 PingRequest 

type PingRequest struct {
	Target     string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` // default to ping itself
	TargetType string `protobuf:"bytes,2,opt,name=target_type,json=targetType,proto3" json:"target_type,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetTarget 

func (x *PingRequest) GetTarget() string

func (*PingRequest) GetTargetType 

func (x *PingRequest) GetTargetType() string

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	StartTimeNs  int64 `protobuf:"varint,1,opt,name=start_time_ns,json=startTimeNs,proto3" json:"start_time_ns,omitempty"`
	RemoteTimeNs int64 `protobuf:"varint,2,opt,name=remote_time_ns,json=remoteTimeNs,proto3" json:"remote_time_ns,omitempty"`
	StopTimeNs   int64 `protobuf:"varint,3,opt,name=stop_time_ns,json=stopTimeNs,proto3" json:"stop_time_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetRemoteTimeNs 

func (x *PingResponse) GetRemoteTimeNs() int64

func (*PingResponse) GetStartTimeNs 

func (x *PingResponse) GetStartTimeNs() int64

func (*PingResponse) GetStopTimeNs 

func (x *PingResponse) GetStopTimeNs() int64

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type RemoteEntry 

type RemoteEntry struct {
	StorageName       string `protobuf:"bytes,1,opt,name=storage_name,json=storageName,proto3" json:"storage_name,omitempty"`
	LastLocalSyncTsNs int64  `protobuf:"varint,2,opt,name=last_local_sync_ts_ns,json=lastLocalSyncTsNs,proto3" json:"last_local_sync_ts_ns,omitempty"`
	RemoteETag        string `protobuf:"bytes,3,opt,name=remote_e_tag,json=remoteETag,proto3" json:"remote_e_tag,omitempty"`
	RemoteMtime       int64  `protobuf:"varint,4,opt,name=remote_mtime,json=remoteMtime,proto3" json:"remote_mtime,omitempty"`
	RemoteSize        int64  `protobuf:"varint,5,opt,name=remote_size,json=remoteSize,proto3" json:"remote_size,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteEntry) Descriptor deprecated 

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

Deprecated: Use RemoteEntry.ProtoReflect.Descriptor instead.

func (*RemoteEntry) GetLastLocalSyncTsNs 

func (x *RemoteEntry) GetLastLocalSyncTsNs() int64

func (*RemoteEntry) GetRemoteETag 

func (x *RemoteEntry) GetRemoteETag() string

func (*RemoteEntry) GetRemoteMtime 

func (x *RemoteEntry) GetRemoteMtime() int64

func (*RemoteEntry) GetRemoteSize 

func (x *RemoteEntry) GetRemoteSize() int64

func (*RemoteEntry) GetStorageName 

func (x *RemoteEntry) GetStorageName() string

func (*RemoteEntry) ProtoMessage 

func (*RemoteEntry) ProtoMessage()

func (*RemoteEntry) ProtoReflect 

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

func (*RemoteEntry) Reset 

func (x *RemoteEntry) Reset()

func (*RemoteEntry) String 

func (x *RemoteEntry) 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)
	StreamRenameEntry(ctx context.Context, in *StreamRenameEntryRequest, opts ...grpc.CallOption) (SeaweedFiler_StreamRenameEntryClient, error)
	AssignVolume(ctx context.Context, in *AssignVolumeRequest, opts ...grpc.CallOption) (*AssignVolumeResponse, error)
	LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error)
	CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error)
	DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error)
	Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, 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)
	CacheRemoteObjectToLocalCluster(ctx context.Context, in *CacheRemoteObjectToLocalClusterRequest, opts ...grpc.CallOption) (*CacheRemoteObjectToLocalClusterResponse, error)
}

SeaweedFilerClient is the client API for SeaweedFiler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#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)
	StreamRenameEntry(*StreamRenameEntryRequest, SeaweedFiler_StreamRenameEntryServer) error
	AssignVolume(context.Context, *AssignVolumeRequest) (*AssignVolumeResponse, error)
	LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error)
	CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error)
	DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
	Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
	Ping(context.Context, *PingRequest) (*PingResponse, 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)
	CacheRemoteObjectToLocalCluster(context.Context, *CacheRemoteObjectToLocalClusterRequest) (*CacheRemoteObjectToLocalClusterResponse, error)
	// contains filtered or unexported methods
}

SeaweedFilerServer is the server API for SeaweedFiler service. All implementations must embed UnimplementedSeaweedFilerServer for forward compatibility

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_StreamRenameEntryClient 

type SeaweedFiler_StreamRenameEntryClient interface {
	Recv() (*StreamRenameEntryResponse, error)
	grpc.ClientStream
}

type SeaweedFiler_StreamRenameEntryServer 

type SeaweedFiler_StreamRenameEntryServer interface {
	Send(*StreamRenameEntryResponse) 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"`
	DiskType    string `protobuf:"bytes,4,opt,name=disk_type,json=diskType,proto3" json:"disk_type,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) GetDiskType 

func (x *StatisticsRequest) GetDiskType() 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 {
	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) GetFileCount 

func (x *StatisticsResponse) GetFileCount() uint64

func (*StatisticsResponse) GetTotalSize 

func (x *StatisticsResponse) GetTotalSize() uint64

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 StreamRenameEntryRequest 

type StreamRenameEntryRequest 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"`
	Signatures   []int32 `protobuf:"varint,5,rep,packed,name=signatures,proto3" json:"signatures,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRenameEntryRequest) Descriptor deprecated 

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

Deprecated: Use StreamRenameEntryRequest.ProtoReflect.Descriptor instead.

func (*StreamRenameEntryRequest) GetNewDirectory 

func (x *StreamRenameEntryRequest) GetNewDirectory() string

func (*StreamRenameEntryRequest) GetNewName 

func (x *StreamRenameEntryRequest) GetNewName() string

func (*StreamRenameEntryRequest) GetOldDirectory 

func (x *StreamRenameEntryRequest) GetOldDirectory() string

func (*StreamRenameEntryRequest) GetOldName 

func (x *StreamRenameEntryRequest) GetOldName() string

func (*StreamRenameEntryRequest) GetSignatures 

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

func (*StreamRenameEntryRequest) ProtoMessage 

func (*StreamRenameEntryRequest) ProtoMessage()

func (*StreamRenameEntryRequest) ProtoReflect 

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

func (*StreamRenameEntryRequest) Reset 

func (x *StreamRenameEntryRequest) Reset()

func (*StreamRenameEntryRequest) String 

func (x *StreamRenameEntryRequest) String() string

type StreamRenameEntryResponse 

type StreamRenameEntryResponse 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 (*StreamRenameEntryResponse) Descriptor deprecated 

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

Deprecated: Use StreamRenameEntryResponse.ProtoReflect.Descriptor instead.

func (*StreamRenameEntryResponse) GetDirectory 

func (x *StreamRenameEntryResponse) GetDirectory() string

func (*StreamRenameEntryResponse) GetEventNotification 

func (x *StreamRenameEntryResponse) GetEventNotification() *EventNotification

func (*StreamRenameEntryResponse) GetTsNs 

func (x *StreamRenameEntryResponse) GetTsNs() int64

func (*StreamRenameEntryResponse) ProtoMessage 

func (*StreamRenameEntryResponse) ProtoMessage()

func (*StreamRenameEntryResponse) ProtoReflect 

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

func (*StreamRenameEntryResponse) Reset 

func (x *StreamRenameEntryResponse) Reset()

func (*StreamRenameEntryResponse) String 

func (x *StreamRenameEntryResponse) 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"`
	PathPrefixes []string `protobuf:"bytes,6,rep,name=path_prefixes,json=pathPrefixes,proto3" json:"path_prefixes,omitempty"`
	ClientId     int32    `protobuf:"varint,7,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeMetadataRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeMetadataRequest.ProtoReflect.Descriptor instead.

func (*SubscribeMetadataRequest) GetClientId 

func (x *SubscribeMetadataRequest) GetClientId() int32

func (*SubscribeMetadataRequest) GetClientName 

func (x *SubscribeMetadataRequest) GetClientName() string

func (*SubscribeMetadataRequest) GetPathPrefix 

func (x *SubscribeMetadataRequest) GetPathPrefix() string

func (*SubscribeMetadataRequest) GetPathPrefixes 

func (x *SubscribeMetadataRequest) GetPathPrefixes() []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 must 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) CacheRemoteObjectToLocalCluster 

func (UnimplementedSeaweedFilerServer) CacheRemoteObjectToLocalCluster(context.Context, *CacheRemoteObjectToLocalClusterRequest) (*CacheRemoteObjectToLocalClusterResponse, error)

func (UnimplementedSeaweedFilerServer) CollectionList 

func (UnimplementedSeaweedFilerServer) CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, 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) Ping 

func (UnimplementedSeaweedFilerServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedSeaweedFilerServer) Statistics 

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

func (UnimplementedSeaweedFilerServer) StreamRenameEntry 

func (UnimplementedSeaweedFilerServer) StreamRenameEntry(*StreamRenameEntryRequest, SeaweedFiler_StreamRenameEntryServer) 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 UnsafeSeaweedFilerServer 

type UnsafeSeaweedFilerServer interface {
	// contains filtered or unexported methods
}

UnsafeSeaweedFilerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SeaweedFilerServer will result in compilation errors.

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.