Documentation
¶
Overview ¶
Package caasprobebinder exists to bind probe providers to the caasprober.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Manifold ¶
func Manifold(config ManifoldConfig) dependency.Manifold
Manifold returns a new manifold for a caasprobebinder worker.
Types ¶
type ManifoldConfig ¶
type ManifoldConfig struct { // ProberName is the name of the caasprober worker to get from the // dependency engine. ProberName string // ProbeProviderNames is a list of probe providers to fetch from the // dependency engine. ProbeProviderNames []string // DefaultProviders is a list of probe providers that are given to this // worker at instantiation and not fetched from the dependency engine. DefaultProviders map[string]probe.ProbeProvider }
ManifoldConfig is the configuration used to setup a new caasprober.
func (ManifoldConfig) Start ¶
func (c ManifoldConfig) Start(ctx context.Context, getter dependency.Getter) (worker.Worker, error)
func (ManifoldConfig) Validate ¶
func (c ManifoldConfig) Validate() error
type ProbeBinder ¶
type ProbeBinder struct {
// contains filtered or unexported fields
}
ProbeBinder is a worker that binds a set of probe providers onto a caasprober worker.
func NewProbeBinder ¶
func NewProbeBinder(probes *caasprober.CAASProbes, providers map[string]probe.ProbeProvider) (*ProbeBinder, error)
NewProbeBinder constructs a new caas probe binder worker.
Click to show internal directories.
Click to hide internal directories.