pb

package
v0.0.0-...-7ab6552 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2024 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.

func NewBlobstoreServiceClient 

func NewBlobstoreServiceClient(cc grpc.ClientConnInterface) BlobstoreServiceClient

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 

type FeServiceClient interface {
	ListHosts(ctx context.Context, in *ListHostsRequest, opts ...grpc.CallOption) (*ListHostsResponse, error)
	ListLocalDir(ctx context.Context, in *ListLocalDirRequest, opts ...grpc.CallOption) (*ListLocalDirResponse, error)
	MkdirLocal(ctx context.Context, in *MkdirLocalRequest, opts ...grpc.CallOption) (*MkdirLocalResponse, error)
	CopyLocal(ctx context.Context, in *CopyLocalRequest, opts ...grpc.CallOption) (*CopyLocalResponse, error)
	MoveLocal(ctx context.Context, in *MoveLocalRequest, opts ...grpc.CallOption) (*MoveLocalResponse, error)
	Download(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (*DownloadResponse, error)
	Upload(ctx context.Context, in *UploadRequest, opts ...grpc.CallOption) (*UploadResponse, error)
	RemoteMove(ctx context.Context, in *RemoteMoveRequest, opts ...grpc.CallOption) (*RemoteMoveResponse, error)
	RemoveLocal(ctx context.Context, in *RemoveLocalRequest, opts ...grpc.CallOption) (*RemoveLocalResponse, error)
}

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 

type FeServiceServer interface {
	ListHosts(context.Context, *ListHostsRequest) (*ListHostsResponse, error)
	ListLocalDir(context.Context, *ListLocalDirRequest) (*ListLocalDirResponse, error)
	MkdirLocal(context.Context, *MkdirLocalRequest) (*MkdirLocalResponse, error)
	CopyLocal(context.Context, *CopyLocalRequest) (*CopyLocalResponse, error)
	MoveLocal(context.Context, *MoveLocalRequest) (*MoveLocalResponse, error)
	Download(context.Context, *DownloadRequest) (*DownloadResponse, error)
	Upload(context.Context, *UploadRequest) (*UploadResponse, error)
	RemoteMove(context.Context, *RemoteMoveRequest) (*RemoteMoveResponse, error)
	RemoveLocal(context.Context, *RemoveLocalRequest) (*RemoveLocalResponse, error)
	// contains filtered or unexported methods
}

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.

func NewFileSystemServiceClient 

func NewFileSystemServiceClient(cc grpc.ClientConnInterface) FileSystemServiceClient

type FileSystemServiceServer 

type FileSystemServiceServer interface {
	ListDir(context.Context, *ListDirRequest) (*ListDirResponse, error)
	FindNodeFullPath(context.Context, *FindNodeFullPathRequest) (*FindNodeFullPathResponse, error)
	Attr(context.Context, *AttrRequest) (*AttrResponse, error)
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	ReadFile(context.Context, *ReadFileRequest) (*ReadFileResponse, error)
	WriteFile(context.Context, *WriteFileRequest) (*WriteFileResponse, error)
	Rename(context.Context, *RenameRequest) (*RenameResponse, error)
	// contains filtered or unexported methods
}

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 (x *GetBlobstoreConfigRequest) ProtoReflect() protoreflect.Message

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 (x *GetBlobstoreConfigResponse) ProtoReflect() protoreflect.Message

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 (x *GetEntriesResponse) GetEntry() []*GetEntriesResponse_Entry

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.

func NewINodeDBServiceClient 

func NewINodeDBServiceClient(cc grpc.ClientConnInterface) INodeDBServiceClient

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 

func (INodeType) Type() protoreflect.EnumType

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.

func NewSystemInfoServiceClient 

func NewSystemInfoServiceClient(cc grpc.ClientConnInterface) SystemInfoServiceClient

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

func (UnimplementedBlobstoreServiceServer) GetConfig(context.Context, *GetBlobstoreConfigRequest) (*GetBlobstoreConfigResponse, error)

func (UnimplementedBlobstoreServiceServer) GetEntries 

func (UnimplementedBlobstoreServiceServer) GetEntries(context.Context, *GetEntriesRequest) (*GetEntriesResponse, error)

func (UnimplementedBlobstoreServiceServer) ReduceCache 

func (UnimplementedBlobstoreServiceServer) ReduceCache(context.Context, *ReduceCacheRequest) (*ReduceCacheResponse, error)

type UnimplementedFeServiceServer 

type UnimplementedFeServiceServer struct {
}

UnimplementedFeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFeServiceServer) CopyLocal 

func (UnimplementedFeServiceServer) CopyLocal(context.Context, *CopyLocalRequest) (*CopyLocalResponse, error)

func (UnimplementedFeServiceServer) Download 

