disk

Documentation

Index

• Constants
• Variables
• type Storage
  • func NewDiskStorage(path string) (*Storage, error)
  • func (d *Storage) Close() error
  • func (d *Storage) Mailbox(name string) vega.Mailbox
  • func (d *Storage) MailboxNames() []string

Constants

const LRUCacheSize = 100 * 1048576

Variables

var ECorruptMailbox = errors.New("corrupt mailbox metadata")

Types

type Storage

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

func NewDiskStorage

func NewDiskStorage(path string) (*Storage, error)

func (*Storage) Close

func (d *Storage) Close() error

func (*Storage) Mailbox

func (d *Storage) Mailbox(name string) vega.Mailbox

func (*Storage) MailboxNames

func (d *Storage) MailboxNames() []string