Documentation ¶
Index ¶
- Variables
- func RegisterMetaServerServer(s grpc.ServiceRegistrar, srv MetaServerServer)
- type AppendFileRequest
- func (*AppendFileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AppendFileRequest) GetClientId() string
- func (x *AppendFileRequest) GetDir() string
- func (x *AppendFileRequest) GetEntry() []*rfs.Entry
- func (*AppendFileRequest) ProtoMessage()
- func (x *AppendFileRequest) ProtoReflect() protoreflect.Message
- func (x *AppendFileRequest) Reset()
- func (x *AppendFileRequest) String() string
- type AppendFileResponse
- func (*AppendFileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AppendFileResponse) GetError() string
- func (*AppendFileResponse) ProtoMessage()
- func (x *AppendFileResponse) ProtoReflect() protoreflect.Message
- func (x *AppendFileResponse) Reset()
- func (x *AppendFileResponse) String() string
- type CreateFileRequest
- func (*CreateFileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateFileRequest) GetClientId() string
- func (x *CreateFileRequest) GetDir() string
- func (x *CreateFileRequest) GetEntry() *rfs.Entry
- func (x *CreateFileRequest) GetOExcl() bool
- func (x *CreateFileRequest) GetSkipCheckParentDirectory() bool
- func (*CreateFileRequest) ProtoMessage()
- func (x *CreateFileRequest) ProtoReflect() protoreflect.Message
- func (x *CreateFileRequest) Reset()
- func (x *CreateFileRequest) String() string
- type CreateFileResponse
- func (*CreateFileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateFileResponse) GetError() string
- func (*CreateFileResponse) ProtoMessage()
- func (x *CreateFileResponse) ProtoReflect() protoreflect.Message
- func (x *CreateFileResponse) Reset()
- func (x *CreateFileResponse) String() string
- type GetFileRequest
- func (*GetFileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetFileRequest) GetClientId() string
- func (x *GetFileRequest) GetPath() string
- func (*GetFileRequest) ProtoMessage()
- func (x *GetFileRequest) ProtoReflect() protoreflect.Message
- func (x *GetFileRequest) Reset()
- func (x *GetFileRequest) String() string
- type GetFileResponse
- func (*GetFileResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetFileResponse) GetEntry() *rfs.Entry
- func (x *GetFileResponse) GetError() string
- func (*GetFileResponse) ProtoMessage()
- func (x *GetFileResponse) ProtoReflect() protoreflect.Message
- func (x *GetFileResponse) Reset()
- func (x *GetFileResponse) String() string
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetClientId() string
- func (x *ListRequest) GetDir() string
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (x *ListRequest) String() string
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResponse) GetEntries() []*rfs.Entry
- func (x *ListResponse) GetError() string
- func (*ListResponse) ProtoMessage()
- func (x *ListResponse) ProtoReflect() protoreflect.Message
- func (x *ListResponse) Reset()
- func (x *ListResponse) String() string
- type MetaServerClient
- type MetaServerServer
- type MkdirRequest
- func (*MkdirRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MkdirRequest) GetClientId() string
- func (x *MkdirRequest) GetDirectory() string
- func (*MkdirRequest) ProtoMessage()
- func (x *MkdirRequest) ProtoReflect() protoreflect.Message
- func (x *MkdirRequest) Reset()
- func (x *MkdirRequest) String() string
- type MkdirResponse
- type MoveRequest
- func (*MoveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MoveRequest) GetClientId() string
- func (x *MoveRequest) GetDstPath() string
- func (x *MoveRequest) GetSrcPath() string
- func (*MoveRequest) ProtoMessage()
- func (x *MoveRequest) ProtoReflect() protoreflect.Message
- func (x *MoveRequest) Reset()
- func (x *MoveRequest) String() string
- type MoveResponse
- type PingRequest
- func (*PingRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PingRequest) GetTarget() string
- func (x *PingRequest) GetTargetType() string
- func (*PingRequest) ProtoMessage()
- func (x *PingRequest) ProtoReflect() protoreflect.Message
- func (x *PingRequest) Reset()
- func (x *PingRequest) String() string
- type PingResponse
- func (*PingResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PingResponse) GetRemoteTimeNs() int64
- func (x *PingResponse) GetStartTimeNs() int64
- func (x *PingResponse) GetStopTimeNs() int64
- func (*PingResponse) ProtoMessage()
- func (x *PingResponse) ProtoReflect() protoreflect.Message
- func (x *PingResponse) Reset()
- func (x *PingResponse) String() string
- type RemoveRequest
- func (*RemoveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveRequest) GetClientId() string
- func (x *RemoveRequest) GetPath() string
- func (x *RemoveRequest) GetRecursive() bool
- func (*RemoveRequest) ProtoMessage()
- func (x *RemoveRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveRequest) Reset()
- func (x *RemoveRequest) String() string
- type RemoveResponse
- type StatRequest
- func (*StatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatRequest) GetClientId() string
- func (x *StatRequest) GetPath() string
- func (*StatRequest) ProtoMessage()
- func (x *StatRequest) ProtoReflect() protoreflect.Message
- func (x *StatRequest) Reset()
- func (x *StatRequest) String() string
- type StatResponse
- func (*StatResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatResponse) GetEntry() *rfs.Entry
- func (x *StatResponse) GetError() string
- func (*StatResponse) ProtoMessage()
- func (x *StatResponse) ProtoReflect() protoreflect.Message
- func (x *StatResponse) Reset()
- func (x *StatResponse) String() string
- type UnimplementedMetaServerServer
- func (UnimplementedMetaServerServer) AppendFile(context.Context, *AppendFileRequest) (*AppendFileResponse, error)
- func (UnimplementedMetaServerServer) CreateFile(context.Context, *CreateFileRequest) (*CreateFileResponse, error)
- func (UnimplementedMetaServerServer) GetFile(context.Context, *GetFileRequest) (*GetFileResponse, error)
- func (UnimplementedMetaServerServer) List(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedMetaServerServer) Mkdir(context.Context, *MkdirRequest) (*MkdirResponse, error)
- func (UnimplementedMetaServerServer) Move(context.Context, *MoveRequest) (*MoveResponse, error)
- func (UnimplementedMetaServerServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
- func (UnimplementedMetaServerServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
- func (UnimplementedMetaServerServer) Stat(context.Context, *StatRequest) (*StatResponse, error)
- type UnsafeMetaServerServer
Constants ¶
This section is empty.
Variables ¶
var File_meta_server_proto protoreflect.FileDescriptor
var MetaServer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "meta_server.MetaServer", HandlerType: (*MetaServerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateFile", Handler: _MetaServer_CreateFile_Handler, }, { MethodName: "AppendFile", Handler: _MetaServer_AppendFile_Handler, }, { MethodName: "GetFile", Handler: _MetaServer_GetFile_Handler, }, { MethodName: "Stat", Handler: _MetaServer_Stat_Handler, }, { MethodName: "Remove", Handler: _MetaServer_Remove_Handler, }, { MethodName: "Move", Handler: _MetaServer_Move_Handler, }, { MethodName: "Mkdir", Handler: _MetaServer_Mkdir_Handler, }, { MethodName: "List", Handler: _MetaServer_List_Handler, }, { MethodName: "Ping", Handler: _MetaServer_Ping_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "meta_server.proto", }
MetaServer_ServiceDesc is the grpc.ServiceDesc for MetaServer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMetaServerServer ¶
func RegisterMetaServerServer(s grpc.ServiceRegistrar, srv MetaServerServer)
Types ¶
type AppendFileRequest ¶
type AppendFileRequest struct { ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"` Dir string `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"` Entry []*rfs.Entry `protobuf:"bytes,3,rep,name=entry,proto3" json:"entry,omitempty"` // contains filtered or unexported fields }
func (*AppendFileRequest) Descriptor
deprecated
func (*AppendFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use AppendFileRequest.ProtoReflect.Descriptor instead.
func (*AppendFileRequest) GetClientId ¶
func (x *AppendFileRequest) GetClientId() string
func (*AppendFileRequest) GetDir ¶
func (x *AppendFileRequest) GetDir() string
func (*AppendFileRequest) GetEntry ¶
func (x *AppendFileRequest) GetEntry() []*rfs.Entry
func (*AppendFileRequest) ProtoMessage ¶
func (*AppendFileRequest) ProtoMessage()
func (*AppendFileRequest) ProtoReflect ¶
func (x *AppendFileRequest) ProtoReflect() protoreflect.Message
func (*AppendFileRequest) Reset ¶
func (x *AppendFileRequest) Reset()
func (*AppendFileRequest) String ¶
func (x *AppendFileRequest) String() string
type AppendFileResponse ¶
type AppendFileResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*AppendFileResponse) Descriptor
deprecated
func (*AppendFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use AppendFileResponse.ProtoReflect.Descriptor instead.
func (*AppendFileResponse) GetError ¶
func (x *AppendFileResponse) GetError() string
func (*AppendFileResponse) ProtoMessage ¶
func (*AppendFileResponse) ProtoMessage()
func (*AppendFileResponse) ProtoReflect ¶
func (x *AppendFileResponse) ProtoReflect() protoreflect.Message
func (*AppendFileResponse) Reset ¶
func (x *AppendFileResponse) Reset()
func (*AppendFileResponse) String ¶
func (x *AppendFileResponse) String() string
type CreateFileRequest ¶
type CreateFileRequest struct { ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"` Dir string `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"` OExcl bool `protobuf:"varint,3,opt,name=o_excl,json=oExcl,proto3" json:"o_excl,omitempty"` SkipCheckParentDirectory bool `` /* 138-byte string literal not displayed */ Entry *rfs.Entry `protobuf:"bytes,5,opt,name=entry,proto3" json:"entry,omitempty"` // contains filtered or unexported fields }
func (*CreateFileRequest) Descriptor
deprecated
func (*CreateFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateFileRequest.ProtoReflect.Descriptor instead.
func (*CreateFileRequest) GetClientId ¶
func (x *CreateFileRequest) GetClientId() string
func (*CreateFileRequest) GetDir ¶
func (x *CreateFileRequest) GetDir() string
func (*CreateFileRequest) GetEntry ¶
func (x *CreateFileRequest) GetEntry() *rfs.Entry
func (*CreateFileRequest) GetOExcl ¶
func (x *CreateFileRequest) GetOExcl() bool
func (*CreateFileRequest) GetSkipCheckParentDirectory ¶
func (x *CreateFileRequest) GetSkipCheckParentDirectory() bool
func (*CreateFileRequest) ProtoMessage ¶
func (*CreateFileRequest) ProtoMessage()
func (*CreateFileRequest) ProtoReflect ¶
func (x *CreateFileRequest) ProtoReflect() protoreflect.Message
func (*CreateFileRequest) Reset ¶
func (x *CreateFileRequest) Reset()
func (*CreateFileRequest) String ¶
func (x *CreateFileRequest) String() string
type CreateFileResponse ¶
type CreateFileResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*CreateFileResponse) Descriptor
deprecated
func (*CreateFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateFileResponse.ProtoReflect.Descriptor instead.
func (*CreateFileResponse) GetError ¶
func (x *CreateFileResponse) GetError() string
func (*CreateFileResponse) ProtoMessage ¶
func (*CreateFileResponse) ProtoMessage()
func (*CreateFileResponse) ProtoReflect ¶
func (x *CreateFileResponse) ProtoReflect() protoreflect.Message
func (*CreateFileResponse) Reset ¶
func (x *CreateFileResponse) Reset()
func (*CreateFileResponse) String ¶
func (x *CreateFileResponse) String() string
type GetFileRequest ¶
type GetFileRequest struct { ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*GetFileRequest) Descriptor
deprecated
func (*GetFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.
func (*GetFileRequest) GetClientId ¶
func (x *GetFileRequest) GetClientId() string
func (*GetFileRequest) GetPath ¶
func (x *GetFileRequest) GetPath() string
func (*GetFileRequest) ProtoMessage ¶
func (*GetFileRequest) ProtoMessage()
func (*GetFileRequest) ProtoReflect ¶
func (x *GetFileRequest) ProtoReflect() protoreflect.Message
func (*GetFileRequest) Reset ¶
func (x *GetFileRequest) Reset()
func (*GetFileRequest) String ¶
func (x *GetFileRequest) String() string
type GetFileResponse ¶
type GetFileResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Entry *rfs.Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"` // contains filtered or unexported fields }
func (*GetFileResponse) Descriptor
deprecated
func (*GetFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetFileResponse.ProtoReflect.Descriptor instead.
func (*GetFileResponse) GetEntry ¶
func (x *GetFileResponse) GetEntry() *rfs.Entry
func (*GetFileResponse) GetError ¶
func (x *GetFileResponse) GetError() string
func (*GetFileResponse) ProtoMessage ¶
func (*GetFileResponse) ProtoMessage()
func (*GetFileResponse) ProtoReflect ¶
func (x *GetFileResponse) ProtoReflect() protoreflect.Message
func (*GetFileResponse) Reset ¶
func (x *GetFileResponse) Reset()
func (*GetFileResponse) String ¶
func (x *GetFileResponse) String() string
type ListRequest ¶
type ListRequest struct { ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"` Dir string `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"` // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetClientId ¶
func (x *ListRequest) GetClientId() string
func (*ListRequest) GetDir ¶
func (x *ListRequest) GetDir() string
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Entries []*rfs.Entry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetEntries ¶
func (x *ListResponse) GetEntries() []*rfs.Entry
func (*ListResponse) GetError ¶
func (x *ListResponse) GetError() string
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type MetaServerClient ¶
type MetaServerClient interface { CreateFile(ctx context.Context, in *CreateFileRequest, opts ...grpc.CallOption) (*CreateFileResponse, error) AppendFile(ctx context.Context, in *AppendFileRequest, opts ...grpc.CallOption) (*AppendFileResponse, error) GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (*GetFileResponse, error) Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error) Move(ctx context.Context, in *MoveRequest, opts ...grpc.CallOption) (*MoveResponse, error) Mkdir(ctx context.Context, in *MkdirRequest, opts ...grpc.CallOption) (*MkdirResponse, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) }
MetaServerClient is the client API for MetaServer 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 NewMetaServerClient ¶
func NewMetaServerClient(cc grpc.ClientConnInterface) MetaServerClient
type MetaServerServer ¶
type MetaServerServer interface { CreateFile(context.Context, *CreateFileRequest) (*CreateFileResponse, error) AppendFile(context.Context, *AppendFileRequest) (*AppendFileResponse, error) GetFile(context.Context, *GetFileRequest) (*GetFileResponse, error) Stat(context.Context, *StatRequest) (*StatResponse, error) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error) Move(context.Context, *MoveRequest) (*MoveResponse, error) Mkdir(context.Context, *MkdirRequest) (*MkdirResponse, error) List(context.Context, *ListRequest) (*ListResponse, error) Ping(context.Context, *PingRequest) (*PingResponse, error) // contains filtered or unexported methods }
MetaServerServer is the server API for MetaServer service. All implementations must embed UnimplementedMetaServerServer for forward compatibility
type MkdirRequest ¶
type MkdirRequest struct { ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"` Directory string `protobuf:"bytes,2,opt,name=directory,proto3" json:"directory,omitempty"` // contains filtered or unexported fields }
func (*MkdirRequest) Descriptor
deprecated
func (*MkdirRequest) Descriptor() ([]byte, []int)
Deprecated: Use MkdirRequest.ProtoReflect.Descriptor instead.
func (*MkdirRequest) GetClientId ¶
func (x *MkdirRequest) GetClientId() string
func (*MkdirRequest) GetDirectory ¶
func (x *MkdirRequest) GetDirectory() string
func (*MkdirRequest) ProtoMessage ¶
func (*MkdirRequest) ProtoMessage()
func (*MkdirRequest) ProtoReflect ¶
func (x *MkdirRequest) ProtoReflect() protoreflect.Message
func (*MkdirRequest) Reset ¶
func (x *MkdirRequest) Reset()
func (*MkdirRequest) String ¶
func (x *MkdirRequest) String() string
type MkdirResponse ¶
type MkdirResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*MkdirResponse) Descriptor
deprecated
func (*MkdirResponse) Descriptor() ([]byte, []int)
Deprecated: Use MkdirResponse.ProtoReflect.Descriptor instead.
func (*MkdirResponse) GetError ¶
func (x *MkdirResponse) GetError() string
func (*MkdirResponse) ProtoMessage ¶
func (*MkdirResponse) ProtoMessage()
func (*MkdirResponse) ProtoReflect ¶
func (x *MkdirResponse) ProtoReflect() protoreflect.Message
func (*MkdirResponse) Reset ¶
func (x *MkdirResponse) Reset()
func (*MkdirResponse) String ¶
func (x *MkdirResponse) String() string
type MoveRequest ¶
type MoveRequest struct { ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"` SrcPath string `protobuf:"bytes,2,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"` DstPath string `protobuf:"bytes,3,opt,name=dst_path,json=dstPath,proto3" json:"dst_path,omitempty"` // contains filtered or unexported fields }
func (*MoveRequest) Descriptor
deprecated
func (*MoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use MoveRequest.ProtoReflect.Descriptor instead.
func (*MoveRequest) GetClientId ¶
func (x *MoveRequest) GetClientId() string
func (*MoveRequest) GetDstPath ¶
func (x *MoveRequest) GetDstPath() string
func (*MoveRequest) GetSrcPath ¶
func (x *MoveRequest) GetSrcPath() string
func (*MoveRequest) ProtoMessage ¶
func (*MoveRequest) ProtoMessage()
func (*MoveRequest) ProtoReflect ¶
func (x *MoveRequest) ProtoReflect() protoreflect.Message
func (*MoveRequest) Reset ¶
func (x *MoveRequest) Reset()
func (*MoveRequest) String ¶
func (x *MoveRequest) String() string
type MoveResponse ¶
type MoveResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*MoveResponse) Descriptor
deprecated
func (*MoveResponse) Descriptor() ([]byte, []int)
Deprecated: Use MoveResponse.ProtoReflect.Descriptor instead.
func (*MoveResponse) GetError ¶
func (x *MoveResponse) GetError() string
func (*MoveResponse) ProtoMessage ¶
func (*MoveResponse) ProtoMessage()
func (*MoveResponse) ProtoReflect ¶
func (x *MoveResponse) ProtoReflect() protoreflect.Message
func (*MoveResponse) Reset ¶
func (x *MoveResponse) Reset()
func (*MoveResponse) String ¶
func (x *MoveResponse) String() string
type PingRequest ¶
type PingRequest struct { Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` TargetType string `protobuf:"bytes,2,opt,name=target_type,json=targetType,proto3" json:"target_type,omitempty"` // contains filtered or unexported fields }
func (*PingRequest) Descriptor
deprecated
func (*PingRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) GetTarget ¶
func (x *PingRequest) GetTarget() string
func (*PingRequest) GetTargetType ¶
func (x *PingRequest) GetTargetType() string
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) ProtoReflect ¶
func (x *PingRequest) ProtoReflect() protoreflect.Message
func (*PingRequest) Reset ¶
func (x *PingRequest) Reset()
func (*PingRequest) String ¶
func (x *PingRequest) String() string
type PingResponse ¶
type PingResponse struct { StartTimeNs int64 `protobuf:"varint,1,opt,name=start_time_ns,json=startTimeNs,proto3" json:"start_time_ns,omitempty"` RemoteTimeNs int64 `protobuf:"varint,2,opt,name=remote_time_ns,json=remoteTimeNs,proto3" json:"remote_time_ns,omitempty"` StopTimeNs int64 `protobuf:"varint,3,opt,name=stop_time_ns,json=stopTimeNs,proto3" json:"stop_time_ns,omitempty"` // contains filtered or unexported fields }
func (*PingResponse) Descriptor
deprecated
func (*PingResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
func (*PingResponse) GetRemoteTimeNs ¶
func (x *PingResponse) GetRemoteTimeNs() int64
func (*PingResponse) GetStartTimeNs ¶
func (x *PingResponse) GetStartTimeNs() int64
func (*PingResponse) GetStopTimeNs ¶
func (x *PingResponse) GetStopTimeNs() int64
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) ProtoReflect ¶
func (x *PingResponse) ProtoReflect() protoreflect.Message
func (*PingResponse) Reset ¶
func (x *PingResponse) Reset()
func (*PingResponse) String ¶
func (x *PingResponse) String() string
type RemoveRequest ¶
type RemoveRequest struct { ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Recursive bool `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"` // contains filtered or unexported fields }
func (*RemoveRequest) Descriptor
deprecated
func (*RemoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.
func (*RemoveRequest) GetClientId ¶
func (x *RemoveRequest) GetClientId() string
func (*RemoveRequest) GetPath ¶
func (x *RemoveRequest) GetPath() string
func (*RemoveRequest) GetRecursive ¶
func (x *RemoveRequest) GetRecursive() bool
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 { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*RemoveResponse) Descriptor
deprecated
func (*RemoveResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.
func (*RemoveResponse) GetError ¶
func (x *RemoveResponse) GetError() string
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 StatRequest ¶
type StatRequest struct { ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*StatRequest) Descriptor
deprecated
func (*StatRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatRequest.ProtoReflect.Descriptor instead.
func (*StatRequest) GetClientId ¶
func (x *StatRequest) GetClientId() string
func (*StatRequest) GetPath ¶
func (x *StatRequest) GetPath() string
func (*StatRequest) ProtoMessage ¶
func (*StatRequest) ProtoMessage()
func (*StatRequest) ProtoReflect ¶
func (x *StatRequest) ProtoReflect() protoreflect.Message
func (*StatRequest) Reset ¶
func (x *StatRequest) Reset()
func (*StatRequest) String ¶
func (x *StatRequest) String() string
type StatResponse ¶
type StatResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Entry *rfs.Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"` // contains filtered or unexported fields }
func (*StatResponse) Descriptor
deprecated
func (*StatResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatResponse.ProtoReflect.Descriptor instead.
func (*StatResponse) GetEntry ¶
func (x *StatResponse) GetEntry() *rfs.Entry
func (*StatResponse) GetError ¶
func (x *StatResponse) GetError() string
func (*StatResponse) ProtoMessage ¶
func (*StatResponse) ProtoMessage()
func (*StatResponse) ProtoReflect ¶
func (x *StatResponse) ProtoReflect() protoreflect.Message
func (*StatResponse) Reset ¶
func (x *StatResponse) Reset()
func (*StatResponse) String ¶
func (x *StatResponse) String() string
type UnimplementedMetaServerServer ¶
type UnimplementedMetaServerServer struct { }
UnimplementedMetaServerServer must be embedded to have forward compatible implementations.
func (UnimplementedMetaServerServer) AppendFile ¶
func (UnimplementedMetaServerServer) AppendFile(context.Context, *AppendFileRequest) (*AppendFileResponse, error)
func (UnimplementedMetaServerServer) CreateFile ¶
func (UnimplementedMetaServerServer) CreateFile(context.Context, *CreateFileRequest) (*CreateFileResponse, error)
func (UnimplementedMetaServerServer) GetFile ¶
func (UnimplementedMetaServerServer) GetFile(context.Context, *GetFileRequest) (*GetFileResponse, error)
func (UnimplementedMetaServerServer) List ¶
func (UnimplementedMetaServerServer) List(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedMetaServerServer) Mkdir ¶
func (UnimplementedMetaServerServer) Mkdir(context.Context, *MkdirRequest) (*MkdirResponse, error)
func (UnimplementedMetaServerServer) Move ¶
func (UnimplementedMetaServerServer) Move(context.Context, *MoveRequest) (*MoveResponse, error)
func (UnimplementedMetaServerServer) Ping ¶
func (UnimplementedMetaServerServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
func (UnimplementedMetaServerServer) Remove ¶
func (UnimplementedMetaServerServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
func (UnimplementedMetaServerServer) Stat ¶
func (UnimplementedMetaServerServer) Stat(context.Context, *StatRequest) (*StatResponse, error)
type UnsafeMetaServerServer ¶
type UnsafeMetaServerServer interface {
// contains filtered or unexported methods
}
UnsafeMetaServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetaServerServer will result in compilation errors.