apiserver

Documentation

Index

• Constants
• Variables
• func DeleteFile(ctx *macaron.Context, log *logs.BeeLogger) (int, []byte)
• func DownloadFile(ctx *macaron.Context, log *logs.BeeLogger) (int, []byte)
• func GetChunkServerGroups() *chunkserver.ChunkServerGroups
• func GetChunkServerInfo() error
• func GetChunkServerInfoTicker()
• func GetConnectionPools() *chunkserver.ChunkServerConnectionPool
• func GetFidRange(mergeWait bool) error
• func GetFidRangeTicker()
• func GetFileInfo(ctx *macaron.Context, log *logs.BeeLogger) (int, []byte)
• func InitAPI() error
• func ReplaceChunkServerGroups(newGroups *chunkserver.ChunkServerGroups)
• func ReplaceConnPoolsAndChunkServerGroups(newConnectionPool *chunkserver.ChunkServerConnectionPool, ...)
• func UploadFile(ctx *macaron.Context, log *logs.BeeLogger) (int, []byte)

Constants

const (
	LimitCSNormalSize = 2
	SUCCESS           = ""
	VERSION1          = "v1"
	VERSION2          = "v2"
)

Variables

var (
	MasterUrl  string
	MasterPort string
	Ip         string
	Port       int
	HttpsPort  int
	Router     *mux.Router
	Running    bool
	Mu         sync.Mutex

	LimitNum         int
	ConnPoolCapacity int

	MetadbIp       string
	MetadbPort     int
	MetadbUser     string
	MetadbPassword string
	MetaDatabase   string
)

Functions

func DeleteFile

func DeleteFile(ctx *macaron.Context, log *logs.BeeLogger) (int, []byte)

func DownloadFile

func DownloadFile(ctx *macaron.Context, log *logs.BeeLogger) (int, []byte)

func GetChunkServerGroups

func GetChunkServerGroups() *chunkserver.ChunkServerGroups

func GetChunkServerInfo

func GetChunkServerInfo() error

func GetChunkServerInfoTicker

func GetChunkServerInfoTicker()

func GetConnectionPools

func GetConnectionPools() *chunkserver.ChunkServerConnectionPool

func GetFidRange

func GetFidRange(mergeWait bool) error

func GetFidRangeTicker

func GetFidRangeTicker()

func GetFileInfo

func GetFileInfo(ctx *macaron.Context, log *logs.BeeLogger) (int, []byte)

func InitAPI

func InitAPI() error

func ReplaceChunkServerGroups

func ReplaceChunkServerGroups(newGroups *chunkserver.ChunkServerGroups)

func ReplaceConnPoolsAndChunkServerGroups

func ReplaceConnPoolsAndChunkServerGroups(newConnectionPool *chunkserver.ChunkServerConnectionPool, newGroups *chunkserver.ChunkServerGroups)

func UploadFile

func UploadFile(ctx *macaron.Context, log *logs.BeeLogger) (int, []byte)