pump

Documentation

Index

• type Config
• type MailPump
  • func NewMailPump(cfg *Config) (*MailPump, error)
  • func (pump *MailPump) Close()

Types

type Config

type Config struct {
	Source imap.ConnectionConfig
	Dest   imap.ConnectionConfig

	SourceFactory imap.Factory
	DestFactory   imap.Factory

	IDLEFallbackInterval time.Duration
	BatchSize            uint
	DisableDeletions     bool
	FetchBufferSize      uint
	FetchMaxInterval     time.Duration

	DoneChan chan<- error
	StopChan <-chan struct{}
	Logger   *slog.Logger
}

type MailPump

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

func NewMailPump

func NewMailPump(cfg *Config) (*MailPump, error)

func (*MailPump) Close

func (pump *MailPump) Close()