job

Documentation

Index

• type Plugin
  • func NewPlugin(dfn plugin.Definition, namespace, sonobuoyImage string) *Plugin
  • func (p *Plugin) Cleanup(kubeclient kubernetes.Interface)
  • func (p *Plugin) ExpectedResults(nodes []v1.Node) []plugin.ExpectedResult
  • func (p *Plugin) FillTemplate(hostname string, cert *tls.Certificate) ([]byte, error)
  • func (p *Plugin) GetName() string
  • func (p *Plugin) GetResultType() string
  • func (p *Plugin) GetSessionID() string
  • func (p *Plugin) Monitor(kubeclient kubernetes.Interface, _ []v1.Node, resultsCh chan<- *plugin.Result)
  • func (p *Plugin) Run(kubeclient kubernetes.Interface, hostname string, cert *tls.Certificate) error

Types

type Plugin

type Plugin struct {
	Definition    plugin.Definition
	SessionID     string
	Namespace     string
	SonobuoyImage string
	// contains filtered or unexported fields
}

Plugin is a plugin driver that dispatches a single pod to the given kubernetes cluster

func NewPlugin

func NewPlugin(dfn plugin.Definition, namespace, sonobuoyImage string) *Plugin

NewPlugin creates a new DaemonSet plugin from the given Plugin Definition and sonobuoy master 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) FillTemplate

func (p *Plugin) FillTemplate(hostname string, cert *tls.Certificate) ([]byte, error)

FillTemplate populates the internal Job YAML template with the values for this particular job.

func (*Plugin) GetName

func (p *Plugin) GetName() string

GetName returns the name of this Job plugin

func (*Plugin) GetResultType

func (p *Plugin) GetResultType() string

GetResultType returns the ResultType for this plugin (to adhere to plugin.Interface)

func (*Plugin) GetSessionID

func (p *Plugin) GetSessionID() string

GetSessionID returns the session id associated with the plugin

func (*Plugin) Monitor

func (p *Plugin) Monitor(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 urecoverable failures.

func (*Plugin) Run

func (p *Plugin) Run(kubeclient kubernetes.Interface, hostname string, cert *tls.Certificate) error

Run dispatches worker pods according to the Job's configuration.