...
▽

Package pluginfactories

import "framework/runtime/pluginfactories"
Overview
Index

Overview ▾

Index ▾

Package files

default_binding_plugins_factory.go default_sampling_plugins_factory.go default_scheduling_plugins_factory.go util.go

type DefaultBindingPluginsFactory 

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

func NewDefaultBindingPluginsFactory 

func NewDefaultBindingPluginsFactory(registry *pipeline.PluginsRegistry[pipeline.ClusterAgentServices]) *DefaultBindingPluginsFactory

func (*DefaultBindingPluginsFactory) NewBindingPipelinePlugins 

func (f *DefaultBindingPluginsFactory) NewBindingPipelinePlugins(clusterAgentServices pipeline.ClusterAgentServices) (*pipeline.BindingPipelinePlugins, error)

type DefaultSamplingPluginsFactory

Default implementation of the SamplingPluginsFactory. 

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

func NewDefaultSamplingPluginsFactory 

func NewDefaultSamplingPluginsFactory(registry *pipeline.PluginsRegistry[pipeline.ClusterAgentServices]) *DefaultSamplingPluginsFactory

func (*DefaultSamplingPluginsFactory) NewSamplingPipelinePlugins 

func (f *DefaultSamplingPluginsFactory) NewSamplingPipelinePlugins(clusterAgentServices pipeline.ClusterAgentServices) (*pipeline.SamplingPipelinePlugins, error)

func (*DefaultSamplingPluginsFactory) NewSamplingStrategiesPlugins 

func (f *DefaultSamplingPluginsFactory) NewSamplingStrategiesPlugins(clusterAgentServices pipeline.ClusterAgentServices) ([]pipeline.SamplingStrategyPlugin, error)

type DefaultSchedulingPluginsFactory

Default implementation of the SchedulingPluginsFactory. 

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

func NewDefaultSchedulingPluginsFactory 

func NewDefaultSchedulingPluginsFactory(registry *pipeline.PluginsRegistry[pipeline.PolarisScheduler]) *DefaultSchedulingPluginsFactory

func (*DefaultSchedulingPluginsFactory) NewDecisionPipelinePlugins 

func (f *DefaultSchedulingPluginsFactory) NewDecisionPipelinePlugins(scheduler pipeline.PolarisScheduler) (*pipeline.DecisionPipelinePlugins, error)

func (*DefaultSchedulingPluginsFactory) NewSampleNodesPlugin 

func (f *DefaultSchedulingPluginsFactory) NewSampleNodesPlugin(scheduler pipeline.PolarisScheduler) (pipeline.SampleNodesPlugin, error)

func (*DefaultSchedulingPluginsFactory) NewSortPlugin 

func (f *DefaultSchedulingPluginsFactory) NewSortPlugin(scheduler pipeline.PolarisScheduler) (pipeline.SortPlugin, error)