indicator_plugin

type DummyIndicatorPlugin struct {
	SystemSpecNames       []apiworkload.ServiceSystemIndicatorName
	BusinessSpecNames     []apiworkload.ServiceBusinessIndicatorName
	BusinessStatusNames   []apiworkload.ServiceBusinessIndicatorName
	ExtendedSpecNames     []string
	AggMetricsStatusNames []string
}

type IndicatorGetter interface {
	// GetIndicatorSpecChan + GetIndicatorStatusChan
	// returns a channel to obtain the whether an update action has been triggered.
	GetIndicatorSpecChan() chan types.NamespacedName
	GetIndicatorStatusChan() chan types.NamespacedName

	// GetIndicatorSpec + GetIndicatorStatus
	// for indicator get functions, IndicatorUpdater will return a channel to obtain the merged results.
	GetIndicatorSpec(_ types.NamespacedName) *apiworkload.ServiceProfileDescriptorSpec
	GetIndicatorStatus(_ types.NamespacedName) *apiworkload.ServiceProfileDescriptorStatus
}

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

type IndicatorPlugin interface {
	// Run starts the main loop for indicator plugin
	Run()
	Name() string

	// GetSupportedBusinessIndicatorSpec + GetSupportedSystemIndicatorSpec + GetSupportedBusinessIndicatorStatus
	// Those methods below returns the supported indicator names, if any name
	// is not supported by any indicator plugin, the controller will clear in CR.
	GetSupportedBusinessIndicatorSpec() []apiworkload.ServiceBusinessIndicatorName
	GetSupportedSystemIndicatorSpec() []apiworkload.ServiceSystemIndicatorName
	GetSupportedExtendedIndicatorSpec() []string
	GetSupportedBusinessIndicatorStatus() []apiworkload.ServiceBusinessIndicatorName
	GetSupportedAggMetricsStatus() []string
}

type IndicatorUpdater interface {
	// UpdateExtendedIndicatorSpec + UpdateBusinessIndicatorSpec + UpdateSystemIndicatorSpec + UpdateBusinessIndicatorStatus
	// for indicator add functions, IndicatorUpdater will try to merge them in local stores.
	UpdateExtendedIndicatorSpec(_ types.NamespacedName, _ []apiworkload.ServiceExtendedIndicatorSpec)
	UpdateBusinessIndicatorSpec(_ types.NamespacedName, _ []apiworkload.ServiceBusinessIndicatorSpec)
	UpdateSystemIndicatorSpec(_ types.NamespacedName, _ []apiworkload.ServiceSystemIndicatorSpec)
	UpdateBusinessIndicatorStatus(_ types.NamespacedName, _ []apiworkload.ServiceBusinessIndicatorStatus)
	UpdateAggMetrics(_ types.NamespacedName, _ []apiworkload.AggPodMetrics)
}

type InitFunc func(ctx context.Context, conf *controller.SPDConfig, extraConf interface{},
	spdWorkloadInformer map[schema.GroupVersionResource]native.DynamicInformer,
	controlCtx *katalystbase.GenericContext, updater IndicatorUpdater) (IndicatorPlugin, error)