config

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)
  • func (c *Consumer) BlockCipher() *crypto.AESGCM
  • func (c *Consumer) ConsumerOpts() *curlyq.ConsumerOpts
  • func (c *Consumer) DB() *sqlx.DB
  • func (c *Consumer) Log() *log.Logger
  • func (c *Consumer) Pidfile() *os.File
  • func (c *Consumer) Redis() *redis.Client
  • func (c *Consumer) Store(name string) (fs.Store, bool)
• type Crypto
• type Curator
  • func DecodeCurator(name string, r io.Reader) (*Curator, error)
  • func (c *Curator) Artifacts() fs.Store
  • func (c *Curator) DB() *sqlx.DB
  • func (c *Curator) Log() *log.Logger
  • func (c *Curator) Pidfile() *os.File
• type Scheduler
  • func DecodeScheduler(name string, r io.Reader) (*Scheduler, error)
  • func (s *Scheduler) BatchSize() int64
  • func (s *Scheduler) DB() *sqlx.DB
  • func (s *Scheduler) Hasher() *crypto.Hasher
  • func (s *Scheduler) Interval() time.Duration
  • func (s *Scheduler) Log() *log.Logger
  • func (s *Scheduler) Pidfile() *os.File
  • func (s *Scheduler) Producers() map[string]*curlyq.Producer
  • func (s *Scheduler) Redis() *redis.Client
• type Server
  • func DecodeServer(name string, r io.Reader) (*Server, error)
  • func (s *Server) Artifacts() Store
  • func (s *Server) BlockCipher() *crypto.AESGCM
  • func (s *Server) DB() *sqlx.DB
  • func (s *Server) Hasher() *crypto.Hasher
  • func (s *Server) Images() Store
  • func (s *Server) Log() *log.Logger
  • func (s *Server) Objects() Store
  • func (s *Server) Pidfile() *os.File
  • func (s *Server) Producers() map[string]*curlyq.Producer
  • func (s *Server) Providers() *provider.Registry
  • func (s *Server) Redis() *redis.Client
  • func (s *Server) SMTP() (*mail.Client, string)
  • func (s *Server) Server() *server.Server
  • func (s *Server) SessionStore() sessions.Store
• type Store
• type Worker
  • func DecodeWorker(name string, r io.Reader) (*Worker, error)
  • func (w *Worker) Artifacts() fs.Store
  • func (w *Worker) BlockCipher() *crypto.AESGCM
  • func (w *Worker) Consumer() *curlyq.Consumer
  • func (w *Worker) DB() *sqlx.DB
  • func (w *Worker) Driver() string
  • func (w *Worker) Log() *log.Logger
  • func (w *Worker) Objects() fs.Store
  • func (w *Worker) Parallelism() int
  • func (w *Worker) Pidfile() *os.File
  • func (w *Worker) Providers() *provider.Registry
  • func (w *Worker) Queue() string
  • func (w *Worker) Redis() *redis.Client
  • func (w *Worker) SMTP() (*mail.Client, string)
  • func (w *Worker) Timeout() time.Duration

Functions

func DecodeDriver

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

Types

type Consumer

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

func DecodeConsumer

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

func (*Consumer) BlockCipher

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

func (*Consumer) ConsumerOpts

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

func (*Consumer) DB

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

func (*Consumer) Log

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

func (*Consumer) Pidfile

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

func (*Consumer) Redis

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

func (*Consumer) Store

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

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