database

Documentation

Index

• Variables
• func AddEngine(ctx context.Context, source *config.Database, log logger.Logger) error
• func GetEngine[T GlobalExecutor](engine config.Engine) T
• type Cursor
• type GlobalExecutor
• type Mongo
  • func (m *Mongo) AddCollection(col string)
  • func (m *Mongo) Close() error
  • func (m *Mongo) Count(ctx context.Context, col string) (int64, error)
  • func (m *Mongo) FindLimit(ctx context.Context, limit int64, col string) (Cursor, error)
  • func (m *Mongo) FindOne(ctx context.Context, filter interface{}, col string) (Result, error)
  • func (m *Mongo) Watcher(ctx context.Context, col string) (<-chan func() (wType WatcherType, res WatchResult), error)
• type MongoExecutor
• type Result
• type SQL
  • func (s *SQL) Close() error
  • func (s *SQL) Count(ctx context.Context, table string) (int64, error)
  • func (s *SQL) FindLimit(ctx context.Context, table string, limit int64) (Cursor, error)
  • func (s *SQL) FindOne(ctx context.Context, table string, query map[string]interface{}) (Result, error)
• type SQLExecutor
• type WatchResult
• type WatcherType
  • func (w WatcherType) String() string

Variables

var ErrEngineNotSupported = errors.New("database not engine supported")

Functions

func AddEngine

func AddEngine(
	ctx context.Context,
	source *config.Database,
	log logger.Logger,
) error

func GetEngine

func GetEngine[T GlobalExecutor](engine config.Engine) T

Types

type Cursor

type Cursor interface {
	Next(ctx context.Context) bool
	Result() ([]*Result, error)
}

type GlobalExecutor

type GlobalExecutor interface {
	Close() error
}

type Mongo

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

func (*Mongo) AddCollection

func (m *Mongo) AddCollection(col string)

func (*Mongo) Close

func (m *Mongo) Close() error

func (*Mongo) Count

func (m *Mongo) Count(ctx context.Context, col string) (int64, error)

func (*Mongo) FindLimit

func (m *Mongo) FindLimit(ctx context.Context, limit int64, col string) (Cursor, error)

func (*Mongo) FindOne

func (m *Mongo) FindOne(ctx context.Context, filter interface{}, col string) (Result, error)

func (*Mongo) Watcher

func (m *Mongo) Watcher(ctx context.Context, col string) (<-chan func() (wType WatcherType, res WatchResult), error)

type MongoExecutor

type MongoExecutor interface {
	GlobalExecutor

	AddCollection(col string)
	Count(ctx context.Context, col string) (int64, error)
	FindOne(ctx context.Context, filter interface{}, col string) (Result, error)
	FindLimit(ctx context.Context, limit int64, col string) (Cursor, error)
	Watcher(ctx context.Context, col string) (<-chan func() (WatcherType, WatchResult), error)
}

type Result

type Result map[string]interface{}

type SQL

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

func (*SQL) Close

func (s *SQL) Close() error

func (*SQL) Count

func (s *SQL) Count(ctx context.Context, table string) (int64, error)

func (*SQL) FindLimit

func (s *SQL) FindLimit(ctx context.Context, table string, limit int64) (Cursor, error)

func (*SQL) FindOne

func (s *SQL) FindOne(ctx context.Context, table string, query map[string]interface{}) (Result, error)

type SQLExecutor

type SQLExecutor interface {
	GlobalExecutor

	Count(ctx context.Context, table string) (int64, error)
	FindOne(ctx context.Context, table string, query map[string]interface{}) (Result, error)
	FindLimit(ctx context.Context, table string, limit int64) (Cursor, error)
}

type WatchResult

type WatchResult struct {
	DocumentId primitive.ObjectID
	Document   Result
	Update     struct {
		UpdateFields Result
		RemoveFields []string
	}
}

type WatcherType

type WatcherType uint8

const (
	Null WatcherType = iota
	OnInsert
	OnUpdate
	OnDelete
	OnReplace
)

func (WatcherType) String

func (w WatcherType) String() string