collecttask

type BucketDO struct {
	ID          int64 `gorm:"primarykey"`
	GmtCreate   time.Time
	GmtModified time.Time
	Name        string `gorm:"unique;"`
	State       string `gorm:"not null;"`
}

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

type ChangeListener interface {
	// OnUpdate apply config delta to listener
	OnUpdate(*Delta)
}

type CollectConfig struct {
	Key  string `json:"key"`
	Type string `json:"type"`
	// 需要有一个版本号之类的东西, key相同的通过version判断新旧, 不用判断新旧, 只要版本不一样就直接替换
	Version string `json:"version"`
	// 站在reg的角度, 它就是给agent发 "一坨配置", 就是一堆二进制格式的数据
	// 怎么去解释这些数据是业务上的事情, 产品层与agent需要约定好内容格式
	Content []byte `json:"-"`
	// ContentObj is for internal usage
	ContentObj interface{} `json:"contentObj"`
}

type CollectTarget struct {
	Key string `json:"key"`
	// localhost 其实现在只有 localhost/pod
	Type    string `json:"type"`
	Version string `json:"version"`
	// Meta的内容根据type解释
	Meta map[string]string `json:"meta"`
}

type CollectTask struct {
	// collect task key
	Key string `json:"key"`
	// collect task version
	Version string `json:"version"`
	// collect config
	Config *CollectConfig `json:"config"`
	// collect target
	Target *CollectTarget `json:"target"`
}

type CollectTaskDO struct {
	ID           int64 `gorm:"primarykey"`
	GmtCreate    time.Time
	GmtModified  time.Time
	Bucket       string `gorm:"index;"`
	Key          string `gorm:"unique;"`
	Version      string `gorm:""`
	CollectBytes []byte `gorm:""`
	TargetBytes  []byte `gorm:""`
}

type CommonResources struct {
	Configs map[string]*CollectConfig
	Targets map[string]*CollectTarget
}

type Delta struct {
	// 一次增量更新的uuid
	Uuid string
	Add  []*CollectTask
	Del  []*CollectTask
}

type IManager interface {
	GetAll() []*CollectTask
	Listen(listener ChangeListener)
	RemoveListen(listener ChangeListener)
}

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

type One struct {
	One *CollectTask
}

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