scheduler

Documentation

Index

• func DiskMigratingStats(c *gin.Context, consulAddr string, input *DiskMigratingStatsInput) (*scheduler.DiskMigratingStats, error)
• func GetSchedulers(c *gin.Context, consulAddr string) ([]string, error)
• func LeaderStats(c *gin.Context, consulAddr string) (*scheduler.TasksStat, error)
• func Request(c *gin.Context, method, consulAddr, path, query string, body io.Reader, ...) (*http.Response, error)
• func Stats(c *gin.Context, nodeAddr string) (*scheduler.TasksStat, error)
• type DiskMigratingStatsInput

Functions

func DiskMigratingStats

func DiskMigratingStats(c *gin.Context, consulAddr string, input *DiskMigratingStatsInput) (*scheduler.DiskMigratingStats, error)

func GetSchedulers

func GetSchedulers(c *gin.Context, consulAddr string) ([]string, error)

func LeaderStats

func LeaderStats(c *gin.Context, consulAddr string) (*scheduler.TasksStat, error)

func Request

func Request(c *gin.Context, method, consulAddr, path, query string, body io.Reader, header map[string]string) (*http.Response, error)

func Stats

func Stats(c *gin.Context, nodeAddr string) (*scheduler.TasksStat, error)

Types

type DiskMigratingStatsInput

type DiskMigratingStatsInput struct {
	DiskId   uint32 `json:"disk_id"`
	TaskType string `json:"task_type"`
}