processor

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 22, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewProcessor 

func NewProcessor(cfg *api.ProcessorConfig, s sender.Sender, g gatherer.Gatherer) api.Processor

Init Processor and dependency plugins

Types

type Processor 

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

Processor is the processing module in Satellite.

func (*Processor) Boot 

func (p *Processor) Boot(ctx context.Context)

Boot fetches the data of Queue, does a series of processing, and then sends to Sender.

func (*Processor) Prepare 

func (p *Processor) Prepare() error

func (*Processor) Shutdown 

func (p *Processor) Shutdown()

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.