Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetRegisteredModelInputFetcherInitFuncs ¶
func GetRegisteredModelInputFetcherInitFuncs() map[string]ModelInputFetcherInitFunc
func RegisterModelInputFetcherInitFunc ¶
func RegisterModelInputFetcherInitFunc(pluginName string, f ModelInputFetcherInitFunc)
Types ¶
type DummyModelInputFetcher ¶
type DummyModelInputFetcher struct{}
func (DummyModelInputFetcher) FetchModelInput ¶
func (d DummyModelInputFetcher) FetchModelInput(ctx context.Context, metaReader metacache.MetaReader, metaWriter metacache.MetaWriter, metaServer *metaserver.MetaServer, ) error
type ModelInputFetcher ¶
type ModelInputFetcher interface {
FetchModelInput(ctx context.Context, metaReader metacache.MetaReader,
metaWriter metacache.MetaWriter, metaServer *metaserver.MetaServer) error
}
func NewDummyModelInputFetcher ¶
func NewDummyModelInputFetcher(fetcherName string, conf *config.Configuration, extraConf interface{}, emitterPool metricspool.MetricsEmitterPool, metaServer *metaserver.MetaServer, metaCache metacache.MetaCache, ) (ModelInputFetcher, error)
type ModelInputFetcherInitFunc ¶
type ModelInputFetcherInitFunc func(fetcherName string, conf *config.Configuration, extraConf interface{}, emitterPool metricspool.MetricsEmitterPool, metaServer *metaserver.MetaServer, metaCache metacache.MetaCache) (ModelInputFetcher, error)
Click to show internal directories.
Click to hide internal directories.