Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

backends

package

Go to main page

Versions in this module

v1

v1.6.1

Dec 28, 2019

Changes in this version

+ type DataCompressor struct

+ Data *bytes.Buffer

+ ExtraHeaders []byte

+ Pool *sync.Pool

+ func (c *DataCompressor) String() string

type SQLProcessorConfig

+ MaxConnLifetime string

+ MaxIdleConns int

+ MaxOpenConns int

+ SQLInsert string

+ SQLValues string

v1.6.0

May 4, 2019

Changes in this version

+ const BackendStateError

+ const BackendStateInitialized

+ const BackendStateNew

+ const BackendStateRunning

+ const BackendStateShuttered

+ const GuerrillaDBAndRedisBatchMax

+ const GuerrillaDBAndRedisBatchTimeout

+ var BackendResultOK = NewResult("200 OK")

+ var ErrProcessorNotFound error

+ var NoSuchUser = RcptError(errors.New("no such user"))

+ var QuotaExceeded = RcptError(errors.New("quota exceeded"))

+ var RedisDialer redisDial

+ var StorageError = RcptError(errors.New("storage error"))

+ var StorageNotAvailable = RcptError(errors.New("storage not available"))

+ var StorageTimeout = RcptError(errors.New("storage timeout"))

+ var StorageTooBusy = RcptError(errors.New("storage too busy"))

+ var Svc *service

+ var UserSuspended = RcptError(errors.New("user suspended"))

+ func Compress(stringArguments ...string) string

+ func Log() log.Logger

+ func MD5Hex(stringArguments ...string) string

+ func ParseHeaders(mailData string) map[string]string

+ type Backend interface

+ Initialize func(BackendConfig) error

+ Process func(*mail.Envelope) Result

+ Reinitialize func() error

+ Shutdown func() error

+ Start func() error

+ ValidateRcpt func(e *mail.Envelope) RcptError

+ func New(backendConfig BackendConfig, l log.Logger) (Backend, error)

+ type BackendConfig map[string]interface

+ type BackendGateway struct

+ State backendState

+ func (gw *BackendGateway) Initialize(cfg BackendConfig) error

+ func (gw *BackendGateway) Process(e *mail.Envelope) Result

+ func (gw *BackendGateway) Reinitialize() error

+ func (gw *BackendGateway) Shutdown() error

+ func (gw *BackendGateway) Start() error

+ func (gw *BackendGateway) ValidateRcpt(e *mail.Envelope) RcptError

+ type BaseConfig interface

+ type Decorator func(Processor) Processor

+ func Compressor() Decorator

+ func Debugger() Decorator

+ func GuerrillaDbRedis() Decorator

+ func Hasher() Decorator

+ func Header() Decorator

+ func HeadersParser() Decorator

+ func Redis() Decorator

+ func SQL() Decorator

+ type DefaultProcessor struct

+ func (w DefaultProcessor) Process(e *mail.Envelope, task SelectTask) (Result, error)

+ type Errors []error

+ func (e Errors) Error() string

+ type GatewayConfig struct

+ SaveProcess string

+ TimeoutSave string

+ TimeoutValidateRcpt string

+ ValidateProcess string

+ WorkersSize int

+ type GuerrillaDBAndRedisBackend struct

+ type HeaderConfig struct

+ PrimaryHost string

+ type InitializeWith func(backendConfig BackendConfig) error

+ func (i InitializeWith) Initialize(backendConfig BackendConfig) error

+ type NoopProcessor struct

+ type ProcessWith func(*mail.Envelope, SelectTask) (Result, error)

+ func (f ProcessWith) Process(e *mail.Envelope, task SelectTask) (Result, error)

+ type Processor interface

+ Process func(*mail.Envelope, SelectTask) (Result, error)

+ func Decorate(c Processor, ds ...Decorator) Processor

+ type ProcessorConstructor func() Decorator

+ type RcptError error

+ type RedisConn interface

+ Close func() error

+ Do func(commandName string, args ...interface{}) (reply interface{}, err error)

+ type RedisDialOption struct

+ type RedisMockConn struct

+ func (m *RedisMockConn) Close() error

+ func (m *RedisMockConn) Do(commandName string, args ...interface{}) (reply interface{}, err error)

+ type RedisProcessor struct

+ type RedisProcessorConfig struct

+ RedisExpireSeconds int

+ RedisInterface string

+ type Result interface

+ Code func() int

+ func NewResult(r ...interface{}) Result

+ type SQLProcessor struct

+ type SQLProcessorConfig struct

+ DSN string

+ Driver string

+ PrimaryHost string

+ Table string

+ type SelectTask int

+ const TaskSaveMail

+ const TaskValidateRcpt

+ func (o SelectTask) String() string

+ type ShutdownWith func() error

+ func (s ShutdownWith) Shutdown() error