rcm

Documentation

Index

• func GetTaskLags(cfg *config.Config) (taskLags map[string]int64, err error)
• type InstanceAssignment
• type NacosConfManager
  • func (ncm *NacosConfManager) Deregister(ip string, port int) (err error)
  • func (ncm *NacosConfManager) GetConfig() (conf *config.Config, err error)
  • func (ncm *NacosConfManager) Init(properties map[string]interface{}) (err error)
  • func (ncm *NacosConfManager) PublishConfig(conf *config.Config) (err error)
  • func (ncm *NacosConfManager) Register(ip string, port int) (err error)
  • func (ncm *NacosConfManager) Run()
  • func (ncm *NacosConfManager) Stop()
• type RemoteConfManager
• type TaskLag

Functions

func GetTaskLags

func GetTaskLags(cfg *config.Config) (taskLags map[string]int64, err error)

GetTaskLags inspired by https://github.com/cloudhut/kminion/blob/1ffd02ba94a5edc26d4f11e57191ed3479d8a111/prometheus/collect_consumer_group_lags.go

Types

type InstanceAssignment

type InstanceAssignment struct {
	Instance string
	TotalLag int64
	TaskLags []TaskLag
}

type NacosConfManager

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

func (*NacosConfManager) Deregister

func (ncm *NacosConfManager) Deregister(ip string, port int) (err error)

func (*NacosConfManager) GetConfig

func (ncm *NacosConfManager) GetConfig() (conf *config.Config, err error)

func (*NacosConfManager) Init

func (ncm *NacosConfManager) Init(properties map[string]interface{}) (err error)

func (*NacosConfManager) PublishConfig

func (ncm *NacosConfManager) PublishConfig(conf *config.Config) (err error)

func (*NacosConfManager) Register

func (ncm *NacosConfManager) Register(ip string, port int) (err error)

func (*NacosConfManager) Run

func (ncm *NacosConfManager) Run()

func (*NacosConfManager) Stop

func (ncm *NacosConfManager) Stop()

type RemoteConfManager

type RemoteConfManager interface {
	Init(properties map[string]interface{}) error
	GetConfig() (conf *config.Config, err error)
	// PublishConfig publishs the config.
	PublishConfig(conf *config.Config) (err error)
	Register(ip string, port int) (err error)
	Deregister(ip string, port int) (err error)

	// Assignment loop
	Run()
	Stop()
}

RemoteConfManager can be implemented by many backends: Nacos, Consul, etcd, ZooKeeper...

type TaskLag

type TaskLag struct {
	Task string
	Lag  int64
}