taskinformer

Documentation

Index

• type Informer
  • func NewInformer(info *types.ServerInfo, zkCli *zkclient.ZkClient) *Informer
  • func (i *Informer) RegisterHandler(h TaskHandler)
  • func (i *Informer) Run(ctx context.Context)
• type TaskHandler

Types

type Informer

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

Informer is component which find cluster and informer cluster

func NewInformer

func NewInformer(info *types.ServerInfo, zkCli *zkclient.ZkClient) *Informer

NewInformer create new informer

func (*Informer) RegisterHandler

func (i *Informer) RegisterHandler(h TaskHandler)

RegisterHandler register task handler

func (*Informer) Run

func (i *Informer) Run(ctx context.Context)

Run run the informer

type TaskHandler

type TaskHandler interface {
	OnAdd(add common.Cluster)
	OnUpdate(old, new common.Cluster)
	OnDelete(del common.Cluster)
}

TaskHandler handler for task