server

package
v0.0.0-...-7101970 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

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 NewMDS 

func NewMDS(endpoint string, readTimeout, writeTimeout int) *MDS

NewMDS return a mds instance

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 (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 

func (m *MDS) RegistHTTPRouter() *mux.Router

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

func (m *MDS) Run()

Run start pixar http and grpc server

func (*MDS) RunOnlyHTTP 

func (m *MDS) RunOnlyHTTP()

RunOnlyHTTP only http

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

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.