smtp

Documentation

Index

• func AuthNormal(addr string, auth *common.Auth) error
• func AuthTls(addr string, auth *common.Auth, tls *tls.Config) error
• func SendMailTls(addr string, auth common.Auth, env *BEnvelope, tls *tls.Config) error
• type BEnvelope
  • func (env *BEnvelope) WriteTo(w io.Writer) (n int64, err error)
• type Conf
  • func (sc *Conf) String() string
• type Delegate
• type RemoteConf
  • func (rc *RemoteConf) String() string
• type Service
  • func NewSMTPSrv(conf *Conf, lclSrvTls *tls.Config) (*Service, error)
  • func (ss *Service) AUTH(auth *common.Auth) error
  • func (ss *Service) NewSession(_ *smtp.Conn) (smtp.Session, error)
  • func (ss *Service) SendMail(auth common.Auth, env *BEnvelope) error
  • func (ss *Service) Start(sig chan struct{}) error
  • func (ss *Service) StartWithCtx(cancel context.CancelFunc) error
  • func (ss *Service) Stop()
• type Session
  • func (s *Session) AuthPlain(username, password string) error
  • func (s *Session) Data(r io.Reader) error
  • func (s *Session) Logout() error
  • func (s *Session) Mail(from string, opts *smtp.MailOptions) error
  • func (s *Session) Rcpt(to string) error
  • func (s *Session) Reset()

Functions

func AuthNormal

func AuthNormal(addr string, auth *common.Auth) error

func AuthTls

func AuthTls(addr string, auth *common.Auth, tls *tls.Config) error

func SendMailTls

func SendMailTls(addr string, auth common.Auth, env *BEnvelope, tls *tls.Config) error

Types

type BEnvelope

type BEnvelope struct {
	From    string
	StampID string
	Tos     []string
	Stamp   comm.StampData
	Data    io.Reader
}

func (*BEnvelope) WriteTo

func (env *BEnvelope) WriteTo(w io.Writer) (n int64, err error)

type Conf

type Conf struct {
	SrvAddr         string                 `json:"srv_addr"`
	SrvDomain       string                 `json:"srv_domain"`
	StampWalletAddr string                 `json:"stamp_wallet_addr"`
	RemoteConf      map[string]*RemoteConf `json:"remote_conf"`
	MaxMessageBytes int                    `json:"max_message_bytes"`
	ReadTimeOut     int                    `json:"read_time_out"`
	WriteTimeOut    int                    `json:"write_time_out"`
	MaxRecipients   int                    `json:"max_recipients"`
}

func (*Conf) String

func (sc *Conf) String() string

type Delegate

type Delegate interface {
	SendMail(auth common.Auth, env *BEnvelope) error
	AUTH(auth *common.Auth) error
}

type RemoteConf

type RemoteConf struct {
	RemoteSrvCAs    string `json:"ca_files"`
	RemoteCADomain  string `json:"ca_domain"`
	AllowNotSecure  bool   `json:"allow_not_secure"`
	RemoteSrvName   string `json:"remote_srv_name"`
	RemoteSrvPort   int    `json:"remote_srv_port"`
	ActiveStampAddr string `json:"active_stamp_addr"`
	// contains filtered or unexported fields
}

func (*RemoteConf) String

func (rc *RemoteConf) String() string

type Service

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

func NewSMTPSrv

func NewSMTPSrv(conf *Conf, lclSrvTls *tls.Config) (*Service, error)

func (*Service) AUTH

func (ss *Service) AUTH(auth *common.Auth) error

func (*Service) NewSession

func (ss *Service) NewSession(_ *smtp.Conn) (smtp.Session, error)

func (*Service) SendMail

func (ss *Service) SendMail(auth common.Auth, env *BEnvelope) error

func (*Service) Start

func (ss *Service) Start(sig chan struct{}) error

func (*Service) StartWithCtx

func (ss *Service) StartWithCtx(cancel context.CancelFunc) error

func (*Service) Stop

func (ss *Service) Stop()

type Session

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

func (*Session) AuthPlain

func (s *Session) AuthPlain(username, password string) error

func (*Session) Data

func (s *Session) Data(r io.Reader) error

func (*Session) Logout

func (s *Session) Logout() error

func (*Session) Mail

func (s *Session) Mail(from string, opts *smtp.MailOptions) error

func (*Session) Rcpt

func (s *Session) Rcpt(to string) error

func (*Session) Reset

func (s *Session) Reset()