mongodb

Documentation

Index

• Constants
• type Config
• type Storage
  • func OpenConnection(cfg *Config) (*Storage, error)
  • func (s *Storage) BulkInsert(r []model.Record) error
  • func (s *Storage) Cleanup(deleteBefore time.Time) error
  • func (s *Storage) Close() error
  • func (s *Storage) Insert(r *model.Record) error

Constants

const EventsCollection = "events"

Types

type Config

type Config struct {
	mgo.DialInfo

	CollectionSize uint64 // in bytes
	MaxDocuments   uint
}

type Storage

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

func OpenConnection

func OpenConnection(cfg *Config) (*Storage, error)

func (*Storage) BulkInsert

func (s *Storage) BulkInsert(r []model.Record) error

func (*Storage) Cleanup

func (s *Storage) Cleanup(deleteBefore time.Time) error

func (*Storage) Close

func (s *Storage) Close() error

func (*Storage) Insert

func (s *Storage) Insert(r *model.Record) error