subscriber

type Config struct {
	// WorkersCount specifies a number workers that process packages
	WorkersCount uint
	// WorkerWaitingAssignmentTimeout amount of time that a worker will wait for assigning a package
	WorkerWaitingAssignmentTimeout time.Duration
	// PackageProcessingMaxTime amount of time for a package to be processed
	PackageProcessingMaxTime time.Duration
	// GracefulShutdownTimeout amount of time for graceful shutdown
	GracefulShutdownTimeout time.Duration
}

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

type Opt func(o *subscriberOpts)

type PackageProperty string

type Processor interface {
	Process(ctx context.Context, inPkg transport.IncomingPkg) error
}

type Subscriber interface {
	// Run listens queues for packages and processes them. Gracefully shuts down either on os.Signal or ctx.Done()
	Run(ctx context.Context, queues ...transport.Queue) error
}