checkers

Documentation

Index

• Constants
• type BalanceChecker
  • func NewBalanceChecker(meta *meta.Meta, targetMgr meta.TargetManagerInterface, ...) *BalanceChecker
  • func (c BalanceChecker) Activate()
  • func (b *BalanceChecker) Check(ctx context.Context) []task.Task
  • func (c BalanceChecker) Deactivate()
  • func (b *BalanceChecker) Description() string
  • func (b *BalanceChecker) ID() utils.CheckerType
  • func (c BalanceChecker) IsActive() bool
• type ChannelChecker
  • func NewChannelChecker(meta *meta.Meta, dist *meta.DistributionManager, ...) *ChannelChecker
  • func (c ChannelChecker) Activate()
  • func (c *ChannelChecker) Check(ctx context.Context) []task.Task
  • func (c ChannelChecker) Deactivate()
  • func (c *ChannelChecker) Description() string
  • func (c *ChannelChecker) ID() utils.CheckerType
  • func (c ChannelChecker) IsActive() bool
• type Checker
• type CheckerController
  • func NewCheckerController(meta *meta.Meta, dist *meta.DistributionManager, ...) *CheckerController
  • func (controller *CheckerController) Activate(typ utils.CheckerType) error
  • func (controller *CheckerController) Check()
  • func (controller *CheckerController) Checkers() []Checker
  • func (controller *CheckerController) Deactivate(typ utils.CheckerType) error
  • func (controller *CheckerController) IsActive(typ utils.CheckerType) (bool, error)
  • func (controller *CheckerController) Start()
  • func (controller *CheckerController) Stop()
• type GetBalancerFunc
• type IndexChecker
  • func NewIndexChecker(meta *meta.Meta, dist *meta.DistributionManager, broker meta.Broker, ...) *IndexChecker
  • func (c IndexChecker) Activate()
  • func (c *IndexChecker) Check(ctx context.Context) []task.Task
  • func (c IndexChecker) Deactivate()
  • func (c *IndexChecker) Description() string
  • func (c *IndexChecker) ID() utils.CheckerType
  • func (c IndexChecker) IsActive() bool
• type LeaderChecker
  • func NewLeaderChecker(meta *meta.Meta, dist *meta.DistributionManager, ...) *LeaderChecker
  • func (c LeaderChecker) Activate()
  • func (c *LeaderChecker) Check(ctx context.Context) []task.Task
  • func (c LeaderChecker) Deactivate()
  • func (c *LeaderChecker) Description() string
  • func (c *LeaderChecker) ID() utils.CheckerType
  • func (c LeaderChecker) IsActive() bool
• type SegmentChecker
  • func NewSegmentChecker(meta *meta.Meta, dist *meta.DistributionManager, ...) *SegmentChecker
  • func (c SegmentChecker) Activate()
  • func (c *SegmentChecker) Check(ctx context.Context) []task.Task
  • func (c SegmentChecker) Deactivate()
  • func (c *SegmentChecker) Description() string
  • func (c *SegmentChecker) ID() utils.CheckerType
  • func (c SegmentChecker) IsActive() bool

Constants

const MaxSegmentNumPerGetIndexInfoRPC = 1024

Types

type BalanceChecker

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

BalanceChecker checks the cluster distribution and generates balance tasks.

func NewBalanceChecker

func NewBalanceChecker(meta *meta.Meta,
	targetMgr meta.TargetManagerInterface,
	nodeMgr *session.NodeManager,
	scheduler task.Scheduler,
	getBalancerFunc GetBalancerFunc,
) *BalanceChecker

func (BalanceChecker) Activate

func (c BalanceChecker) Activate()

func (*BalanceChecker) Check

func (b *BalanceChecker) Check(ctx context.Context) []task.Task

func (BalanceChecker) Deactivate

func (c BalanceChecker) Deactivate()

func (*BalanceChecker) Description

func (b *BalanceChecker) Description() string

func (*BalanceChecker) ID

func (b *BalanceChecker) ID() utils.CheckerType

func (BalanceChecker) IsActive

func (c BalanceChecker) IsActive() bool

type ChannelChecker

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

TODO(sunby): have too much similar codes with SegmentChecker

func NewChannelChecker

func NewChannelChecker(
	meta *meta.Meta,
	dist *meta.DistributionManager,
	targetMgr meta.TargetManagerInterface,
	nodeMgr *session.NodeManager,
	getBalancerFunc GetBalancerFunc,
) *ChannelChecker

