master

Documentation

Index

• Constants
• func Auth(c *gin.Context) (err error)
• func ExportToClusterHandler(router *gin.Engine, masterService *masterService)
• func ExportToMonitorHandler(router *gin.Engine, monitorService *monitorService)
• type Server
  • func NewServer(ctx context.Context) (*Server, error)
  • func (s *Server) Start() (err error)
  • func (s *Server) StartCleanJon(ctx context.Context)
  • func (s *Server) Stop()
  • func (s *Server) WatchServerJob(ctx context.Context, cli *client.Client) error

Constants

const (
	DB = "db"

	NodeID = "node_id"
)

const CronInterval = 60

Functions

func Auth

func Auth(c *gin.Context) (err error)

Auth valid whether username is root and password equal config

func ExportToClusterHandler

func ExportToClusterHandler(router *gin.Engine, masterService *masterService)

func ExportToMonitorHandler

func ExportToMonitorHandler(router *gin.Engine, monitorService *monitorService)

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context) (*Server, error)

func (*Server) Start

func (s *Server) Start() (err error)

func (*Server) StartCleanJon

func (s *Server) StartCleanJon(ctx context.Context)

the job check partition infos and fix it

func (*Server) Stop

func (s *Server) Stop()

func (*Server) WatchServerJob

func (s *Server) WatchServerJob(ctx context.Context, cli *client.Client) error

WatchServerJob watch ps server put and delete