jobs

package

v0.0.0-...-4be293a Latest Latest Go to latest Published: Jan 17, 2025 License: MIT Imports: 4 Imported by: 0

Details

View Source

const (
	DefaultPoolSize  = 5
	DefaultNamespace = "__foundation_jobs__"
)

View Source

const (
	ComponentName = "jobs-enqueuer"
)

This section is empty.

This section is empty.

type Component struct {
	Enqueuer *work.Enqueuer
	// contains filtered or unexported fields
}

func NewComponent(opts ...ComponentOption) *Component

func (c *Component) Health() error

Health implements the Component interface.

func (c *Component) Name() string

Name implements the Component interface.

func (c *Component) Start() error

Start implements the Component interface.

func (c *Component) Stop() error

Stop implements the Component interface.

type ComponentOption func(*Component)

ComponentOption is an option to `Component`.

func WithLogger(logger *logrus.Entry) ComponentOption

WithLogger sets the logger for the JobsEnqueuer component

func WithNamespace(namespace string) ComponentOption

WithNamespace sets the namespace for JobsEnqueuer component.

func WithRedisPool(redisPool *redis.Pool) ComponentOption

WithRedisPool sets the redis pool for JobsEnqueuer component.