coordinator

type Config struct {
	InternalServiceAddr      string
	MetricsServiceAddr       string
	MetadataProviderImpl     MetadataProviderImpl
	K8SMetadataNamespace     string
	K8SMetadataConfigMapName string
	FileMetadataPath         string
	ClusterConfigProvider    func() (model.ClusterConfig, error)
	ClusterConfigRefreshTime time.Duration
}

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

type MetadataProviderImpl string