worker

Documentation

Index

• type ListenOptions
  • func (o *ListenOptions) Validate() (*ListenOptions, error)
• type Worker
  • func New(ctx context.Context, opts *WorkerOptions) (w *Worker, c context.Context, err error)
  • func (w *Worker) Cancel()
  • func (w *Worker) Exec(ctx context.Context) error
  • func (w *Worker) ExportStats() stat.Worker
  • func (w *Worker) ID() uuid.UUID
• type WorkerOptions
  • func (o *WorkerOptions) Validate() (*WorkerOptions, error)

Types

type ListenOptions

type ListenOptions struct {
	Device, PcapFile string

	SnapLen     int32
	Promiscuous bool
	BPFFilter   string

	Timeout       time.Duration
	CaptureLayers []gopacket.LayerType
}

func (*ListenOptions) Validate

func (o *ListenOptions) Validate() (*ListenOptions, error)

type Worker

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

func New

func New(ctx context.Context, opts *WorkerOptions) (w *Worker, c context.Context, err error)

func (*Worker) Cancel

func (w *Worker) Cancel()

func (*Worker) Exec

func (w *Worker) Exec(ctx context.Context) error

func (*Worker) ExportStats

func (w *Worker) ExportStats() stat.Worker

func (*Worker) ID

func (w *Worker) ID() uuid.UUID

type WorkerOptions

type WorkerOptions struct {
	ListenOptions

	AssembleTypes []assemble.AssembleType
}

func (*WorkerOptions) Validate

func (o *WorkerOptions) Validate() (*WorkerOptions, error)