Documentation ¶
Index ¶
- Constants
- Variables
- func Logger(ctx *Context)
- func Summary(w http.ResponseWriter, ctx *Context)
- type Context
- type DiskServer
- func (d *DiskServer) AssignVolumeHandler(w http.ResponseWriter, r *http.Request)
- func (s *DiskServer) CreateDiskOpt()
- func (d *DiskServer) DeleteHandler(w http.ResponseWriter, r *http.Request)
- func (s *DiskServer) DistributedOperation(masterNode string, volumeId util.VIDType, op func(location Location) error) error
- func (d *DiskServer) GetHandler(w http.ResponseWriter, r *http.Request)
- func (s *DiskServer) Heartbeat()
- func (d *DiskServer) PostHandler(w http.ResponseWriter, r *http.Request)
- func (s *DiskServer) RegistRouter()
- func (d *DiskServer) ReplicatedDelete(masterNode string, volumeId util.VIDType, n *needle.Needle, r *http.Request) (uint32, error)
- func (s *DiskServer) ReplicatedWrite(masterNode string, volumeId util.VIDType, n *needle.Needle, r *http.Request) (size uint32, isUnchanged bool, errorStatus error)
- func (s *DiskServer) StartServer() bool
- func (s *DiskServer) StatusHandler(w http.ResponseWriter, r *http.Request)
- func (d *DiskServer) VacuumVolumeCheckHandler(w http.ResponseWriter, r *http.Request)
- func (d *DiskServer) VacuumVolumeCommitHandler(w http.ResponseWriter, r *http.Request)
- func (d *DiskServer) VacuumVolumeCompactHandler(w http.ResponseWriter, r *http.Request)
- func (d *DiskServer) VolumeDeleteHandler(w http.ResponseWriter, r *http.Request)
- type DistributedOperationResult
- type Location
- type LookupResult
- type RemoteResult
- type UploadResult
- type VidCache
- type VidInfo
Constants ¶
View Source
const ( StartLogTemplate = "begin: host=[%s] remoteRealIP=[%s] method=[%s] url=[%s] start_time=[%s] form_data=[%s] \n" EndLogTemplate = "" /* 139-byte string literal not displayed */ TimeFormat = "2006-01-02 15:04:05" RespBodyTypeJson = "json" RespBodyTypeString = "string" )
View Source
const (
HeaderXRealIP = "x-real-ip"
)
View Source
const (
MAX_TTL_VOLUME_REMOVAL_DELAY = 10 // 10 minutes
)
Variables ¶
View Source
var (
ErrorNotFound = errors.New("not found")
)
Functions ¶
func Summary ¶
func Summary(w http.ResponseWriter, ctx *Context)
Types ¶
type Context ¶
type Context struct { RemoteRealIP string Host string Start time.Time ProcessTime int64 FormValues string Request *http.Request RespHttpStatus int Err error RespBodyType string RespBody string RespBodyJson interface{} }
func NewContext ¶
type DiskServer ¶
type DiskServer struct { Port *int Ip *string MaxCpu *int DataCenter *string Rack *string Folders []string FolderMaxLimits []int Debug *bool Router *mux.Router Disk *diskopt.Disk CurrentLeader string ManageNode []string DiskServerLock sync.RWMutex PulseSeconds *int }
func NewDiskServer ¶
func NewDiskServer() *DiskServer
func (*DiskServer) AssignVolumeHandler ¶
func (d *DiskServer) AssignVolumeHandler(w http.ResponseWriter, r *http.Request)
func (*DiskServer) DeleteHandler ¶
func (d *DiskServer) DeleteHandler(w http.ResponseWriter, r *http.Request)
func (*DiskServer) DistributedOperation ¶
func (*DiskServer) GetHandler ¶
func (d *DiskServer) GetHandler(w http.ResponseWriter, r *http.Request)
func (*DiskServer) PostHandler ¶
func (d *DiskServer) PostHandler(w http.ResponseWriter, r *http.Request)
func (*DiskServer) RegistRouter ¶
func (s *DiskServer) RegistRouter()
func (*DiskServer) ReplicatedDelete ¶
func (*DiskServer) ReplicatedWrite ¶
func (*DiskServer) StatusHandler ¶
func (s *DiskServer) StatusHandler(w http.ResponseWriter, r *http.Request)
func (*DiskServer) VacuumVolumeCheckHandler ¶
func (d *DiskServer) VacuumVolumeCheckHandler(w http.ResponseWriter, r *http.Request)
func (*DiskServer) VacuumVolumeCommitHandler ¶
func (d *DiskServer) VacuumVolumeCommitHandler(w http.ResponseWriter, r *http.Request)
func (*DiskServer) VacuumVolumeCompactHandler ¶
func (d *DiskServer) VacuumVolumeCompactHandler(w http.ResponseWriter, r *http.Request)
func (*DiskServer) VolumeDeleteHandler ¶
func (d *DiskServer) VolumeDeleteHandler(w http.ResponseWriter, r *http.Request)
type DistributedOperationResult ¶
func (DistributedOperationResult) Error ¶
func (dr DistributedOperationResult) Error() error
type LookupResult ¶
type RemoteResult ¶
type UploadResult ¶
Click to show internal directories.
Click to hide internal directories.