pb

package
v0.0.0-...-7570391 Latest Latest
Warning

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

Go to latest
Published: Mar 14, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	INodeType_name = map[int32]string{
		0: "FILE",
		1: "DIR",
	}
	INodeType_value = map[string]int32{
		"FILE": 0,
		"DIR":  1,
	}
)

Enum value maps for INodeType.

View Source
var BlobstoreService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.BlobstoreService",
	HandlerType: (*BlobstoreServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetConfig",
			Handler:    _BlobstoreService_GetConfig_Handler,
		},
		{
			MethodName: "GetEntries",
			Handler:    _BlobstoreService_GetEntries_Handler,
		},
		{
			MethodName: "ReduceCache",
			Handler:    _BlobstoreService_ReduceCache_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "otaru.proto",
}

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

View Source
var FeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.FeService",
	HandlerType: (*FeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListHosts",
			Handler:    _FeService_ListHosts_Handler,
		},
		{
			MethodName: "ListLocalDir",
			Handler:    _FeService_ListLocalDir_Handler,
		},
		{
			MethodName: "MkdirLocal",
			Handler:    _FeService_MkdirLocal_Handler,
		},
		{
			MethodName: "CopyLocal",
			Handler:    _FeService_CopyLocal_Handler,
		},
		{
			MethodName: "MoveLocal",
			Handler:    _FeService_MoveLocal_Handler,
		},
		{
			MethodName: "Download",
			Handler:    _FeService_Download_Handler,
		},
		{
			MethodName: "Upload",
			Handler:    _FeService_Upload_Handler,
		},
		{
			MethodName: "RemoteMove",
			Handler:    _FeService_RemoteMove_Handler,
		},
		{
			MethodName: "RemoveLocal",
			Handler:    _FeService_RemoveLocal_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "otaru.proto",
}

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

View Source
var FileSystemService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.FileSystemService",
	HandlerType: (*FileSystemServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListDir",
			Handler:    _FileSystemService_ListDir_Handler,
		},
		{
			MethodName: "FindNodeFullPath",
			Handler:    _FileSystemService_FindNodeFullPath_Handler,
		},
		{
			MethodName: "Attr",
			Handler:    _FileSystemService_Attr_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _FileSystemService_Create_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _FileSystemService_Remove_Handler,
		},
		{
			MethodName: "ReadFile",
			Handler:    _FileSystemService_ReadFile_Handler,
		},
		{
			MethodName: "WriteFile",
			Handler:    _FileSystemService_WriteFile_Handler,
		},
		{
			MethodName: "Rename",
			Handler:    _FileSystemService_Rename_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "otaru.proto",
}

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

View Source
var File_otaru_proto protoreflect.FileDescriptor
View Source
var INodeDBService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.INodeDBService",
	HandlerType: (*INodeDBServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetINodeDBStats",
			Handler:    _INodeDBService_GetINodeDBStats_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "otaru.proto",
}

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

View Source
var SystemInfoService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.SystemInfoService",
	HandlerType: (*SystemInfoServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSystemInfo",
			Handler:    _SystemInfoService_GetSystemInfo_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _SystemInfoService_GetVersion_Handler,
		},
		{
			MethodName: "Whoami",
			Handler:    _SystemInfoService_Whoami_Handler,
		},
		{
			MethodName: "AuthTestAnonymous",
			Handler:    _SystemInfoService_AuthTestAnonymous_Handler,
		},
		{
			MethodName: "AuthTestReadOnly",
			Handler:    _SystemInfoService_AuthTestReadOnly_Handler,
		},
		{
			MethodName: "AuthTestAdmin",
			Handler:    _SystemInfoService_AuthTestAdmin_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "otaru.proto",
}

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

Functions

func RegisterBlobstoreServiceHandler

func RegisterBlobstoreServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBlobstoreServiceHandler registers the http handlers for service BlobstoreService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBlobstoreServiceHandlerClient

func RegisterBlobstoreServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BlobstoreServiceClient) error

RegisterBlobstoreServiceHandlerClient registers the http handlers for service BlobstoreService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BlobstoreServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BlobstoreServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BlobstoreServiceClient" to call the correct interceptors.

func RegisterBlobstoreServiceHandlerFromEndpoint

func RegisterBlobstoreServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBlobstoreServiceHandlerFromEndpoint is same as RegisterBlobstoreServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBlobstoreServiceHandlerServer

func RegisterBlobstoreServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BlobstoreServiceServer) error

RegisterBlobstoreServiceHandlerServer registers the http handlers for service BlobstoreService to "mux". UnaryRPC :call BlobstoreServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBlobstoreServiceHandlerFromEndpoint instead.

func RegisterBlobstoreServiceServer

func RegisterBlobstoreServiceServer(s grpc.ServiceRegistrar, srv BlobstoreServiceServer)

func RegisterFeServiceHandler

func RegisterFeServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterFeServiceHandler registers the http handlers for service FeService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterFeServiceHandlerClient

func RegisterFeServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FeServiceClient) error

RegisterFeServiceHandlerClient registers the http handlers for service FeService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FeServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FeServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FeServiceClient" to call the correct interceptors.

func RegisterFeServiceHandlerFromEndpoint

func RegisterFeServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterFeServiceHandlerFromEndpoint is same as RegisterFeServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterFeServiceHandlerServer

func RegisterFeServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FeServiceServer) error

RegisterFeServiceHandlerServer registers the http handlers for service FeService to "mux". UnaryRPC :call FeServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterFeServiceHandlerFromEndpoint instead.

func RegisterFeServiceServer

func RegisterFeServiceServer(s grpc.ServiceRegistrar, srv FeServiceServer)

func RegisterFileSystemServiceHandler

func RegisterFileSystemServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterFileSystemServiceHandler registers the http handlers for service FileSystemService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterFileSystemServiceHandlerClient

func RegisterFileSystemServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FileSystemServiceClient) error

RegisterFileSystemServiceHandlerClient registers the http handlers for service FileSystemService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FileSystemServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FileSystemServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FileSystemServiceClient" to call the correct interceptors.

func RegisterFileSystemServiceHandlerFromEndpoint

func RegisterFileSystemServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterFileSystemServiceHandlerFromEndpoint is same as RegisterFileSystemServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterFileSystemServiceHandlerServer

func RegisterFileSystemServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FileSystemServiceServer) error

RegisterFileSystemServiceHandlerServer registers the http handlers for service FileSystemService to "mux". UnaryRPC :call FileSystemServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterFileSystemServiceHandlerFromEndpoint instead.

func RegisterFileSystemServiceServer

func RegisterFileSystemServiceServer(s grpc.ServiceRegistrar, srv FileSystemServiceServer)

func RegisterINodeDBServiceHandler

func RegisterINodeDBServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterINodeDBServiceHandler registers the http handlers for service INodeDBService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterINodeDBServiceHandlerClient

func RegisterINodeDBServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client INodeDBServiceClient) error

RegisterINodeDBServiceHandlerClient registers the http handlers for service INodeDBService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "INodeDBServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "INodeDBServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "INodeDBServiceClient" to call the correct interceptors.

func RegisterINodeDBServiceHandlerFromEndpoint

func RegisterINodeDBServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterINodeDBServiceHandlerFromEndpoint is same as RegisterINodeDBServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterINodeDBServiceHandlerServer

func RegisterINodeDBServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server INodeDBServiceServer) error

RegisterINodeDBServiceHandlerServer registers the http handlers for service INodeDBService to "mux". UnaryRPC :call INodeDBServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterINodeDBServiceHandlerFromEndpoint instead.

func RegisterINodeDBServiceServer

func RegisterINodeDBServiceServer(s grpc.ServiceRegistrar, srv INodeDBServiceServer)

func RegisterSystemInfoServiceHandler

func RegisterSystemInfoServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSystemInfoServiceHandler registers the http handlers for service SystemInfoService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSystemInfoServiceHandlerClient

func RegisterSystemInfoServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SystemInfoServiceClient) error

RegisterSystemInfoServiceHandlerClient registers the http handlers for service SystemInfoService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SystemInfoServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SystemInfoServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SystemInfoServiceClient" to call the correct interceptors.

func RegisterSystemInfoServiceHandlerFromEndpoint

func RegisterSystemInfoServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSystemInfoServiceHandlerFromEndpoint is same as RegisterSystemInfoServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSystemInfoServiceHandlerServer

func RegisterSystemInfoServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SystemInfoServiceServer) error

RegisterSystemInfoServiceHandlerServer registers the http handlers for service SystemInfoService to "mux". UnaryRPC :call SystemInfoServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSystemInfoServiceHandlerFromEndpoint instead.

func RegisterSystemInfoServiceServer

func RegisterSystemInfoServiceServer(s grpc.ServiceRegistrar, srv SystemInfoServiceServer)

Types

type AttrRequest

type AttrRequest struct {

	// If |id| == 0, then query path.
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*AttrRequest) Descriptor deprecated

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

Deprecated: Use AttrRequest.ProtoReflect.Descriptor instead.

func (*AttrRequest) GetId

func (x *AttrRequest) GetId() uint64

func (*AttrRequest) GetPath

func (x *AttrRequest) GetPath() string

func (*AttrRequest) ProtoMessage

func (*AttrRequest) ProtoMessage()

func (*AttrRequest) ProtoReflect

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

func (*AttrRequest) Reset

func (x *AttrRequest) Reset()

func (*AttrRequest) String

func (x *AttrRequest) String() string

type AttrResponse

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

func (*AttrResponse) Descriptor deprecated

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

Deprecated: Use AttrResponse.ProtoReflect.Descriptor instead.

func (*AttrResponse) GetEntry

func (x *AttrResponse) GetEntry() *INodeView

func (*AttrResponse) ProtoMessage

func (*AttrResponse) ProtoMessage()

func (*AttrResponse) ProtoReflect

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

func (*AttrResponse) Reset

func (x *AttrResponse) Reset()

func (*AttrResponse) String

func (x *AttrResponse) String() string

type AuthTestRequest

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

func (*AuthTestRequest) Descriptor deprecated

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

Deprecated: Use AuthTestRequest.ProtoReflect.Descriptor instead.

func (*AuthTestRequest) ProtoMessage

func (*AuthTestRequest) ProtoMessage()

func (*AuthTestRequest) ProtoReflect

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

func (*AuthTestRequest) Reset

func (x *AuthTestRequest) Reset()

func (*AuthTestRequest) String

func (x *AuthTestRequest) String() string

type AuthTestResponse

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

func (*AuthTestResponse) Descriptor deprecated

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

Deprecated: Use AuthTestResponse.ProtoReflect.Descriptor instead.

func (*AuthTestResponse) ProtoMessage

func (*AuthTestResponse) ProtoMessage()

func (*AuthTestResponse) ProtoReflect

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

func (*AuthTestResponse) Reset

func (x *AuthTestResponse) Reset()

func (*AuthTestResponse) String

func (x *AuthTestResponse) String() string

type BlobstoreServiceClient

type BlobstoreServiceClient interface {
	GetConfig(ctx context.Context, in *GetBlobstoreConfigRequest, opts ...grpc.CallOption) (*GetBlobstoreConfigResponse, error)
	GetEntries(ctx context.Context, in *GetEntriesRequest, opts ...grpc.CallOption) (*GetEntriesResponse, error)
	ReduceCache(ctx context.Context, in *ReduceCacheRequest, opts ...grpc.CallOption) (*ReduceCacheResponse, error)
}

BlobstoreServiceClient is the client API for BlobstoreService 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.

type BlobstoreServiceServer

type BlobstoreServiceServer interface {
	GetConfig(context.Context, *GetBlobstoreConfigRequest) (*GetBlobstoreConfigResponse, error)
	GetEntries(context.Context, *GetEntriesRequest) (*GetEntriesResponse, error)
	ReduceCache(context.Context, *ReduceCacheRequest) (*ReduceCacheResponse, error)
	// contains filtered or unexported methods
}

BlobstoreServiceServer is the server API for BlobstoreService service. All implementations must embed UnimplementedBlobstoreServiceServer for forward compatibility

type CopyLocalRequest

