processor

Documentation

Index

• Variables
• type Processor
  • func NewProcessor(jb interfaces.Transformer, storage interfaces.StorageSetter, ...) *Processor
  • func (p *Processor) Start(ctx context.Context) error
  • func (p *Processor) Stop(ctx context.Context) error
• type Task

Variables

var ErrorAlreadyStarted = errors.New("Already started")

Types

type Processor

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

func NewProcessor

func NewProcessor(jb interfaces.Transformer, storage interfaces.StorageSetter, controller interfaces.Controller, workers int) *Processor

func (*Processor) Start

func (p *Processor) Start(ctx context.Context) error

func (*Processor) Stop

func (p *Processor) Stop(ctx context.Context) error

type Task

type Task struct {
	JD *types.JetDrop
}