db

Documentation

Index

• Constants
• type Db
  • func New(ctx context.Context, config models.Config) (Db, error)
• type MongoDb

Constants

const (
	DB = "iot_db"
)

Types

type Db

type Db interface {
	Get(string) (*mongo.Cursor, error)
	GetWithFilter(string, primitive.D) (*mongo.Cursor, error)
	FetchCollectionNames() ([]string, error)
	TimestampBetween(int, int) primitive.D
}

func New

func New(ctx context.Context, config models.Config) (Db, error)

type MongoDb

type MongoDb interface {
	Get(string, primitive.D, *options.FindOptions) (*mongo.Cursor, error)
	ListCollectionNames() ([]string, error)
	TimestampBetween(int, int) primitive.D
}