type CopyLocalRequest struct {
	PathSrc  string `protobuf:"bytes,1,opt,name=path_src,json=pathSrc,proto3" json:"path_src,omitempty"`
	PathDest string `protobuf:"bytes,2,opt,name=path_dest,json=pathDest,proto3" json:"path_dest,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyLocalRequest) Descriptor deprecated

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

Deprecated: Use CopyLocalRequest.ProtoReflect.Descriptor instead.

func (*CopyLocalRequest) GetPathDest

func (x *CopyLocalRequest) GetPathDest() string

func (*CopyLocalRequest) GetPathSrc

func (x *CopyLocalRequest) GetPathSrc() string

func (*CopyLocalRequest) ProtoMessage

func (*CopyLocalRequest) ProtoMessage()

func (*CopyLocalRequest) ProtoReflect

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

func (*CopyLocalRequest) Reset

func (x *CopyLocalRequest) Reset()

func (*CopyLocalRequest) String

func (x *CopyLocalRequest) String() string

type CopyLocalResponse

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

func (*CopyLocalResponse) Descriptor deprecated

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

Deprecated: Use CopyLocalResponse.ProtoReflect.Descriptor instead.

func (*CopyLocalResponse) ProtoMessage

func (*CopyLocalResponse) ProtoMessage()

func (*CopyLocalResponse) ProtoReflect

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

func (*CopyLocalResponse) Reset

func (x *CopyLocalResponse) Reset()

func (*CopyLocalResponse) String

func (x *CopyLocalResponse) String() string

type CreateRequest

type CreateRequest struct {

	// If |dir_id| == 0, then treat |name| as fullpath.
	DirId        uint64    `protobuf:"varint,1,opt,name=dir_id,json=dirId,proto3" json:"dir_id,omitempty"`
	Name         string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Uid          uint32    `protobuf:"varint,3,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid          uint32    `protobuf:"varint,4,opt,name=gid,proto3" json:"gid,omitempty"`
	PermMode     uint32    `protobuf:"varint,5,opt,name=perm_mode,json=permMode,proto3" json:"perm_mode,omitempty"`
	ModifiedTime int64     `protobuf:"varint,6,opt,name=modified_time,json=modifiedTime,proto3" json:"modified_time,omitempty"`
	Type         INodeType `protobuf:"varint,7,opt,name=type,proto3,enum=pb.INodeType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetDirId

func (x *CreateRequest) GetDirId() uint64

func (*CreateRequest) GetGid

func (x *CreateRequest) GetGid() uint32

func (*CreateRequest) GetModifiedTime

func (x *CreateRequest) GetModifiedTime() int64

func (*CreateRequest) GetName

func (x *CreateRequest) GetName() string

func (*CreateRequest) GetPermMode

func (x *CreateRequest) GetPermMode() uint32

func (*CreateRequest) GetType

func (x *CreateRequest) GetType() INodeType

func (*CreateRequest) GetUid

func (x *CreateRequest) GetUid() uint32

func (*CreateRequest) ProtoMessage

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect

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

func (*CreateRequest) Reset

func (x *CreateRequest) Reset()

func (*CreateRequest) String

func (x *CreateRequest) String() string

type CreateResponse

type CreateResponse struct {
	Id    uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	IsNew bool   `protobuf:"varint,2,opt,name=is_new,json=isNew,proto3" json:"is_new,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetId

func (x *CreateResponse) GetId() uint64

func (*CreateResponse) GetIsNew

func (x *CreateResponse) GetIsNew() bool

func (*CreateResponse) ProtoMessage

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect

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

func (*CreateResponse) Reset

func (x *CreateResponse) Reset()

func (*CreateResponse) String

func (x *CreateResponse) String() string

type DownloadRequest

type DownloadRequest struct {
	OpathSrc       string `protobuf:"bytes,1,opt,name=opath_src,json=opathSrc,proto3" json:"opath_src,omitempty"`
	PathDest       string `protobuf:"bytes,2,opt,name=path_dest,json=pathDest,proto3" json:"path_dest,omitempty"`
	AllowOverwrite bool   `protobuf:"varint,3,opt,name=allow_overwrite,json=allowOverwrite,proto3" json:"allow_overwrite,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadRequest) Descriptor deprecated

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

Deprecated: Use DownloadRequest.ProtoReflect.Descriptor instead.

func (*DownloadRequest) GetAllowOverwrite

func (x *DownloadRequest) GetAllowOverwrite() bool

func (*DownloadRequest) GetOpathSrc

func (x *DownloadRequest) GetOpathSrc() string

func (*DownloadRequest) GetPathDest

func (x *DownloadRequest) GetPathDest() string

func (*DownloadRequest) ProtoMessage

func (*DownloadRequest) ProtoMessage()

func (*DownloadRequest) ProtoReflect

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

func (*DownloadRequest) Reset

func (x *DownloadRequest) Reset()

func (*DownloadRequest) String

func (x *DownloadRequest) String() string

type DownloadResponse

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

func (*DownloadResponse) Descriptor deprecated

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

Deprecated: Use DownloadResponse.ProtoReflect.Descriptor instead.

func (*DownloadResponse) ProtoMessage

func (*DownloadResponse) ProtoMessage()

func (*DownloadResponse) ProtoReflect

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

func (*DownloadResponse) Reset

func (x *DownloadResponse) Reset()

func (*DownloadResponse) String

func (x *DownloadResponse) String() string

type FeServiceClient

FeServiceClient is the client API for FeService 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 NewFeServiceClient

func NewFeServiceClient(cc grpc.ClientConnInterface) FeServiceClient

type FeServiceServer

FeServiceServer is the server API for FeService service. All implementations must embed UnimplementedFeServiceServer for forward compatibility

type FileInfo

type FileInfo struct {
	Name         string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type         INodeType `protobuf:"varint,2,opt,name=type,proto3,enum=pb.INodeType" json:"type,omitempty"`
	Size         int64     `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	PermMode     uint32    `protobuf:"varint,4,opt,name=perm_mode,json=permMode,proto3" json:"perm_mode,omitempty"`
	ModifiedTime int64     `protobuf:"varint,5,opt,name=modified_time,json=modifiedTime,proto3" json:"modified_time,omitempty"`
	// contains filtered or unexported fields
}

func (*FileInfo) Descriptor deprecated

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

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetModifiedTime

func (x *FileInfo) GetModifiedTime() int64

func (*FileInfo) GetName

func (x *FileInfo) GetName() string

func (*FileInfo) GetPermMode

func (x *FileInfo) GetPermMode() uint32

func (*FileInfo) GetSize

func (x *FileInfo) GetSize() int64

func (*FileInfo) GetType

func (x *FileInfo) GetType() INodeType

func (*FileInfo) ProtoMessage

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect

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

func (*FileInfo) Reset

func (x *FileInfo) Reset()

func (*FileInfo) String

func (x *FileInfo) String() string

type FileSystemServiceClient

type FileSystemServiceClient interface {
	ListDir(ctx context.Context, in *ListDirRequest, opts ...grpc.CallOption) (*ListDirResponse, error)
	FindNodeFullPath(ctx context.Context, in *FindNodeFullPathRequest, opts ...grpc.CallOption) (*FindNodeFullPathResponse, error)
	Attr(ctx context.Context, in *AttrRequest, opts ...grpc.CallOption) (*AttrResponse, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	ReadFile(ctx context.Context, in *ReadFileRequest, opts ...grpc.CallOption) (*ReadFileResponse, error)
	WriteFile(ctx context.Context, in *WriteFileRequest, opts ...grpc.CallOption) (*WriteFileResponse, error)
	Rename(ctx context.Context, in *RenameRequest, opts ...grpc.CallOption) (*RenameResponse, error)
}

FileSystemServiceClient is the client API for FileSystemService 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.

type FileSystemServiceServer

FileSystemServiceServer is the server API for FileSystemService service. All implementations must embed UnimplementedFileSystemServiceServer for forward compatibility

type FindNodeFullPathRequest

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

func (*FindNodeFullPathRequest) Descriptor deprecated

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

Deprecated: Use FindNodeFullPathRequest.ProtoReflect.Descriptor instead.

func (*FindNodeFullPathRequest) GetPath

func (x *FindNodeFullPathRequest) GetPath() string

func (*FindNodeFullPathRequest) ProtoMessage

func (*FindNodeFullPathRequest) ProtoMessage()

func (*FindNodeFullPathRequest) ProtoReflect

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

func (*FindNodeFullPathRequest) Reset

func (x *FindNodeFullPathRequest) Reset()

func (*FindNodeFullPathRequest) String

func (x *FindNodeFullPathRequest) String() string

type FindNodeFullPathResponse

type FindNodeFullPathResponse struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*FindNodeFullPathResponse) Descriptor deprecated

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

Deprecated: Use FindNodeFullPathResponse.ProtoReflect.Descriptor instead.

func (*FindNodeFullPathResponse) GetId

func (x *FindNodeFullPathResponse) GetId() uint64

func (*FindNodeFullPathResponse) ProtoMessage

func (*FindNodeFullPathResponse) ProtoMessage()

func (*FindNodeFullPathResponse) ProtoReflect

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

func (*FindNodeFullPathResponse) Reset

func (x *FindNodeFullPathResponse) Reset()

func (*FindNodeFullPathResponse) String

func (x *FindNodeFullPathResponse) String() string

type GetBlobstoreConfigRequest

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

func (*GetBlobstoreConfigRequest) Descriptor deprecated

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

Deprecated: Use GetBlobstoreConfigRequest.ProtoReflect.Descriptor instead.

func (*GetBlobstoreConfigRequest) ProtoMessage

func (*GetBlobstoreConfigRequest) ProtoMessage()

func (*GetBlobstoreConfigRequest) ProtoReflect

func (*GetBlobstoreConfigRequest) Reset

func (x *GetBlobstoreConfigRequest) Reset()

func (*GetBlobstoreConfigRequest) String

func (x *GetBlobstoreConfigRequest) String() string

type GetBlobstoreConfigResponse

type GetBlobstoreConfigResponse struct {
	BackendImplName string `protobuf:"bytes,1,opt,name=backend_impl_name,json=backendImplName,proto3" json:"backend_impl_name,omitempty"`
	BackendFlags    string `protobuf:"bytes,2,opt,name=backend_flags,json=backendFlags,proto3" json:"backend_flags,omitempty"`
	CacheImplName   string `protobuf:"bytes,3,opt,name=cache_impl_name,json=cacheImplName,proto3" json:"cache_impl_name,omitempty"`
	CacheFlags      string `protobuf:"bytes,4,opt,name=cache_flags,json=cacheFlags,proto3" json:"cache_flags,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlobstoreConfigResponse) Descriptor deprecated

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

Deprecated: Use GetBlobstoreConfigResponse.ProtoReflect.Descriptor instead.

func (*GetBlobstoreConfigResponse) GetBackendFlags

func (x *GetBlobstoreConfigResponse) GetBackendFlags() string

func (*GetBlobstoreConfigResponse) GetBackendImplName

func (x *GetBlobstoreConfigResponse) GetBackendImplName() string

func (*GetBlobstoreConfigResponse) GetCacheFlags

func (x *GetBlobstoreConfigResponse) GetCacheFlags() string

func (*GetBlobstoreConfigResponse) GetCacheImplName

func (x *GetBlobstoreConfigResponse) GetCacheImplName() string

func (*GetBlobstoreConfigResponse) ProtoMessage

func (*GetBlobstoreConfigResponse) ProtoMessage()

func (*GetBlobstoreConfigResponse) ProtoReflect

func (*GetBlobstoreConfigResponse) Reset

func (x *GetBlobstoreConfigResponse) Reset()

func (*GetBlobstoreConfigResponse) String

func (x *GetBlobstoreConfigResponse) String() string

type GetCategoriesRequest

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

func (*GetCategoriesRequest) Descriptor deprecated

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

Deprecated: Use GetCategoriesRequest.ProtoReflect.Descriptor instead.

func (*GetCategoriesRequest) ProtoMessage

func (*GetCategoriesRequest) ProtoMessage()

func (*GetCategoriesRequest) ProtoReflect

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

func (*GetCategoriesRequest) Reset

func (x *GetCategoriesRequest) Reset()

func (*GetCategoriesRequest) String

func (x *GetCategoriesRequest) String() string

type GetEntriesRequest

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

func (*GetEntriesRequest) Descriptor deprecated

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

Deprecated: Use GetEntriesRequest.ProtoReflect.Descriptor instead.

func (*GetEntriesRequest) ProtoMessage

func (*GetEntriesRequest) ProtoMessage()

func (*GetEntriesRequest) ProtoReflect

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

func (*GetEntriesRequest) Reset

func (x *GetEntriesRequest) Reset()

func (*GetEntriesRequest) String

func (x *GetEntriesRequest) String() string

type GetEntriesResponse

type GetEntriesResponse struct {
	Entry []*GetEntriesResponse_Entry `protobuf:"bytes,1,rep,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEntriesResponse) Descriptor deprecated

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

Deprecated: Use GetEntriesResponse.ProtoReflect.Descriptor instead.

func (*GetEntriesResponse) GetEntry

func (*GetEntriesResponse) ProtoMessage

func (*GetEntriesResponse) ProtoMessage()

func (*GetEntriesResponse) ProtoReflect

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

func (*GetEntriesResponse) Reset

func (x *GetEntriesResponse) Reset()

func (*GetEntriesResponse) String

func (x *GetEntriesResponse) String() string

type GetEntriesResponse_Entry

type GetEntriesResponse_Entry struct {
	BlobPath              string `protobuf:"bytes,1,opt,name=blob_path,json=blobPath,proto3" json:"blob_path,omitempty"`
	State                 string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	BlobLen               int64  `protobuf:"varint,3,opt,name=blob_len,json=blobLen,proto3" json:"blob_len,omitempty"`
	ValidLen              int64  `protobuf:"varint,4,opt,name=valid_len,json=validLen,proto3" json:"valid_len,omitempty"`
	SyncCount             int64  `protobuf:"varint,5,opt,name=sync_count,json=syncCount,proto3" json:"sync_count,omitempty"`
	LastUsed              int64  `protobuf:"varint,6,opt,name=last_used,json=lastUsed,proto3" json:"last_used,omitempty"`
	LastWrite             int64  `protobuf:"varint,7,opt,name=last_write,json=lastWrite,proto3" json:"last_write,omitempty"`
	LastSync              int64  `protobuf:"varint,8,opt,name=last_sync,json=lastSync,proto3" json:"last_sync,omitempty"`
	NumberOfWriterHandles int64  `` /* 129-byte string literal not displayed */
	NumberOfHandles       int64  `protobuf:"varint,10,opt,name=number_of_handles,json=numberOfHandles,proto3" json:"number_of_handles,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEntriesResponse_Entry) Descriptor deprecated

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

Deprecated: Use GetEntriesResponse_Entry.ProtoReflect.Descriptor instead.

func (*GetEntriesResponse_Entry) GetBlobLen

func (x *GetEntriesResponse_Entry) GetBlobLen() int64

func (*GetEntriesResponse_Entry) GetBlobPath

func (x *GetEntriesResponse_Entry) GetBlobPath() string

func (*GetEntriesResponse_Entry) GetLastSync

func (x *GetEntriesResponse_Entry) GetLastSync() int64

func (*GetEntriesResponse_Entry) GetLastUsed

func (x *GetEntriesResponse_Entry) GetLastUsed() int64

func (*GetEntriesResponse_Entry) GetLastWrite

func (x *GetEntriesResponse_Entry) GetLastWrite() int64

func (*GetEntriesResponse_Entry) GetNumberOfHandles

func (x *GetEntriesResponse_Entry) GetNumberOfHandles() int64

func (*GetEntriesResponse_Entry) GetNumberOfWriterHandles

func (x *GetEntriesResponse_Entry) GetNumberOfWriterHandles() int64

func (*GetEntriesResponse_Entry) GetState

func (x *GetEntriesResponse_Entry) GetState() string

func (*GetEntriesResponse_Entry) GetSyncCount

func (x *GetEntriesResponse_Entry) GetSyncCount() int64

func (*GetEntriesResponse_Entry) GetValidLen

func (x *GetEntriesResponse_Entry) GetValidLen() int64

func (*GetEntriesResponse_Entry) ProtoMessage

func (*GetEntriesResponse_Entry) ProtoMessage()

func (*GetEntriesResponse_Entry) ProtoReflect

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

func (*GetEntriesResponse_Entry) Reset

func (x *GetEntriesResponse_Entry) Reset()

func (*GetEntriesResponse_Entry) String

func (x *GetEntriesResponse_Entry) String() string

type GetINodeDBStatsRequest

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

func (*GetINodeDBStatsRequest) Descriptor deprecated

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

Deprecated: Use GetINodeDBStatsRequest.ProtoReflect.Descriptor instead.

func (*GetINodeDBStatsRequest) ProtoMessage

func (*GetINodeDBStatsRequest) ProtoMessage()

func (*GetINodeDBStatsRequest) ProtoReflect

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

func (*GetINodeDBStatsRequest) Reset

func (x *GetINodeDBStatsRequest) Reset()

func (*GetINodeDBStatsRequest) String

func (x *GetINodeDBStatsRequest) String() string

type GetINodeDBStatsResponse

type GetINodeDBStatsResponse struct {
	LastSync          int64  `protobuf:"varint,1,opt,name=last_sync,json=lastSync,proto3" json:"last_sync,omitempty"`
	LastTx            int64  `protobuf:"varint,2,opt,name=last_tx,json=lastTx,proto3" json:"last_tx,omitempty"`
	LastId            uint64 `protobuf:"varint,3,opt,name=last_id,json=lastId,proto3" json:"last_id,omitempty"`
	Version           uint64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	LastTicket        uint64 `protobuf:"varint,5,opt,name=last_ticket,json=lastTicket,proto3" json:"last_ticket,omitempty"`
	NumberOfNodeLocks uint32 `protobuf:"varint,6,opt,name=number_of_node_locks,json=numberOfNodeLocks,proto3" json:"number_of_node_locks,omitempty"`
	// contains filtered or unexported fields
}

func (*GetINodeDBStatsResponse) Descriptor deprecated

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

Deprecated: Use GetINodeDBStatsResponse.ProtoReflect.Descriptor instead.

func (*GetINodeDBStatsResponse) GetLastId

func (x *GetINodeDBStatsResponse) GetLastId() uint64

func (*GetINodeDBStatsResponse) GetLastSync

func (x *GetINodeDBStatsResponse) GetLastSync() int64

func (*GetINodeDBStatsResponse) GetLastTicket

func (x *GetINodeDBStatsResponse) GetLastTicket() uint64

func (*GetINodeDBStatsResponse) GetLastTx

func (x *GetINodeDBStatsResponse) GetLastTx() int64

func (*GetINodeDBStatsResponse) GetNumberOfNodeLocks

func (x *GetINodeDBStatsResponse) GetNumberOfNodeLocks() uint32

func (*GetINodeDBStatsResponse) GetVersion

func (x *GetINodeDBStatsResponse) GetVersion() uint64

func (*GetINodeDBStatsResponse) ProtoMessage

func (*GetINodeDBStatsResponse) ProtoMessage()

func (*GetINodeDBStatsResponse) ProtoReflect

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

func (*GetINodeDBStatsResponse) Reset

func (x *GetINodeDBStatsResponse) Reset()

func (*GetINodeDBStatsResponse) String

func (x *GetINodeDBStatsResponse) String() string

type GetSystemInfoRequest

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

func (*GetSystemInfoRequest) Descriptor deprecated

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

Deprecated: Use GetSystemInfoRequest.ProtoReflect.Descriptor instead.

func (*GetSystemInfoRequest) ProtoMessage

func (*GetSystemInfoRequest) ProtoMessage()

func (*GetSystemInfoRequest) ProtoReflect

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

func (*GetSystemInfoRequest) Reset

func (x *GetSystemInfoRequest) Reset()

func (*GetSystemInfoRequest) String

func (x *GetSystemInfoRequest) String() string

type GetVersionRequest

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

func (*GetVersionRequest) Descriptor deprecated

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

Deprecated: Use GetVersionRequest.ProtoReflect.Descriptor instead.

func (*GetVersionRequest) ProtoMessage

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) ProtoReflect

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

func (*GetVersionRequest) Reset

func (x *GetVersionRequest) Reset()

func (*GetVersionRequest) String

func (x *GetVersionRequest) String() string

type INodeDBServiceClient

type INodeDBServiceClient interface {
	GetINodeDBStats(ctx context.Context, in *GetINodeDBStatsRequest, opts ...grpc.CallOption) (*GetINodeDBStatsResponse, error)
}

INodeDBServiceClient is the client API for INodeDBService 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.

type INodeDBServiceServer

type INodeDBServiceServer interface {
	GetINodeDBStats(context.Context, *GetINodeDBStatsRequest) (*GetINodeDBStatsResponse, error)
	// contains filtered or unexported methods
}

INodeDBServiceServer is the server API for INodeDBService service. All implementations must embed UnimplementedINodeDBServiceServer for forward compatibility

type INodeType

type INodeType int32
const (
	INodeType_FILE INodeType = 0
	INodeType_DIR  INodeType = 1
)

func (INodeType) Descriptor

func (INodeType) Descriptor() protoreflect.EnumDescriptor

func (INodeType) Enum

func (x INodeType) Enum() *INodeType

func (INodeType) EnumDescriptor deprecated

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

Deprecated: Use INodeType.Descriptor instead.

func (INodeType) Number

func (x INodeType) Number() protoreflect.EnumNumber

func (INodeType) String

func (x INodeType) String() string

func (INodeType) Type

type INodeView

type INodeView struct {
	Id           uint64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name         string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type         INodeType `protobuf:"varint,3,opt,name=type,proto3,enum=pb.INodeType" json:"type,omitempty"`
	Size         int64     `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Uid          uint32    `protobuf:"varint,5,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid          uint32    `protobuf:"varint,6,opt,name=gid,proto3" json:"gid,omitempty"`
	PermMode     uint32    `protobuf:"varint,7,opt,name=perm_mode,json=permMode,proto3" json:"perm_mode,omitempty"`
	ModifiedTime int64     `protobuf:"varint,8,opt,name=modified_time,json=modifiedTime,proto3" json:"modified_time,omitempty"`
	// contains filtered or unexported fields
}

func (*INodeView) Descriptor deprecated

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

Deprecated: Use INodeView.ProtoReflect.Descriptor instead.

func (*INodeView) GetGid

func (x *INodeView) GetGid() uint32

func (*INodeView) GetId

func (x *INodeView) GetId() uint64

func (*INodeView) GetModifiedTime

func (x *INodeView) GetModifiedTime() int64

func (*INodeView) GetName

func (x *INodeView) GetName() string

func (*INodeView) GetPermMode

func (x *INodeView) GetPermMode() uint32

func (*INodeView) GetSize

func (x *INodeView) GetSize() int64

func (*INodeView) GetType

func (x *INodeView) GetType() INodeType

func (*INodeView) GetUid

func (x *INodeView) GetUid() uint32

func (*INodeView) ProtoMessage

func (*INodeView) ProtoMessage()

func (*INodeView) ProtoReflect

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

func (*INodeView) Reset

func (x *INodeView) Reset()

func (*INodeView) String

func (x *INodeView) String() string

type ListDirRequest

type ListDirRequest struct {

	// If |len(id)| == 0, then query path.
	Id   []uint64 `protobuf:"varint,1,rep,packed,name=id,proto3" json:"id,omitempty"`
	Path string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDirRequest) Descriptor deprecated

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

Deprecated: Use ListDirRequest.ProtoReflect.Descriptor instead.

func (*ListDirRequest) GetId

func (x *ListDirRequest) GetId() []uint64

func (*ListDirRequest) GetPath

func (x *ListDirRequest) GetPath() string

func (*ListDirRequest) ProtoMessage

func (*ListDirRequest) ProtoMessage()

func (*ListDirRequest) ProtoReflect

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

func (*ListDirRequest) Reset

func (x *ListDirRequest) Reset()

func (*ListDirRequest) String

func (x *ListDirRequest) String() string

type ListDirResponse

type ListDirResponse struct {
	Listing []*ListDirResponse_Listing `protobuf:"bytes,1,rep,name=listing,proto3" json:"listing,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDirResponse) Descriptor deprecated

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

Deprecated: Use ListDirResponse.ProtoReflect.Descriptor instead.

func (*ListDirResponse) GetListing

func (x *ListDirResponse) GetListing() []*ListDirResponse_Listing

func (*ListDirResponse) ProtoMessage

func (*ListDirResponse) ProtoMessage()

func (*ListDirResponse) ProtoReflect

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

func (*ListDirResponse) Reset

func (x *ListDirResponse) Reset()

func (*ListDirResponse) String

func (x *ListDirResponse) String() string

type ListDirResponse_Listing

type ListDirResponse_Listing struct {
	DirId uint64       `protobuf:"varint,1,opt,name=dir_id,json=dirId,proto3" json:"dir_id,omitempty"`
	Entry []*INodeView `protobuf:"bytes,2,rep,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDirResponse_Listing) Descriptor deprecated

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

Deprecated: Use ListDirResponse_Listing.ProtoReflect.Descriptor instead.

func (*ListDirResponse_Listing) GetDirId

func (x *ListDirResponse_Listing) GetDirId() uint64

func (*ListDirResponse_Listing) GetEntry

func (x *ListDirResponse_Listing) GetEntry() []*INodeView

func (*ListDirResponse_Listing) ProtoMessage

func (*ListDirResponse_Listing) ProtoMessage()

func (*ListDirResponse_Listing) ProtoReflect

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

func (*ListDirResponse_Listing) Reset

func (x *ListDirResponse_Listing) Reset()

func (*ListDirResponse_Listing) String

func (x *ListDirResponse_Listing) String() string

type ListHostsRequest

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

func (*ListHostsRequest) Descriptor deprecated

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

Deprecated: Use ListHostsRequest.ProtoReflect.Descriptor instead.

func (*ListHostsRequest) ProtoMessage

func (*ListHostsRequest) ProtoMessage()

func (*ListHostsRequest) ProtoReflect

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

func (*ListHostsRequest) Reset

func (x *ListHostsRequest) Reset()

func (*ListHostsRequest) String

func (x *ListHostsRequest) String() string

type ListHostsResponse

type ListHostsResponse struct {
	Host []string `protobuf:"bytes,1,rep,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*ListHostsResponse) Descriptor deprecated

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

Deprecated: Use ListHostsResponse.ProtoReflect.Descriptor instead.

func (*ListHostsResponse) GetHost

func (x *ListHostsResponse) GetHost() []string

func (*ListHostsResponse) ProtoMessage

func (*ListHostsResponse) ProtoMessage()

func (*ListHostsResponse) ProtoReflect

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

func (*ListHostsResponse) Reset

func (x *ListHostsResponse) Reset()

func (*ListHostsResponse) String

func (x *ListHostsResponse) String() string

type ListLocalDirRequest

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

func (*ListLocalDirRequest) Descriptor deprecated

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

Deprecated: Use ListLocalDirRequest.ProtoReflect.Descriptor instead.

func (*ListLocalDirRequest) GetPath

func (x *ListLocalDirRequest) GetPath() string

func (*ListLocalDirRequest) ProtoMessage

func (*ListLocalDirRequest) ProtoMessage()

func (*ListLocalDirRequest) ProtoReflect

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

func (*ListLocalDirRequest) Reset

func (x *ListLocalDirRequest) Reset()

func (*ListLocalDirRequest) String

func (x *ListLocalDirRequest) String() string

type ListLocalDirResponse

type ListLocalDirResponse struct {
	Entry []*FileInfo `protobuf:"bytes,1,rep,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLocalDirResponse) Descriptor deprecated

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

Deprecated: Use ListLocalDirResponse.ProtoReflect.Descriptor instead.

func (*ListLocalDirResponse) GetEntry

func (x *ListLocalDirResponse) GetEntry() []*FileInfo

func (*ListLocalDirResponse) ProtoMessage

func (*ListLocalDirResponse) ProtoMessage()

func (*ListLocalDirResponse) ProtoReflect

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

func (*ListLocalDirResponse) Reset

func (x *ListLocalDirResponse) Reset()

func (*ListLocalDirResponse) String

func (x *ListLocalDirResponse) String() string

type MkdirLocalRequest

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

func (*MkdirLocalRequest) Descriptor deprecated

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

Deprecated: Use MkdirLocalRequest.ProtoReflect.Descriptor instead.

func (*MkdirLocalRequest) GetPath

func (x *MkdirLocalRequest) GetPath() string

func (*MkdirLocalRequest) ProtoMessage

func (*MkdirLocalRequest) ProtoMessage()

func (*MkdirLocalRequest) ProtoReflect

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

func (*MkdirLocalRequest) Reset

func (x *MkdirLocalRequest) Reset()

func (*MkdirLocalRequest) String

func (x *MkdirLocalRequest) String() string

type MkdirLocalResponse

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

func (*MkdirLocalResponse) Descriptor deprecated

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

Deprecated: Use MkdirLocalResponse.ProtoReflect.Descriptor instead.

func (*MkdirLocalResponse) ProtoMessage

func (*MkdirLocalResponse) ProtoMessage()

func (*MkdirLocalResponse) ProtoReflect

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

func (*MkdirLocalResponse) Reset

func (x *MkdirLocalResponse) Reset()

func (*MkdirLocalResponse) String

func (x *MkdirLocalResponse) String() string

type MoveLocalRequest

type MoveLocalRequest struct {
	PathSrc  string `protobuf:"bytes,1,opt,name=path_src,json=pathSrc,proto3" json:"path_src,omitempty"`
	PathDest string `protobuf:"bytes,2,opt,name=path_dest,json=pathDest,proto3" json:"path_dest,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveLocalRequest) Descriptor deprecated

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

Deprecated: Use MoveLocalRequest.ProtoReflect.Descriptor instead.

func (*MoveLocalRequest) GetPathDest

func (x *MoveLocalRequest) GetPathDest() string

func (*MoveLocalRequest) GetPathSrc

func (x *MoveLocalRequest) GetPathSrc() string

func (*MoveLocalRequest) ProtoMessage

func (*MoveLocalRequest) ProtoMessage()

func (*MoveLocalRequest) ProtoReflect

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

func (*MoveLocalRequest) Reset

func (x *MoveLocalRequest) Reset()

func (*MoveLocalRequest) String

func (x *MoveLocalRequest) String() string

type MoveLocalResponse

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

func (*MoveLocalResponse) Descriptor deprecated

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

Deprecated: Use MoveLocalResponse.ProtoReflect.Descriptor instead.

func (*MoveLocalResponse) ProtoMessage

func (*MoveLocalResponse) ProtoMessage()

func (*MoveLocalResponse) ProtoReflect

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

func (*MoveLocalResponse) Reset

func (x *MoveLocalResponse) Reset()

func (*MoveLocalResponse) String

func (x *MoveLocalResponse) String() string

type ReadFileRequest

type ReadFileRequest struct {
	Id     uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Length uint32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadFileRequest) Descriptor deprecated

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

Deprecated: Use ReadFileRequest.ProtoReflect.Descriptor instead.

func (*ReadFileRequest) GetId

func (x *ReadFileRequest) GetId() uint64

func (*ReadFileRequest) GetLength

func (x *ReadFileRequest) GetLength() uint32

func (*ReadFileRequest) GetOffset

func (x *ReadFileRequest) GetOffset() uint64

func (*ReadFileRequest) ProtoMessage

func (*ReadFileRequest) ProtoMessage()

func (*ReadFileRequest) ProtoReflect

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

func (*ReadFileRequest) Reset

func (x *ReadFileRequest) Reset()

func (*ReadFileRequest) String

func (x *ReadFileRequest) String() string

type ReadFileResponse

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

func (*ReadFileResponse) Descriptor deprecated

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

Deprecated: Use ReadFileResponse.ProtoReflect.Descriptor instead.

func (*ReadFileResponse) GetBody

func (x *ReadFileResponse) GetBody() []byte

func (*ReadFileResponse) ProtoMessage

func (*ReadFileResponse) ProtoMessage()

func (*ReadFileResponse) ProtoReflect

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

func (*ReadFileResponse) Reset

func (x *ReadFileResponse) Reset()

func (*ReadFileResponse) String

func (x *ReadFileResponse) String() string

type ReduceCacheRequest

type ReduceCacheRequest struct {
	DryRun      bool   `protobuf:"varint,1,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	DesiredSize string `protobuf:"bytes,2,opt,name=desired_size,json=desiredSize,proto3" json:"desired_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ReduceCacheRequest) Descriptor deprecated

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

Deprecated: Use ReduceCacheRequest.ProtoReflect.Descriptor instead.

func (*ReduceCacheRequest) GetDesiredSize

func (x *ReduceCacheRequest) GetDesiredSize() string

func (*ReduceCacheRequest) GetDryRun

func (x *ReduceCacheRequest) GetDryRun() bool

func (*ReduceCacheRequest) ProtoMessage

func (*ReduceCacheRequest) ProtoMessage()

func (*ReduceCacheRequest) ProtoReflect

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

func (*ReduceCacheRequest) Reset

func (x *ReduceCacheRequest) Reset()

func (*ReduceCacheRequest) String

func (x *ReduceCacheRequest) String() string

type ReduceCacheResponse

type ReduceCacheResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*ReduceCacheResponse) Descriptor deprecated

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

Deprecated: Use ReduceCacheResponse.ProtoReflect.Descriptor instead.

func (*ReduceCacheResponse) GetErrorMessage

func (x *ReduceCacheResponse) GetErrorMessage() string

func (*ReduceCacheResponse) GetSuccess

func (x *ReduceCacheResponse) GetSuccess() bool

func (*ReduceCacheResponse) ProtoMessage

func (*ReduceCacheResponse) ProtoMessage()

func (*ReduceCacheResponse) ProtoReflect

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

func (*ReduceCacheResponse) Reset

func (x *ReduceCacheResponse) Reset()

func (*ReduceCacheResponse) String

func (x *ReduceCacheResponse) String() string

type RemoteMoveRequest

type RemoteMoveRequest struct {
	OpathSrc  string `protobuf:"bytes,1,opt,name=opath_src,json=opathSrc,proto3" json:"opath_src,omitempty"`
	OpathDest string `protobuf:"bytes,2,opt,name=opath_dest,json=opathDest,proto3" json:"opath_dest,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteMoveRequest) Descriptor deprecated

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

Deprecated: Use RemoteMoveRequest.ProtoReflect.Descriptor instead.

func (*RemoteMoveRequest) GetOpathDest

func (x *RemoteMoveRequest) GetOpathDest() string

func (*RemoteMoveRequest) GetOpathSrc

func (x *RemoteMoveRequest) GetOpathSrc() string

func (*RemoteMoveRequest) ProtoMessage

func (*RemoteMoveRequest) ProtoMessage()

func (*RemoteMoveRequest) ProtoReflect

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

func (*RemoteMoveRequest) Reset

func (x *RemoteMoveRequest) Reset()

func (*RemoteMoveRequest) String

func (x *RemoteMoveRequest) String() string

type RemoteMoveResponse

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

func (*RemoteMoveResponse) Descriptor deprecated

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

Deprecated: Use RemoteMoveResponse.ProtoReflect.Descriptor instead.

func (*RemoteMoveResponse) ProtoMessage

func (*RemoteMoveResponse) ProtoMessage()

func (*RemoteMoveResponse) ProtoReflect

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

func (*RemoteMoveResponse) Reset

func (x *RemoteMoveResponse) Reset()

func (*RemoteMoveResponse) String

func (x *RemoteMoveResponse) String() string

type RemoveLocalRequest

type RemoveLocalRequest struct {
	Path           string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	RemoveChildren bool   `protobuf:"varint,2,opt,name=remove_children,json=removeChildren,proto3" json:"remove_children,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveLocalRequest) Descriptor deprecated

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

Deprecated: Use RemoveLocalRequest.ProtoReflect.Descriptor instead.

func (*RemoveLocalRequest) GetPath

func (x *RemoveLocalRequest) GetPath() string

func (*RemoveLocalRequest) GetRemoveChildren

func (x *RemoveLocalRequest) GetRemoveChildren() bool

func (*RemoveLocalRequest) ProtoMessage

func (*RemoveLocalRequest) ProtoMessage()

func (*RemoveLocalRequest) ProtoReflect

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

func (*RemoveLocalRequest) Reset

func (x *RemoveLocalRequest) Reset()

func (*RemoveLocalRequest) String

func (x *RemoveLocalRequest) String() string

type RemoveLocalResponse

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

func (*RemoveLocalResponse) Descriptor deprecated

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

Deprecated: Use RemoveLocalResponse.ProtoReflect.Descriptor instead.

func (*RemoveLocalResponse) ProtoMessage

func (*RemoveLocalResponse) ProtoMessage()

func (*RemoveLocalResponse) ProtoReflect

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

func (*RemoveLocalResponse) Reset

func (x *RemoveLocalResponse) Reset()

func (*RemoveLocalResponse) String

func (x *RemoveLocalResponse) String() string

type RemoveRequest

type RemoveRequest struct {

	// If |dir_id| == 0, then treat |name| as fullpath.
	DirId uint64 `protobuf:"varint,1,opt,name=dir_id,json=dirId,proto3" json:"dir_id,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRequest) Descriptor deprecated

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

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetDirId

func (x *RemoveRequest) GetDirId() uint64

func (*RemoveRequest) GetName

func (x *RemoveRequest) GetName() string

func (*RemoveRequest) ProtoMessage

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect

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

func (*RemoveRequest) Reset

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String

func (x *RemoveRequest) String() string

type RemoveResponse

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

func (*RemoveResponse) Descriptor deprecated

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

Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.

func (*RemoveResponse) ProtoMessage

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) ProtoReflect

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

func (*RemoveResponse) Reset

func (x *RemoveResponse) Reset()

func (*RemoveResponse) String

func (x *RemoveResponse) String() string

type RenameRequest

type RenameRequest struct {
	PathSrc  string `protobuf:"bytes,1,opt,name=path_src,json=pathSrc,proto3" json:"path_src,omitempty"`
	PathDest string `protobuf:"bytes,2,opt,name=path_dest,json=pathDest,proto3" json:"path_dest,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameRequest) Descriptor deprecated

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

Deprecated: Use RenameRequest.ProtoReflect.Descriptor instead.

func (*RenameRequest) GetPathDest

func (x *RenameRequest) GetPathDest() string

func (*RenameRequest) GetPathSrc

func (x *RenameRequest) GetPathSrc() string

func (*RenameRequest) ProtoMessage

func (*RenameRequest) ProtoMessage()

func (*RenameRequest) ProtoReflect

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

func (*RenameRequest) Reset

func (x *RenameRequest) Reset()

func (*RenameRequest) String

func (x *RenameRequest) String() string

type RenameResponse

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

func (*RenameResponse) Descriptor deprecated

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

Deprecated: Use RenameResponse.ProtoReflect.Descriptor instead.

func (*RenameResponse) ProtoMessage

func (*RenameResponse) ProtoMessage()

func (*RenameResponse) ProtoReflect

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

func (*RenameResponse) Reset

func (x *RenameResponse) Reset()

func (*RenameResponse) String

func (x *RenameResponse) String() string

type SystemInfoResponse

type SystemInfoResponse struct {
	GoVersion    string `protobuf:"bytes,1,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	Os           string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
	Arch         string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"`
	NumGoroutine uint32 `protobuf:"varint,4,opt,name=num_goroutine,json=numGoroutine,proto3" json:"num_goroutine,omitempty"`
	Hostname     string `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Pid          uint64 `protobuf:"varint,6,opt,name=pid,proto3" json:"pid,omitempty"`
	Uid          uint64 `protobuf:"varint,7,opt,name=uid,proto3" json:"uid,omitempty"`
	MemAlloc     uint64 `protobuf:"varint,8,opt,name=mem_alloc,json=memAlloc,proto3" json:"mem_alloc,omitempty"`
	MemSys       uint64 `protobuf:"varint,9,opt,name=mem_sys,json=memSys,proto3" json:"mem_sys,omitempty"`
	NumGc        uint32 `protobuf:"varint,10,opt,name=num_gc,json=numGc,proto3" json:"num_gc,omitempty"`
	NumFds       uint32 `protobuf:"varint,11,opt,name=num_fds,json=numFds,proto3" json:"num_fds,omitempty"`
	// contains filtered or unexported fields
}

func (*SystemInfoResponse) Descriptor deprecated

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

Deprecated: Use SystemInfoResponse.ProtoReflect.Descriptor instead.

func (*SystemInfoResponse) GetArch

func (x *SystemInfoResponse) GetArch() string

func (*SystemInfoResponse) GetGoVersion

func (x *SystemInfoResponse) GetGoVersion() string

func (*SystemInfoResponse) GetHostname

func (x *SystemInfoResponse) GetHostname() string

func (*SystemInfoResponse) GetMemAlloc

func (x *SystemInfoResponse) GetMemAlloc() uint64

func (*SystemInfoResponse) GetMemSys

func (x *SystemInfoResponse) GetMemSys() uint64

func (*SystemInfoResponse) GetNumFds

func (x *SystemInfoResponse) GetNumFds() uint32

func (*SystemInfoResponse) GetNumGc

func (x *SystemInfoResponse) GetNumGc() uint32

func (*SystemInfoResponse) GetNumGoroutine

func (x *SystemInfoResponse) GetNumGoroutine() uint32

func (*SystemInfoResponse) GetOs

func (x *SystemInfoResponse) GetOs() string

func (*SystemInfoResponse) GetPid

func (x *SystemInfoResponse) GetPid() uint64

func (*SystemInfoResponse) GetUid

func (x *SystemInfoResponse) GetUid() uint64

func (*SystemInfoResponse) ProtoMessage

func (*SystemInfoResponse) ProtoMessage()

func (*SystemInfoResponse) ProtoReflect

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

func (*SystemInfoResponse) Reset

func (x *SystemInfoResponse) Reset()

func (*SystemInfoResponse) String

func (x *SystemInfoResponse) String() string

type SystemInfoServiceClient

type SystemInfoServiceClient interface {
	GetSystemInfo(ctx context.Context, in *GetSystemInfoRequest, opts ...grpc.CallOption) (*SystemInfoResponse, error)
	GetVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
	Whoami(ctx context.Context, in *WhoamiRequest, opts ...grpc.CallOption) (*WhoamiResponse, error)
	AuthTestAnonymous(ctx context.Context, in *AuthTestRequest, opts ...grpc.CallOption) (*AuthTestResponse, error)
	AuthTestReadOnly(ctx context.Context, in *AuthTestRequest, opts ...grpc.CallOption) (*AuthTestResponse, error)
	AuthTestAdmin(ctx context.Context, in *AuthTestRequest, opts ...grpc.CallOption) (*AuthTestResponse, error)
}

SystemInfoServiceClient is the client API for SystemInfoService 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.

type SystemInfoServiceServer

type SystemInfoServiceServer interface {
	GetSystemInfo(context.Context, *GetSystemInfoRequest) (*SystemInfoResponse, error)
	GetVersion(context.Context, *GetVersionRequest) (*VersionResponse, error)
	Whoami(context.Context, *WhoamiRequest) (*WhoamiResponse, error)
	AuthTestAnonymous(context.Context, *AuthTestRequest) (*AuthTestResponse, error)
	AuthTestReadOnly(context.Context, *AuthTestRequest) (*AuthTestResponse, error)
	AuthTestAdmin(context.Context, *AuthTestRequest) (*AuthTestResponse, error)
	// contains filtered or unexported methods
}

SystemInfoServiceServer is the server API for SystemInfoService service. All implementations must embed UnimplementedSystemInfoServiceServer for forward compatibility

type UnimplementedBlobstoreServiceServer

type UnimplementedBlobstoreServiceServer struct {
}

UnimplementedBlobstoreServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBlobstoreServiceServer) GetEntries

func (UnimplementedBlobstoreServiceServer) ReduceCache

type UnimplementedFeServiceServer

type UnimplementedFeServiceServer struct {
}

UnimplementedFeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFeServiceServer) CopyLocal

func (UnimplementedFeServiceServer) Download

func (UnimplementedFeServiceServer) ListHosts

func (UnimplementedFeServiceServer) ListLocalDir

func (UnimplementedFeServiceServer) MkdirLocal

func (UnimplementedFeServiceServer) MoveLocal

func (UnimplementedFeServiceServer) RemoteMove

func (UnimplementedFeServiceServer) RemoveLocal

func (UnimplementedFeServiceServer) Upload

type UnimplementedFileSystemServiceServer

type UnimplementedFileSystemServiceServer struct {
}

UnimplementedFileSystemServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFileSystemServiceServer) Attr

func (UnimplementedFileSystemServiceServer) Create

func (UnimplementedFileSystemServiceServer) FindNodeFullPath

func (UnimplementedFileSystemServiceServer) ListDir

func (UnimplementedFileSystemServiceServer) ReadFile

func (UnimplementedFileSystemServiceServer) Remove

func (UnimplementedFileSystemServiceServer) Rename

func (UnimplementedFileSystemServiceServer) WriteFile

type UnimplementedINodeDBServiceServer

type UnimplementedINodeDBServiceServer struct {
}

UnimplementedINodeDBServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedINodeDBServiceServer) GetINodeDBStats

type UnimplementedSystemInfoServiceServer

type UnimplementedSystemInfoServiceServer struct {
}

UnimplementedSystemInfoServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSystemInfoServiceServer) AuthTestAdmin

func (UnimplementedSystemInfoServiceServer) AuthTestAnonymous

func (UnimplementedSystemInfoServiceServer) AuthTestReadOnly

func (UnimplementedSystemInfoServiceServer) GetSystemInfo

func (UnimplementedSystemInfoServiceServer) GetVersion

func (UnimplementedSystemInfoServiceServer) Whoami

type UnsafeBlobstoreServiceServer

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

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

type UnsafeFeServiceServer

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

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

type UnsafeFileSystemServiceServer

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

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

type UnsafeINodeDBServiceServer

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

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

type UnsafeSystemInfoServiceServer

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

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

type UploadRequest

type UploadRequest struct {
	PathSrc        string `protobuf:"bytes,1,opt,name=path_src,json=pathSrc,proto3" json:"path_src,omitempty"`
	OpathDest      string `protobuf:"bytes,2,opt,name=opath_dest,json=opathDest,proto3" json:"opath_dest,omitempty"`
	AllowOverwrite bool   `protobuf:"varint,3,opt,name=allow_overwrite,json=allowOverwrite,proto3" json:"allow_overwrite,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadRequest) Descriptor deprecated

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

Deprecated: Use UploadRequest.ProtoReflect.Descriptor instead.

func (*UploadRequest) GetAllowOverwrite

func (x *UploadRequest) GetAllowOverwrite() bool

func (*UploadRequest) GetOpathDest

func (x *UploadRequest) GetOpathDest() string

func (*UploadRequest) GetPathSrc

func (x *UploadRequest) GetPathSrc() string

func (*UploadRequest) ProtoMessage

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) ProtoReflect

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

func (*UploadRequest) Reset

func (x *UploadRequest) Reset()

func (*UploadRequest) String

func (x *UploadRequest) String() string

type UploadResponse

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

func (*UploadResponse) Descriptor deprecated

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

Deprecated: Use UploadResponse.ProtoReflect.Descriptor instead.

func (*UploadResponse) ProtoMessage

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) ProtoReflect

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

func (*UploadResponse) Reset

func (x *UploadResponse) Reset()

func (*UploadResponse) String

func (x *UploadResponse) String() string

type VersionResponse

type VersionResponse struct {
	GitCommit string `protobuf:"bytes,1,opt,name=git_commit,json=gitCommit,proto3" json:"git_commit,omitempty"`
	BuildHost string `protobuf:"bytes,2,opt,name=build_host,json=buildHost,proto3" json:"build_host,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetBuildHost

func (x *VersionResponse) GetBuildHost() string

func (*VersionResponse) GetGitCommit

func (x *VersionResponse) GetGitCommit() string

func (*VersionResponse) ProtoMessage

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect

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

func (*VersionResponse) Reset

func (x *VersionResponse) Reset()

func (*VersionResponse) String

func (x *VersionResponse) String() string

type WhoamiRequest

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

func (*WhoamiRequest) Descriptor deprecated

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

Deprecated: Use WhoamiRequest.ProtoReflect.Descriptor instead.

func (*WhoamiRequest) ProtoMessage

func (*WhoamiRequest) ProtoMessage()

func (*WhoamiRequest) ProtoReflect

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

func (*WhoamiRequest) Reset

func (x *WhoamiRequest) Reset()

func (*WhoamiRequest) String

func (x *WhoamiRequest) String() string

type WhoamiResponse

type WhoamiResponse struct {
	Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*WhoamiResponse) Descriptor deprecated

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

Deprecated: Use WhoamiResponse.ProtoReflect.Descriptor instead.

func (*WhoamiResponse) GetRole

func (x *WhoamiResponse) GetRole() string

func (*WhoamiResponse) GetUser

func (x *WhoamiResponse) GetUser() string

func (*WhoamiResponse) ProtoMessage

func (*WhoamiResponse) ProtoMessage()

func (*WhoamiResponse) ProtoReflect

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

func (*WhoamiResponse) Reset

func (x *WhoamiResponse) Reset()

func (*WhoamiResponse) String

func (x *WhoamiResponse) String() string

type WriteFileRequest

type WriteFileRequest struct {
	Id     uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Body   []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteFileRequest) Descriptor deprecated

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

Deprecated: Use WriteFileRequest.ProtoReflect.Descriptor instead.

func (*WriteFileRequest) GetBody

func (x *WriteFileRequest) GetBody() []byte

func (*WriteFileRequest) GetId

func (x *WriteFileRequest) GetId() uint64

func (*WriteFileRequest) GetOffset

func (x *WriteFileRequest) GetOffset() uint64

func (*WriteFileRequest) ProtoMessage

func (*WriteFileRequest) ProtoMessage()

func (*WriteFileRequest) ProtoReflect

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

func (*WriteFileRequest) Reset

func (x *WriteFileRequest) Reset()

func (*WriteFileRequest) String

func (x *WriteFileRequest) String() string

type WriteFileResponse

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

func (*WriteFileResponse) Descriptor deprecated

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

Deprecated: Use WriteFileResponse.ProtoReflect.Descriptor instead.

func (*WriteFileResponse) ProtoMessage

func (*WriteFileResponse) ProtoMessage()

func (*WriteFileResponse) ProtoReflect

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

func (*WriteFileResponse) Reset

func (x *WriteFileResponse) Reset()

func (*WriteFileResponse) String

func (x *WriteFileResponse) String() string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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