store

Documentation

Overview

package store implements types that store message literals.

Messages may be stored either in-memory or on-disk. When stored on disk, they are stored encrypted and optionally compressed.

Index

• type Builder
• type Compressor
• type GZipCompressor
  • func (GZipCompressor) Compress(dec []byte) ([]byte, error)
  • func (GZipCompressor) Decompress(cmp []byte) ([]byte, error)
• type OnDiskStoreBuilder
  • func (*OnDiskStoreBuilder) Delete(path, userID string) error
  • func (*OnDiskStoreBuilder) New(path, userID string, passphrase []byte) (Store, error)
• type Option
  • func WithCompressor(cmp Compressor) Option
  • func WithSemaphore(sem *Semaphore) Option
• type Semaphore
  • func NewSemaphore(max int) *Semaphore
  • func (sem *Semaphore) Block()
  • func (sem *Semaphore) Do(fn func())
  • func (sem *Semaphore) Go(fn func())
  • func (sem *Semaphore) Lock()
  • func (sem *Semaphore) Unblock()
  • func (sem *Semaphore) Unlock()
  • func (sem *Semaphore) Wait()
• type Store
  • func NewOnDiskStore(path string, pass []byte, opt ...Option) (Store, error)
• type ZLibCompressor
  • func (ZLibCompressor) Compress(dec []byte) ([]byte, error)
  • func (ZLibCompressor) Decompress(cmp []byte) ([]byte, error)

Types

type Builder

type Builder interface {
	New(dir, userID string, passphrase []byte) (Store, error)
	Delete(dir, userID string) error
}

type Compressor

type Compressor interface {
	Compress([]byte) ([]byte, error)
	Decompress([]byte) ([]byte, error)
}

type GZipCompressor

type GZipCompressor struct{}

func (GZipCompressor) Compress

func (GZipCompressor) Compress(dec []byte) ([]byte, error)

func (GZipCompressor) Decompress

func (GZipCompressor) Decompress(cmp []byte) ([]byte, error)

type OnDiskStoreBuilder

type OnDiskStoreBuilder struct{}

func (*OnDiskStoreBuilder) Delete

func (*OnDiskStoreBuilder) Delete(path, userID string) error

func (*OnDiskStoreBuilder) New

func (*OnDiskStoreBuilder) New(path, userID string, passphrase []byte) (Store, error)

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithCompressor

func WithCompressor(cmp Compressor) Option

func WithSemaphore

func WithSemaphore(sem *Semaphore) Option

type Semaphore

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

Semaphore implements a type used to limit concurrent operations.

func NewSemaphore

func NewSemaphore(max int) *Semaphore

NewSemaphore constructs a new semaphore with the given limit.

func (*Semaphore) Block

func (sem *Semaphore) Block()

Block prevents the semaphore from being locked.

func (*Semaphore) Do

func (sem *Semaphore) Do(fn func())

Do executes the given function synchronously.

func (*Semaphore) Go

func (sem *Semaphore) Go(fn func())

Go executes the given function asynchronously.

func (*Semaphore) Lock

func (sem *Semaphore) Lock()

Lock locks the semaphore, waiting first until it is possible.

func (*Semaphore) Unblock

func (sem *Semaphore) Unblock()

Unblock allows the semaphore to be locked again.

func (*Semaphore) Unlock

func (sem *Semaphore) Unlock()

Unlock unlocks the semaphore.

func (*Semaphore) Wait

func (sem *Semaphore) Wait()

Wait waits for all functions started by Go to finish executing.

type Store

type Store interface {
	Get(messageID imap.InternalMessageID) ([]byte, error)
	Set(messageID imap.InternalMessageID, literal []byte) error
	Delete(messageID ...imap.InternalMessageID) error
	Close() error
	List() ([]imap.InternalMessageID, error)
}

func NewOnDiskStore

func NewOnDiskStore(path string, pass []byte, opt ...Option) (Store, error)

type ZLibCompressor

type ZLibCompressor struct{}

func (ZLibCompressor) Compress

func (ZLibCompressor) Compress(dec []byte) ([]byte, error)

func (ZLibCompressor) Decompress

func (ZLibCompressor) Decompress(cmp []byte) ([]byte, error)