func (UnimplementedFeServiceServer) Download(context.Context, *DownloadRequest) (*DownloadResponse, error)

func (UnimplementedFeServiceServer) ListHosts 

func (UnimplementedFeServiceServer) ListHosts(context.Context, *ListHostsRequest) (*ListHostsResponse, error)

func (UnimplementedFeServiceServer) ListLocalDir 

func (UnimplementedFeServiceServer) ListLocalDir(context.Context, *ListLocalDirRequest) (*ListLocalDirResponse, error)

func (UnimplementedFeServiceServer) MkdirLocal 

func (UnimplementedFeServiceServer) MkdirLocal(context.Context, *MkdirLocalRequest) (*MkdirLocalResponse, error)

func (UnimplementedFeServiceServer) MoveLocal 

func (UnimplementedFeServiceServer) MoveLocal(context.Context, *MoveLocalRequest) (*MoveLocalResponse, error)

func (UnimplementedFeServiceServer) RemoteMove 

func (UnimplementedFeServiceServer) RemoteMove(context.Context, *RemoteMoveRequest) (*RemoteMoveResponse, error)

func (UnimplementedFeServiceServer) RemoveLocal 

func (UnimplementedFeServiceServer) RemoveLocal(context.Context, *RemoveLocalRequest) (*RemoveLocalResponse, error)

func (UnimplementedFeServiceServer) Upload 

func (UnimplementedFeServiceServer) Upload(context.Context, *UploadRequest) (*UploadResponse, error)

type UnimplementedFileSystemServiceServer 

type UnimplementedFileSystemServiceServer struct {
}

UnimplementedFileSystemServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFileSystemServiceServer) Attr 

func (UnimplementedFileSystemServiceServer) Attr(context.Context, *AttrRequest) (*AttrResponse, error)

func (UnimplementedFileSystemServiceServer) Create 

func (UnimplementedFileSystemServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedFileSystemServiceServer) FindNodeFullPath 

func (UnimplementedFileSystemServiceServer) FindNodeFullPath(context.Context, *FindNodeFullPathRequest) (*FindNodeFullPathResponse, error)

func (UnimplementedFileSystemServiceServer) ListDir 

func (UnimplementedFileSystemServiceServer) ListDir(context.Context, *ListDirRequest) (*ListDirResponse, error)

func (UnimplementedFileSystemServiceServer) ReadFile 

func (UnimplementedFileSystemServiceServer) ReadFile(context.Context, *ReadFileRequest) (*ReadFileResponse, error)

func (UnimplementedFileSystemServiceServer) Remove 

func (UnimplementedFileSystemServiceServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)

func (UnimplementedFileSystemServiceServer) Rename 

func (UnimplementedFileSystemServiceServer) Rename(context.Context, *RenameRequest) (*RenameResponse, error)

func (UnimplementedFileSystemServiceServer) WriteFile 

func (UnimplementedFileSystemServiceServer) WriteFile(context.Context, *WriteFileRequest) (*WriteFileResponse, error)

type UnimplementedINodeDBServiceServer 

type UnimplementedINodeDBServiceServer struct {
}

UnimplementedINodeDBServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedINodeDBServiceServer) GetINodeDBStats 

func (UnimplementedINodeDBServiceServer) GetINodeDBStats(context.Context, *GetINodeDBStatsRequest) (*GetINodeDBStatsResponse, error)

type UnimplementedSystemInfoServiceServer 

type UnimplementedSystemInfoServiceServer struct {
}

UnimplementedSystemInfoServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSystemInfoServiceServer) AuthTestAdmin 

func (UnimplementedSystemInfoServiceServer) AuthTestAdmin(context.Context, *AuthTestRequest) (*AuthTestResponse, error)

func (UnimplementedSystemInfoServiceServer) AuthTestAnonymous 

func (UnimplementedSystemInfoServiceServer) AuthTestAnonymous(context.Context, *AuthTestRequest) (*AuthTestResponse, error)

func (UnimplementedSystemInfoServiceServer) AuthTestReadOnly 

func (UnimplementedSystemInfoServiceServer) AuthTestReadOnly(context.Context, *AuthTestRequest) (*AuthTestResponse, error)

func (UnimplementedSystemInfoServiceServer) GetSystemInfo 

func (UnimplementedSystemInfoServiceServer) GetSystemInfo(context.Context, *GetSystemInfoRequest) (*SystemInfoResponse, error)

func (UnimplementedSystemInfoServiceServer) GetVersion 

func (UnimplementedSystemInfoServiceServer) GetVersion(context.Context, *GetVersionRequest) (*VersionResponse, error)

func (UnimplementedSystemInfoServiceServer) Whoami 

func (UnimplementedSystemInfoServiceServer) Whoami(context.Context, *WhoamiRequest) (*WhoamiResponse, error)

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

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.