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 (*MDS) Close

func (*MDS) Create

func (*MDS) CreateVolume

CreateVolume return an volume

func (*MDS) DelChunk

func (*MDS) DelDelFile

func (*MDS) Fallocate

func (*MDS) Flock

func (*MDS) GetAttr

func (*MDS) GetChunks

func (*MDS) GetDelFiles

func (*MDS) GetXAttr

func (*MDS) Getlk

func (*MDS) ListSlices

func (*MDS) ListXAttr

func (*MDS) Lookup

func (*MDS) Mkdir

func (*MDS) Mknod

func (*MDS) NewSession

func (*MDS) NextInode

func (*MDS) NextSlice

func (*MDS) Open

func (*MDS) Read

func (*MDS) Readdir

func (*MDS) RegistHTTPRouter

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

RegistHTTPRouter http router for manager api

func (*MDS) RemoveXAttr

func (*MDS) Rename

func (*MDS) Resolve

func (*MDS) Rmdir

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

func (*MDS) SetXAttr

func (*MDS) Setlk

func (*MDS) StatFS

func (*MDS) Status

func (m *MDS) Status(w http.ResponseWriter, r *http.Request)

Status return mds current status

func (*MDS) Truncate

func (*MDS) Write

Jump to

Keyboard shortcuts

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