rcm

Documentation

Index

• func GetTaskStateAndLags(cfg *config.Config) (stateLags map[string]StateLag, 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 StateLag
  • func GetTaskStateAndLag(cfg *config.Config, taskName string) (stateLag StateLag, err error)
• type TaskLag

Functions

func GetTaskStateAndLags

func GetTaskStateAndLags(cfg *config.Config) (stateLags map[string]StateLag, err error)

GetTaskStateAndLags get state and lag of all tasks.

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 StateLag

type StateLag struct {
	State string
	Lag   int64
}

func GetTaskStateAndLag

func GetTaskStateAndLag(cfg *config.Config, taskName string) (stateLag StateLag, err error)

GetTaskStateAndLag get state and lag of a task.

type TaskLag

type TaskLag struct {
	Task string
	Lag  int64
}