Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kormongo

package module

Go to main page

Versions in this module

v0

v0.3.0

Nov 19, 2022

v0.2.0

Nov 19, 2022

v0.1.0

Nov 19, 2022

Changes in this version

+ const Blue

+ const CACHE_TOPIC

+ const Green

+ const Magenta

+ const Red

+ const Yellow

+ var Debug = false

+ var DefaultDB = ""

+ var FlushCacheEvery = 30 * time.Minute

+ func AutoMigrate(tableName string, dbName ...string) error

+ func BeforeDataWS(...)

+ func BeforeServersData(fn func(data any, conn *ws.Conn))

+ func DisableCache()

+ func FlushCache()

+ func GetAllColumnsTypes(table string, dbName ...string) map[string]string

+ func GetAllTables(dbName ...string) []string

+ func GetConnection(dbName ...string) (*mongo.Database, bool)

+ func InitShell() bool

+ func New(dbName string, dbDSN ...string) error

+ func NewFromConnection(dbName string, dbConn *mongo.Database) error

+ func RunEvery(t time.Duration, function any)

+ func ShutdownDatabases(databasesName ...string) error

+ func WithBus(bus *ksbus.Server) *ksbus.Server

+ type Builder struct

+ func BuilderS(tableName ...string) *Builder[T]

+ func Model(tableName ...string) *Builder[T]

+ func (b *Builder[T]) All() ([]T, error)

+ func (b *Builder[T]) Context(ctx context.Context) *Builder[T]

+ func (b *Builder[T]) Database(dbName string) *Builder[T]

+ func (b *Builder[T]) Debug() *Builder[T]

+ func (b *Builder[T]) Delete() (int, error)

+ func (b *Builder[T]) Drop() (int, error)

+ func (b *Builder[T]) Insert(model *T) (int, error)

+ func (b *Builder[T]) Limit(limit int) *Builder[T]

+ func (b *Builder[T]) One() (T, error)

+ func (b *Builder[T]) OrderBy(fields ...string) *Builder[T]

+ func (b *Builder[T]) Page(pageNumber int) *Builder[T]

+ func (b *Builder[T]) Select(columns ...string) *Builder[T]

+ func (b *Builder[T]) Set(fieldsCommaSeparated string, args ...any) (int, error)

+ func (b *Builder[T]) Where(fieldsCommaSeparated string, args ...any) *Builder[T]

+ type BuilderM struct

+ func BuilderMap(tableName string) *BuilderM

+ func Table(tableName string) *BuilderM

+ func (b *BuilderM) All() ([]map[string]any, error)

+ func (b *BuilderM) Context(ctx context.Context) *BuilderM

+ func (b *BuilderM) Database(dbName string) *BuilderM

+ func (b *BuilderM) Debug() *BuilderM

+ func (b *BuilderM) Delete() (int, error)

+ func (b *BuilderM) Drop() (int, error)

+ func (b *BuilderM) Insert(fieldsCommaSeparated string, fields_values ...any) (int, error)

+ func (b *BuilderM) Limit(limit int) *BuilderM

+ func (b *BuilderM) One() (map[string]any, error)

+ func (b *BuilderM) OrderBy(fields ...string) *BuilderM

+ func (b *BuilderM) Page(pageNumber int) *BuilderM

+ func (b *BuilderM) Select(columns ...string) *BuilderM

+ func (b *BuilderM) Set(fieldsCommaSeparated string, args ...any) (int, error)

+ func (b *BuilderM) Where(fieldsCommaSeparated string, args ...any) *BuilderM

+ type DatabaseEntity struct

+ MongoConn *mongo.Database

+ Name string

+ Tables []TableEntity

+ func GetMemoryDatabase(dbName string) (*DatabaseEntity, error)

+ func GetMemoryDatabases() []DatabaseEntity

+ type TableEntity struct

+ Columns []string

+ ModelTypes map[string]string

+ Name string

+ Pk string

+ Tags map[string][]string

+ Types map[string]string

+ func GetMemoryTable(tbName string, dbName ...string) (TableEntity, error)

+ func GetMemoryTables(dbName ...string) ([]TableEntity, error)