master

Documentation

Index

• Constants
• func ExportToClusterHandler(router *gin.Engine, masterService *masterService)
• func ExportToUserHandler(router *gin.Engine, masterService *masterService)
• func NewUser(name, password, allowedHost string, userDB map[string]struct{}, ...) *entity.User
• 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()

Constants

const (
	DB = "db"

	PartitionId = "partition_id"
)

const CronInterval = 60

Functions

func ExportToClusterHandler

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

func ExportToUserHandler

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

func NewUser

func NewUser(name, password, allowedHost string, userDB map[string]struct{}, privi entity.UserPrivi) *entity.User

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