master

README

JimDB Master

catalog management and cluster coordination

Documentation

Index

• Constants
• func ExportToClusterHandler(router *gin.Engine, service *service.BaseService)
• func ExportToHealthHandler(router *gin.Engine, service *service.BaseService)
• func ExportToNodeHandler(router *gin.Engine, nodeService *service.BaseService)
• func ExportToRangeHandler(router *gin.Engine, rangeService *service.BaseService, ...)
• func ExportToWatcherHandler(router *gin.Engine, bs *service.BaseService) *service.WatcherService
• type ConfigResult
• type RangeChange
  • func (r RangeChange) IsChanged() bool
  • func (r RangeChange) IsLeaderChange() bool
  • func (r RangeChange) IsPeerChange() bool
• type Server
  • func NewServer(ctx context.Context, cancel context.CancelFunc) (*Server, error)
  • func (s *Server) Start() (err error)
  • func (s *Server) Stop()

Constants

const (
	Timeout          = "timeout"
	CancelFunc       = "__cancelFunc"
	Ctx              = "__ctx"
	Start            = "__start_time"
	ProtoContentType = "application/proto"
)

Functions

func ExportToClusterHandler

func ExportToClusterHandler(router *gin.Engine, service *service.BaseService)

func ExportToHealthHandler

func ExportToHealthHandler(router *gin.Engine, service *service.BaseService)

func ExportToNodeHandler

func ExportToNodeHandler(router *gin.Engine, nodeService *service.BaseService)

func ExportToRangeHandler

func ExportToRangeHandler(router *gin.Engine, rangeService *service.BaseService, watcherService *service.WatcherService)

func ExportToWatcherHandler

func ExportToWatcherHandler(router *gin.Engine, bs *service.BaseService) *service.WatcherService

Types

type ConfigResult

type ConfigResult struct {
	Error     string `json:"error,omitempty"`
	AutoSplit bool   `json:"auto_split"`
	FailOver  bool   `json:"fail_over"`
	Balanced  bool   `json:"balanced"`
}

type RangeChange

type RangeChange int

const (
	LeaderChange RangeChange = 1 << iota
	PeerChange
)

func (RangeChange) IsChanged

func (r RangeChange) IsChanged() bool

func (RangeChange) IsLeaderChange

func (r RangeChange) IsLeaderChange() bool

func (RangeChange) IsPeerChange

func (r RangeChange) IsPeerChange() bool

type Server

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

func NewServer

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

func (*Server) Start

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

func (*Server) Stop

func (s *Server) Stop()