arbiter

package

v4.3.0+incompatible Latest Latest Go to latest Published: Nov 3, 2017 License: Apache-2.0 Imports: 24 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/blackducksoftware/ose-scanner

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Arbiter
- func NewArbiter(os *osclient.Client, kc *kclient.Client, hub HubParams) *Arbiter
type Dispatcher
- func NewDispatcher(jobQueue chan Job) *Dispatcher
- func (d *Dispatcher) Run()
type HubParams
type Job
type ScanImage
type Watcher
- func NewWatcher(os *osclient.Client, c *Arbiter) *Watcher
type Worker
- func NewWorker(index int, workerPool chan chan Job) Worker
- func (w Worker) Start()

Constants ¶

View Source

const MaxWorkers = 5

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Arbiter ¶

type Arbiter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewArbiter ¶

func NewArbiter(os *osclient.Client, kc *kclient.Client, hub HubParams) *Arbiter

func (*Arbiter) Add ¶

func (arb *Arbiter) Add()

func (*Arbiter) CanSendHubJobs ¶

func (arb *Arbiter) CanSendHubJobs() bool

func (*Arbiter) Done ¶

func (arb *Arbiter) Done(result bool, Reference string)

func (*Arbiter) ListenForControllers ¶

func (arb *Arbiter) ListenForControllers()

func (*Arbiter) Load ¶

func (arb *Arbiter) Load(done <-chan struct{})

func (*Arbiter) Start ¶

func (arb *Arbiter) Start()

func (*Arbiter) Stop ¶

func (arb *Arbiter) Stop()

func (*Arbiter) ValidateConfig ¶

func (arb *Arbiter) ValidateConfig() bool

ValidateConfig validates if the Hub server configuration is valid. A login attempt will be performed.

func (*Arbiter) Watch ¶

func (arb *Arbiter) Watch()

type Dispatcher ¶

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

func NewDispatcher ¶

func NewDispatcher(jobQueue chan Job) *Dispatcher

func (*Dispatcher) Run ¶

func (d *Dispatcher) Run()

type HubParams ¶

type HubParams struct {
	Config  *bdscommon.HubConfig
	Version string
}

var Hub HubParams

type Job ¶

type Job struct {
	ScanImage *ScanImage
	// contains filtered or unexported fields
}

func (Job) Done ¶

func (job Job) Done(result bool)

func (Job) GetAnnotationInfo ¶

func (job Job) GetAnnotationInfo() (result bool, info bdscommon.ImageInfo)

func (Job) Load ¶

func (job Job) Load()

func (Job) MergeAnnotationResults ¶

func (job Job) MergeAnnotationResults(oldInfo bdscommon.ImageInfo, newInfo bdscommon.ImageInfo) bdscommon.ImageInfo

func (Job) UpdateAnnotationInfo ¶

func (job Job) UpdateAnnotationInfo(newInfo bdscommon.ImageInfo) bool

type ScanImage ¶

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

type Watcher ¶

type Watcher struct {
	Namespace string
	// contains filtered or unexported fields
}

func NewWatcher ¶

func NewWatcher(os *osclient.Client, c *Arbiter) *Watcher

Create a new watcher

func (*Watcher) ImageAdded ¶

func (w *Watcher) ImageAdded(is *imageapi.ImageStream)

func (*Watcher) ImageDeleted ¶

func (w *Watcher) ImageDeleted(is *imageapi.ImageStream)

func (*Watcher) ImageUpdated ¶

func (w *Watcher) ImageUpdated(is *imageapi.ImageStream)

func (*Watcher) Run ¶

func (w *Watcher) Run()

type Worker ¶

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

func NewWorker ¶

func NewWorker(index int, workerPool chan chan Job) Worker

func (Worker) Start ¶

func (w Worker) Start()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL