Documentation ¶
Index ¶
- Constants
- type MDS
- func (m *MDS) Access(context.Context, *pb.AccessRequest) (*pb.AccessResponse, error)
- func (m *MDS) CleanInvalidSessions(context.Context, *pb.CleanInvalidSessionsRequest) (*pb.CleanInvalidSessionsResponse, error)
- func (m *MDS) Close(context.Context, *pb.CloseRequest) (*pb.CloseResponse, error)
- func (m *MDS) CommitCompact(context.Context, *pb.CommitCompactRequest) (*pb.CommitCompactResponse, error)
- func (m *MDS) CompactSlices(context.Context, *pb.CompactSlicesRequest) (*pb.CompactSlicesResponse, error)
- func (m *MDS) CopyFileRange(context.Context, *pb.CopyFileRangeRequest) (*pb.CopyFileRangeResponse, error)
- func (m *MDS) Create(context.Context, *pb.CreateRequest) (*pb.CreateResponse, error)
- func (m *MDS) CreateVolume(context.Context, *pb.CreateVolumeRequest) (*pb.CreateVolumeResponse, error)
- func (m *MDS) DelChunk(context.Context, *pb.DelChunkRequest) (*pb.DelChunkResponse, error)
- func (m *MDS) DelDelFile(context.Context, *pb.DelDelFileRequest) (*pb.DelDelFileResponse, error)
- func (m *MDS) Fallocate(context.Context, *pb.FallocateRequest) (*pb.FallocateResponse, error)
- func (m *MDS) FindCompactChunk(context.Context, *pb.FindCompactChunkRequest) (*pb.FindCompactChunkResponse, error)
- func (m *MDS) Flock(context.Context, *pb.FlockRequest) (*pb.FlockResponse, error)
- func (m *MDS) GetAttr(context.Context, *pb.GetAttrRequest) (*pb.GetAttrResponse, error)
- func (m *MDS) GetChunks(context.Context, *pb.GetChunksRequest) (*pb.GetChunksResponse, error)
- func (m *MDS) GetDelFiles(context.Context, *pb.GetDelFilesRequest) (*pb.GetDelFilesResponse, error)
- func (m *MDS) GetXAttr(context.Context, *pb.GetXAttrRequest) (*pb.GetXAttrResponse, error)
- func (m *MDS) Getlk(context.Context, *pb.GetlkRequest) (*pb.GetlkResponse, error)
- func (m *MDS) Link(context.Context, *pb.LinkRequest) (*pb.LinkResponse, error)
- func (m *MDS) ListSlices(context.Context, *pb.ListSlicesRequest) (*pb.ListSlicesResponse, error)
- func (m *MDS) ListXAttr(context.Context, *pb.ListXAttrRequest) (*pb.ListXAttrResponse, error)
- func (m *MDS) Lookup(context.Context, *pb.LookupRequest) (*pb.LookupResponse, error)
- func (m *MDS) Mkdir(context.Context, *pb.MkdirRequest) (*pb.MkdirResponse, error)
- func (m *MDS) Mknod(context.Context, *pb.MknodRequest) (*pb.MknodResponse, error)
- func (m *MDS) NewSession(context.Context, *pb.NewSessionRequest) (*pb.NewSessionResponse, error)
- func (m *MDS) NextInode(context.Context, *pb.NextInodeRequest) (*pb.NextInodeResponse, error)
- func (m *MDS) NextSlice(context.Context, *pb.NextSliceRequest) (*pb.NextSliceResponse, error)
- func (m *MDS) Open(context.Context, *pb.OpenRequest) (*pb.OpenResponse, error)
- func (m *MDS) Read(context.Context, *pb.ReadRequest) (*pb.ReadResponse, error)
- func (m *MDS) Readdir(context.Context, *pb.ReaddirRequest) (*pb.ReaddirResponse, error)
- func (m *MDS) RegistHTTPRouter() *mux.Router
- func (m *MDS) RemoveXAttr(context.Context, *pb.RemoveXAttrRequest) (*pb.RemoveXAttrResponse, error)
- func (m *MDS) Rename(context.Context, *pb.RenameRequest) (*pb.RenameResponse, error)
- func (m *MDS) Resolve(context.Context, *pb.ResolveRequest) (*pb.ResolveResponse, error)
- func (m *MDS) Rmdir(context.Context, *pb.RmdirRequest) (*pb.RmdirResponse, error)
- func (m *MDS) Run()
- func (m *MDS) RunOnlyHTTP()
- func (m *MDS) SessionHeartbeat(context.Context, *pb.SessionHeartbeatRequest) (*pb.SessionHeartbeatResponse, error)
- func (m *MDS) SetAttr(context.Context, *pb.SetAttrRequest) (*pb.SetAttrResponse, error)
- func (m *MDS) SetXAttr(context.Context, *pb.SetXAttrResponse) (*pb.SetXAttrResponse, error)
- func (m *MDS) Setlk(context.Context, *pb.SetlkRequest) (*pb.SetlkResponse, error)
- func (m *MDS) StatFS(context.Context, *pb.StatFSRequest) (*pb.StatFSResponse, error)
- func (m *MDS) Status(w http.ResponseWriter, r *http.Request)
- func (m *MDS) Symlink(context.Context, *pb.SymlinkRequest) (*pb.SymlinkResponse, error)
- func (m *MDS) Truncate(context.Context, *pb.TruncateRequest) (*pb.TruncateResponse, error)
- func (m *MDS) Unlink(context.Context, *pb.UnlinkRequest) (*pb.UnlinkResponse, error)
- func (m *MDS) UpdateNeedCompact(context.Context, *pb.UpdateNeedCompactRequest) (*pb.UpdateNeedCompactResponse, error)
- func (m *MDS) Write(context.Context, *pb.WriteRequest) (*pb.WriteResponse, error)
Constants ¶
View Source
const ( // KeepAliveTime is the duration of time after which if the client doesn't see // any activity it pings the server to see if the transport is still alive. KeepAliveTime = time.Duration(10) * time.Second // KeepAliveTimeout is the duration of time for which the client waits after having // pinged for keepalive check and if no activity is seen even after that the connection // is closed. KeepAliveTimeout = time.Duration(3) * time.Second // InitialWindowSize we set it 1GB is to provide system's throughput. InitialWindowSize = 1 << 30 // InitialConnWindowSize we set it 1GB is to provide system's throughput. InitialConnWindowSize = 1 << 30 // MaxSendMsgSize set max gRPC request message size sent to server. // If any request message size is larger than current value, an error will be reported from gRPC. MaxSendMsgSize = 4 << 30 // MaxRecvMsgSize set max gRPC receive message size received from server. // If any message size is larger than current value, an error will be reported from gRPC. MaxRecvMsgSize = 4 << 30 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MDS ¶
type MDS struct {
// contains filtered or unexported fields
}
MDS metadata server
func (*MDS) Access ¶
func (m *MDS) Access(context.Context, *pb.AccessRequest) (*pb.AccessResponse, error)
func (*MDS) CleanInvalidSessions ¶
func (m *MDS) CleanInvalidSessions(context.Context, *pb.CleanInvalidSessionsRequest) (*pb.CleanInvalidSessionsResponse, error)
func (*MDS) Close ¶
func (m *MDS) Close(context.Context, *pb.CloseRequest) (*pb.CloseResponse, error)
func (*MDS) CommitCompact ¶
func (m *MDS) CommitCompact(context.Context, *pb.CommitCompactRequest) (*pb.CommitCompactResponse, error)
func (*MDS) CompactSlices ¶
func (m *MDS) CompactSlices(context.Context, *pb.CompactSlicesRequest) (*pb.CompactSlicesResponse, error)
func (*MDS) CopyFileRange ¶
func (m *MDS) CopyFileRange(context.Context, *pb.CopyFileRangeRequest) (*pb.CopyFileRangeResponse, error)
func (*MDS) Create ¶
func (m *MDS) Create(context.Context, *pb.CreateRequest) (*pb.CreateResponse, error)
func (*MDS) CreateVolume ¶
func (m *MDS) CreateVolume(context.Context, *pb.CreateVolumeRequest) (*pb.CreateVolumeResponse, error)
CreateVolume return an volume
func (*MDS) DelChunk ¶
func (m *MDS) DelChunk(context.Context, *pb.DelChunkRequest) (*pb.DelChunkResponse, error)
func (*MDS) DelDelFile ¶
func (m *MDS) DelDelFile(context.Context, *pb.DelDelFileRequest) (*pb.DelDelFileResponse, error)
func (*MDS) Fallocate ¶
func (m *MDS) Fallocate(context.Context, *pb.FallocateRequest) (*pb.FallocateResponse, error)
func (*MDS) FindCompactChunk ¶
func (m *MDS) FindCompactChunk(context.Context, *pb.FindCompactChunkRequest) (*pb.FindCompactChunkResponse, error)
func (*MDS) Flock ¶
func (m *MDS) Flock(context.Context, *pb.FlockRequest) (*pb.FlockResponse, error)
func (*MDS) GetAttr ¶
func (m *MDS) GetAttr(context.Context, *pb.GetAttrRequest) (*pb.GetAttrResponse, error)
func (*MDS) GetChunks ¶
func (m *MDS) GetChunks(context.Context, *pb.GetChunksRequest) (*pb.GetChunksResponse, error)
func (*MDS) GetDelFiles ¶
func (m *MDS) GetDelFiles(context.Context, *pb.GetDelFilesRequest) (*pb.GetDelFilesResponse, error)
func (*MDS) GetXAttr ¶
func (m *MDS) GetXAttr(context.Context, *pb.GetXAttrRequest) (*pb.GetXAttrResponse, error)
func (*MDS) Getlk ¶
func (m *MDS) Getlk(context.Context, *pb.GetlkRequest) (*pb.GetlkResponse, error)
func (*MDS) Link ¶
func (m *MDS) Link(context.Context, *pb.LinkRequest) (*pb.LinkResponse, error)
func (*MDS) ListSlices ¶
func (m *MDS) ListSlices(context.Context, *pb.ListSlicesRequest) (*pb.ListSlicesResponse, error)
func (*MDS) ListXAttr ¶
func (m *MDS) ListXAttr(context.Context, *pb.ListXAttrRequest) (*pb.ListXAttrResponse, error)
func (*MDS) Lookup ¶
func (m *MDS) Lookup(context.Context, *pb.LookupRequest) (*pb.LookupResponse, error)
func (*MDS) Mkdir ¶
func (m *MDS) Mkdir(context.Context, *pb.MkdirRequest) (*pb.MkdirResponse, error)
func (*MDS) Mknod ¶
func (m *MDS) Mknod(context.Context, *pb.MknodRequest) (*pb.MknodResponse, error)
func (*MDS) NewSession ¶
func (m *MDS) NewSession(context.Context, *pb.NewSessionRequest) (*pb.NewSessionResponse, error)
func (*MDS) NextInode ¶
func (m *MDS) NextInode(context.Context, *pb.NextInodeRequest) (*pb.NextInodeResponse, error)
func (*MDS) NextSlice ¶
func (m *MDS) NextSlice(context.Context, *pb.NextSliceRequest) (*pb.NextSliceResponse, error)
func (*MDS) Open ¶
func (m *MDS) Open(context.Context, *pb.OpenRequest) (*pb.OpenResponse, error)
func (*MDS) Read ¶
func (m *MDS) Read(context.Context, *pb.ReadRequest) (*pb.ReadResponse, error)
func (*MDS) Readdir ¶
func (m *MDS) Readdir(context.Context, *pb.ReaddirRequest) (*pb.ReaddirResponse, error)
func (*MDS) RegistHTTPRouter ¶
RegistHTTPRouter http router for manager api
func (*MDS) RemoveXAttr ¶
func (m *MDS) RemoveXAttr(context.Context, *pb.RemoveXAttrRequest) (*pb.RemoveXAttrResponse, error)
func (*MDS) Rename ¶
func (m *MDS) Rename(context.Context, *pb.RenameRequest) (*pb.RenameResponse, error)
func (*MDS) Resolve ¶
func (m *MDS) Resolve(context.Context, *pb.ResolveRequest) (*pb.ResolveResponse, error)
func (*MDS) Rmdir ¶
func (m *MDS) Rmdir(context.Context, *pb.RmdirRequest) (*pb.RmdirResponse, error)
func (*MDS) SessionHeartbeat ¶
func (m *MDS) SessionHeartbeat(context.Context, *pb.SessionHeartbeatRequest) (*pb.SessionHeartbeatResponse, error)
func (*MDS) SetAttr ¶
func (m *MDS) SetAttr(context.Context, *pb.SetAttrRequest) (*pb.SetAttrResponse, error)
func (*MDS) SetXAttr ¶
func (m *MDS) SetXAttr(context.Context, *pb.SetXAttrResponse) (*pb.SetXAttrResponse, error)
func (*MDS) Setlk ¶
func (m *MDS) Setlk(context.Context, *pb.SetlkRequest) (*pb.SetlkResponse, error)
func (*MDS) StatFS ¶
func (m *MDS) StatFS(context.Context, *pb.StatFSRequest) (*pb.StatFSResponse, error)
func (*MDS) Status ¶
func (m *MDS) Status(w http.ResponseWriter, r *http.Request)
Status return mds current status
func (*MDS) Symlink ¶
func (m *MDS) Symlink(context.Context, *pb.SymlinkRequest) (*pb.SymlinkResponse, error)
func (*MDS) Truncate ¶
func (m *MDS) Truncate(context.Context, *pb.TruncateRequest) (*pb.TruncateResponse, error)
func (*MDS) Unlink ¶
func (m *MDS) Unlink(context.Context, *pb.UnlinkRequest) (*pb.UnlinkResponse, error)
func (*MDS) UpdateNeedCompact ¶
func (m *MDS) UpdateNeedCompact(context.Context, *pb.UpdateNeedCompactRequest) (*pb.UpdateNeedCompactResponse, error)
func (*MDS) Write ¶
func (m *MDS) Write(context.Context, *pb.WriteRequest) (*pb.WriteResponse, error)
Click to show internal directories.
Click to hide internal directories.