processor

Documentation

Index

• func NewProcessor(cfg *api.ProcessorConfig) api.Processor
• type Processor
  • func (p *Processor) Boot(ctx context.Context)
  • func (p *Processor) Prepare() error
  • func (p *Processor) SetGatherer(m api.Module) error
  • func (p *Processor) SetSender(m api.Module) error
  • func (p *Processor) Shutdown()
  • func (p *Processor) SyncInvoke(d *v1.SniffData) (*v1.SniffData, grpc.ClientStream, error)

Functions

func NewProcessor

func NewProcessor(cfg *api.ProcessorConfig) 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) SetGatherer

func (p *Processor) SetGatherer(m api.Module) error

func (*Processor) SetSender

func (p *Processor) SetSender(m api.Module) error

func (*Processor) Shutdown

func (p *Processor) Shutdown()

func (*Processor) SyncInvoke

func (p *Processor) SyncInvoke(d *v1.SniffData) (*v1.SniffData, grpc.ClientStream, error)