indicator_plugin

type DummyIndicatorPlugin struct {
	SystemSpecNames     []apiworkload.TargetIndicatorName
	BusinessSpecNames   []apiworkload.ServiceBusinessIndicatorName
	BusinessStatusNames []apiworkload.ServiceBusinessIndicatorName
}

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.TargetIndicatorName
	GetSupportedBusinessIndicatorStatus() []apiworkload.ServiceBusinessIndicatorName
}

type IndicatorUpdater interface {
	// AddBusinessIndicatorSpec + AddSystemIndicatorSpec + AddBusinessIndicatorStatus
	// for indicator add functions, IndicatorUpdater will try to merge them in local stores.
	AddBusinessIndicatorSpec(_ types.NamespacedName, _ []apiworkload.ServiceBusinessIndicatorSpec)
	AddSystemIndicatorSpec(_ types.NamespacedName, _ []apiworkload.ServiceSystemIndicatorSpec)
	AddBusinessIndicatorStatus(_ types.NamespacedName, _ []apiworkload.ServiceBusinessIndicatorStatus)
}

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