func (ChannelChecker) Activate

func (c ChannelChecker) Activate()

func (*ChannelChecker) Check

func (c *ChannelChecker) Check(ctx context.Context) []task.Task

func (ChannelChecker) Deactivate

func (c ChannelChecker) Deactivate()

func (*ChannelChecker) Description

func (c *ChannelChecker) Description() string

func (*ChannelChecker) ID

func (c *ChannelChecker) ID() utils.CheckerType

func (ChannelChecker) IsActive

func (c ChannelChecker) IsActive() bool

type Checker

type Checker interface {
	ID() utils.CheckerType
	Description() string
	Check(ctx context.Context) []task.Task
	IsActive() bool
	Activate()
	Deactivate()
}

type CheckerController

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

func NewCheckerController

func NewCheckerController(
	meta *meta.Meta,
	dist *meta.DistributionManager,
	targetMgr meta.TargetManagerInterface,
	nodeMgr *session.NodeManager,
	scheduler task.Scheduler,
	broker meta.Broker,
	getBalancerFunc GetBalancerFunc,
) *CheckerController

func (*CheckerController) Activate

func (controller *CheckerController) Activate(typ utils.CheckerType) error

func (*CheckerController) Check

func (controller *CheckerController) Check()

func (*CheckerController) Checkers

func (controller *CheckerController) Checkers() []Checker

func (*CheckerController) Deactivate

func (controller *CheckerController) Deactivate(typ utils.CheckerType) error

func (*CheckerController) IsActive

func (controller *CheckerController) IsActive(typ utils.CheckerType) (bool, error)

func (*CheckerController) Start

func (controller *CheckerController) Start()

func (*CheckerController) Stop

func (controller *CheckerController) Stop()

type GetBalancerFunc

type GetBalancerFunc = func() balance.Balance

type IndexChecker

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

IndexChecker perform segment index check.

func NewIndexChecker

func NewIndexChecker(
	meta *meta.Meta,
	dist *meta.DistributionManager,
	broker meta.Broker,
	nodeMgr *session.NodeManager,
	targetMgr meta.TargetManagerInterface,
) *IndexChecker

func (IndexChecker) Activate

func (c IndexChecker) Activate()

func (*IndexChecker) Check

func (c *IndexChecker) Check(ctx context.Context) []task.Task

func (IndexChecker) Deactivate

func (c IndexChecker) Deactivate()

func (*IndexChecker) Description

func (c *IndexChecker) Description() string

func (*IndexChecker) ID

func (c *IndexChecker) ID() utils.CheckerType

func (IndexChecker) IsActive

func (c IndexChecker) IsActive() bool

type LeaderChecker

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

LeaderChecker perform segment index check.

func NewLeaderChecker

func NewLeaderChecker(
	meta *meta.Meta,
	dist *meta.DistributionManager,
	target meta.TargetManagerInterface,
	nodeMgr *session.NodeManager,
) *LeaderChecker

func (LeaderChecker) Activate

func (c LeaderChecker) Activate()

func (*LeaderChecker) Check

func (c *LeaderChecker) Check(ctx context.Context) []task.Task

func (LeaderChecker) Deactivate

func (c LeaderChecker) Deactivate()

func (*LeaderChecker) Description

func (c *LeaderChecker) Description() string

func (*LeaderChecker) ID

func (c *LeaderChecker) ID() utils.CheckerType

func (LeaderChecker) IsActive

func (c LeaderChecker) IsActive() bool

type SegmentChecker

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

func NewSegmentChecker

func NewSegmentChecker(
	meta *meta.Meta,
	dist *meta.DistributionManager,
	targetMgr meta.TargetManagerInterface,
	nodeMgr *session.NodeManager,
	getBalancerFunc GetBalancerFunc,
) *SegmentChecker

func (SegmentChecker) Activate

func (c SegmentChecker) Activate()

func (*SegmentChecker) Check

func (c *SegmentChecker) Check(ctx context.Context) []task.Task

func (SegmentChecker) Deactivate

func (c SegmentChecker) Deactivate()

func (*SegmentChecker) Description

func (c *SegmentChecker) Description() string

func (*SegmentChecker) ID

func (c *SegmentChecker) ID() utils.CheckerType

func (SegmentChecker) IsActive

func (c SegmentChecker) IsActive() bool