config

package

v1.1.1 Latest Latest Go to latest Published: Oct 30, 2021 License: Apache-2.0 Imports: 31 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/djinn-ci/djinn

Links

Open Source Insights

Documentation ¶

Index ¶

func DecodeDriver(dname, fname string, r io.Reader) (driver.Init, driver.Config, error)
type Consumer
- func DecodeConsumer(name string, r io.Reader) (*Consumer, error)
type Crypto
type Curator
- func DecodeCurator(name string, r io.Reader) (*Curator, error)
type Scheduler
- func DecodeScheduler(name string, r io.Reader) (*Scheduler, error)
type Server
- func DecodeServer(name string, r io.Reader) (*Server, error)
type Store
type Worker
- func DecodeWorker(name string, r io.Reader) (*Worker, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DecodeDriver ¶

func DecodeDriver(dname, fname string, r io.Reader) (driver.Init, driver.Config, error)

Types ¶

type Consumer ¶ added in v1.1.0

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

func DecodeConsumer ¶ added in v1.1.0

func DecodeConsumer(name string, r io.Reader) (*Consumer, error)

func (*Consumer) BlockCipher ¶ added in v1.1.0

func (c *Consumer) BlockCipher() *crypto.AESGCM

func (*Consumer) ConsumerOpts ¶ added in v1.1.0

func (c *Consumer) ConsumerOpts() *curlyq.ConsumerOpts

func (*Consumer) DB ¶ added in v1.1.0

func (c *Consumer) DB() *sqlx.DB

func (*Consumer) Log ¶ added in v1.1.0

func (c *Consumer) Log() *log.Logger

func (*Consumer) Pidfile ¶ added in v1.1.0

func (c *Consumer) Pidfile() *os.File

func (*Consumer) Redis ¶ added in v1.1.0

func (c *Consumer) Redis() *redis.Client

func (*Consumer) Store ¶ added in v1.1.0

func (c *Consumer) Store(name string) (fs.Store, bool)

type Crypto ¶

type Crypto struct {
	Hash  []byte
	Block []byte
	Salt  []byte
	Auth  []byte
}

type Curator ¶

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

func DecodeCurator ¶

func DecodeCurator(name string, r io.Reader) (*Curator, error)

func (*Curator) Artifacts ¶

func (c *Curator) Artifacts() fs.Store

func (*Curator) DB ¶

func (c *Curator) DB() *sqlx.DB

func (*Curator) Log ¶

func (c *Curator) Log() *log.Logger

func (*Curator) Pidfile ¶

func (c *Curator) Pidfile() *os.File

type Scheduler ¶

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

func DecodeScheduler ¶

func DecodeScheduler(name string, r io.Reader) (*Scheduler, error)

func (*Scheduler) BatchSize ¶

func (s *Scheduler) BatchSize() int64

func (*Scheduler) DB ¶

func (s *Scheduler) DB() *sqlx.DB

func (*Scheduler) Hasher ¶

func (s *Scheduler) Hasher() *crypto.Hasher

func (*Scheduler) Interval ¶

func (s *Scheduler) Interval() time.Duration

func (*Scheduler) Log ¶

func (s *Scheduler) Log() *log.Logger

func (*Scheduler) Pidfile ¶

func (s *Scheduler) Pidfile() *os.File

func (*Scheduler) Producers ¶

func (s *Scheduler) Producers() map[string]*curlyq.Producer

func (*Scheduler) Redis ¶

func (s *Scheduler) Redis() *redis.Client

type Server ¶

type Server struct {
	Crypto Crypto
	// contains filtered or unexported fields
}

func DecodeServer ¶

func DecodeServer(name string, r io.Reader) (*Server, error)

func (*Server) Artifacts ¶

func (s *Server) Artifacts() Store

func (*Server) BlockCipher ¶

func (s *Server) BlockCipher() *crypto.AESGCM

func (*Server) DB ¶

func (s *Server) DB() *sqlx.DB

func (*Server) Hasher ¶

func (s *Server) Hasher() *crypto.Hasher

func (*Server) Images ¶

func (s *Server) Images() Store

func (*Server) Log ¶

func (s *Server) Log() *log.Logger

func (*Server) Objects ¶

func (s *Server) Objects() Store

func (*Server) Pidfile ¶

func (s *Server) Pidfile() *os.File

func (*Server) Producers ¶

func (s *Server) Producers() map[string]*curlyq.Producer

func (*Server) Providers ¶

func (s *Server) Providers() *provider.Registry

func (*Server) Redis ¶

func (s *Server) Redis() *redis.Client

func (*Server) SMTP ¶

func (s *Server) SMTP() (*mail.Client, string)

func (*Server) Server ¶

func (s *Server) Server() *server.Server

func (*Server) SessionStore ¶

func (s *Server) SessionStore() sessions.Store

type Store ¶

type Store struct {
	Limit int64
	Store fs.Store
}

type Worker ¶

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

func DecodeWorker ¶

func DecodeWorker(name string, r io.Reader) (*Worker, error)

func (*Worker) Artifacts ¶

func (w *Worker) Artifacts() fs.Store

func (*Worker) BlockCipher ¶

func (w *Worker) BlockCipher() *crypto.AESGCM

func (*Worker) Consumer ¶ added in v1.1.0

func (w *Worker) Consumer() *curlyq.Consumer

func (*Worker) DB ¶

func (w *Worker) DB() *sqlx.DB

func (*Worker) Driver ¶

func (w *Worker) Driver() string

func (*Worker) Log ¶

func (w *Worker) Log() *log.Logger

func (*Worker) Objects ¶

func (w *Worker) Objects() fs.Store

func (*Worker) Parallelism ¶

func (w *Worker) Parallelism() int

func (*Worker) Pidfile ¶

func (w *Worker) Pidfile() *os.File

func (*Worker) Providers ¶

func (w *Worker) Providers() *provider.Registry

func (*Worker) Queue ¶

func (w *Worker) Queue() string

func (*Worker) Redis ¶

func (w *Worker) Redis() *redis.Client

func (*Worker) SMTP ¶

func (w *Worker) SMTP() (*mail.Client, string)

func (*Worker) Timeout ¶

func (w *Worker) Timeout() time.Duration

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL