db

Documentation

Index

• type Database
• type Mongodb
  • func (m *Mongodb) AddEntry(ctx context.Context, e interface{}) error
  • func (m *Mongodb) DatabaseCollection(database string, collection string)
  • func (m *Mongodb) DeleteAll(ctx context.Context, message string) error
  • func (m *Mongodb) Disconnect(ctx context.Context) error
  • func (m *Mongodb) Entries(ctx context.Context) ([]interface{}, error)
  • func (m *Mongodb) EntriesMinutesAgo(ctx context.Context, minutes int, opts *options.FindOptions) (interface{}, error)

Types

type Database

type Database interface {
	Entries(context.Context) ([]interface{}, error)
	EntriesMinutesAgo(context.Context, int, *options.FindOptions) (interface{}, error)
	AddEntry(context.Context, interface{}) error
	DeleteAll(context.Context, string) error
	DatabaseCollection(string, string)
	Disconnect(context.Context) error
}

type Mongodb

type Mongodb struct {
	Conn       *mongo.Client
	Database   string
	Collection string
}

func (*Mongodb) AddEntry

func (m *Mongodb) AddEntry(ctx context.Context, e interface{}) error

func (*Mongodb) DatabaseCollection

func (m *Mongodb) DatabaseCollection(database string, collection string)

func (*Mongodb) DeleteAll

func (m *Mongodb) DeleteAll(ctx context.Context, message string) error

func (*Mongodb) Disconnect

func (m *Mongodb) Disconnect(ctx context.Context) error

func (*Mongodb) Entries

func (m *Mongodb) Entries(ctx context.Context) ([]interface{}, error)

func (*Mongodb) EntriesMinutesAgo

func (m *Mongodb) EntriesMinutesAgo(ctx context.Context, minutes int, opts *options.FindOptions) (interface{}, error)