mongodb

Documentation

Index

• Constants
• type Config
• type Storage
  • func OpenConnection(cfg *Config) (*Storage, error)
  • func (s *Storage) BulkInsert(r []kubeClientModel.Event, collection string) error
  • func (s *Storage) Close() error
  • func (s *Storage) Insert(r *kubeClientModel.Event, collection string) error

Constants

const (
	ResourceQuotasCollection = "namespaces"
	EventsCollection         = "events"
	DeploymentCollection     = "deployments"
	ServiceCollection        = "services"
	IngressCollection        = "ingresses"
	PVCCollection            = "volumes"
	UserCollection           = "user"
	SystemCollection         = "system"
)

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 []kubeClientModel.Event, collection string) error

func (*Storage) Close

func (s *Storage) Close() error

func (*Storage) Insert

func (s *Storage) Insert(r *kubeClientModel.Event, collection string) error