jobs

README

Spiral: Async Jobs and Queue

Documentation

Index

• Constants
• type Config
  • func (c *Config) Hydrate(cfg service.Config) error
  • func (c *Config) Valid() error
• type Service
  • func (s *Service) Init(cfg *Config, r *rpc.Service) (ok bool, err error)
  • func (s *Service) Serve() error
  • func (s *Service) Stop()

Constants

const ID = "jobs"

Types

type Config

type Config struct {
	Enabled   bool
	Pipelines map[string]string
	Handlers  struct {
		Local *roadrunner.ServerConfig
	}
}

func (*Config) Hydrate

func (c *Config) Hydrate(cfg service.Config) error

func (*Config) Valid

func (c *Config) Valid() error

Valid validates the configuration.

type Service

type Service struct {
	Logger *logrus.Logger
	// contains filtered or unexported fields
}

func (*Service) Init

func (s *Service) Init(cfg *Config, r *rpc.Service) (ok bool, err error)

func (*Service) Serve

func (s *Service) Serve() error

func (*Service) Stop

func (s *Service) Stop()