borwein

Documentation

Index

• Constants
• func NewBorweinModelResultFetcher(fetcherName string, conf *config.Configuration, extraConf interface{}, ...) (modelresultfetcher.ModelResultFetcher, error)
• func SetGetContainerFeatureValueFunc(f GetContainerFeatureValueFunc)
• func SetGetNodeFeatureValueFunc(f GetNodeFeatureValueFunc)
• type BorweinModelResultFetcher
  • func (bmrf *BorweinModelResultFetcher) FetchModelResult(ctx context.Context, metaReader metacache.MetaReader, ...) error
• type GetContainerFeatureValueFunc
• type GetNodeFeatureValueFunc

Constants

const (
	BorweinModelResultFetcherName = "borwein_model_result_fetcher"
)

const (
	NodeFeatureNodeName = "node_feature_name"
)

Functions

func NewBorweinModelResultFetcher

func NewBorweinModelResultFetcher(fetcherName string, conf *config.Configuration, extraConf interface{},
	emitterPool metricspool.MetricsEmitterPool, metaServer *metaserver.MetaServer,
	metaCache metacache.MetaCache) (modelresultfetcher.ModelResultFetcher, error)

func SetGetContainerFeatureValueFunc

func SetGetContainerFeatureValueFunc(f GetContainerFeatureValueFunc)

RegisterGetContainerFeatureValueFunc allows to register pluggable function providing container features

func SetGetNodeFeatureValueFunc

func SetGetNodeFeatureValueFunc(f GetNodeFeatureValueFunc)

RegisterGetNodeFeatureValueFunc allows to register pluggable function providing node features

Types

type BorweinModelResultFetcher

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

func (*BorweinModelResultFetcher) FetchModelResult

func (bmrf *BorweinModelResultFetcher) FetchModelResult(ctx context.Context, metaReader metacache.MetaReader,
	metaWriter metacache.MetaWriter, metaServer *metaserver.MetaServer) error

type GetContainerFeatureValueFunc

type GetContainerFeatureValueFunc func(timestamp int64, podUID string, containerName string, featureName string,
	metaServer *metaserver.MetaServer, metaReader metacache.MetaReader) (string, error)

type GetNodeFeatureValueFunc

type GetNodeFeatureValueFunc func(timestamp int64, featureName string, metaServer *metaserver.MetaServer, metaReader metacache.MetaReader) (string, error)