Documentation
¶
Index ¶
- type Plugin
- func (p *Plugin) Cleanup(kubeclient kubernetes.Interface)
- func (p *Plugin) ExpectedResults(nodes []v1.Node) []plugin.ExpectedResult
- func (p *Plugin) Monitor(ctx context.Context, kubeclient kubernetes.Interface, _ []v1.Node, ...)
- func (p *Plugin) Run(kubeclient kubernetes.Interface, hostname string, cert *tls.Certificate, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Plugin ¶
Plugin is a plugin driver that dispatches a single pod to the given kubernetes cluster.
func NewPlugin ¶
func NewPlugin(dfn manifest.Manifest, namespace, sonobuoyImage, imagePullPolicy, imagePullSecrets string, customAnnotations map[string]string) *Plugin
NewPlugin creates a new DaemonSet plugin from the given Plugin Definition and sonobuoy aggregator address.
func (*Plugin) Cleanup ¶
func (p *Plugin) Cleanup(kubeclient kubernetes.Interface)
Cleanup cleans up the k8s Job and ConfigMap created by this plugin instance
func (*Plugin) ExpectedResults ¶
func (p *Plugin) ExpectedResults(nodes []v1.Node) []plugin.ExpectedResult
ExpectedResults returns the list of results expected for this plugin. Since a Job only launches one pod, only one result type is expected.
func (*Plugin) Monitor ¶
func (p *Plugin) Monitor(ctx context.Context, kubeclient kubernetes.Interface, _ []v1.Node, resultsCh chan<- *plugin.Result)
Monitor adheres to plugin.Interface by ensuring the pod created by the job doesn't have any unrecoverable failures. It closes the results channel when it is done.
Source Files
Click to show internal directories.
Click to hide internal directories.