apollo

type Apollo struct {
	Worker []WorkerContract
	Wg     *sync.WaitGroup
	// contains filtered or unexported fields
}

type ConfigData map[string]map[string]string

type DefaultWorker struct {
	Meta *MetaConfig
	Data *sync.Map
	// contains filtered or unexported fields
}

type MetaConfig struct {
	Address    string
	Cluster    string
	ClientIp   string
	AppId      string
	Secret     string
	Namespaces []string
	FileName   string
	Syntax     string
}

type WorkerContract interface {
	SetMeta(meta *MetaConfig)
	GetMeta() *MetaConfig
	GetConfig(wg *sync.WaitGroup, ctx context.Context)
	GetChan() chan struct{}
	CloseChan()
	GetData() *sync.Map
	DeleteDataKey(key string)
	IsAllInOne() bool
}