pipe

Documentation

Index

• type Worker
  • func NewWorker(name string, sources []*v1.Source, handler handlers.Handler, ...) *Worker
  • func (w *Worker) HealthStatus() v1.HealthStatus
  • func (w *Worker) Start(ctx context.Context) error
• type WorkerOption
  • func WithDynamicRate(start, min int, windowSize time.Duration) WorkerOption
  • func WithErrorSource(source *v1.Source) WorkerOption
  • func WithFixedRate(rate int) WorkerOption
  • func WithOutput(source *v1.Source) WorkerOption

Types

type Worker

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

func NewWorker

func NewWorker(name string, sources []*v1.Source, handler handlers.Handler, opts ...WorkerOption) *Worker

func (*Worker) HealthStatus

func (w *Worker) HealthStatus() v1.HealthStatus

func (*Worker) Start

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

type WorkerOption

type WorkerOption func(w *Worker)

func WithDynamicRate

func WithDynamicRate(start, min int, windowSize time.Duration) WorkerOption

func WithErrorSource

func WithErrorSource(source *v1.Source) WorkerOption

func WithFixedRate

func WithFixedRate(rate int) WorkerOption

func WithOutput

func WithOutput(source *v1.Source) WorkerOption