database

Documentation

Overview

result.go

Index

• type Collection
• type Connecter
• type Database
• type ResultList
  • func CreateResultList() ResultList
  • func (resultList *ResultList) Add(convertSource func() map[string]interface{})
  • func (resultList *ResultList) Get() []document

Types

type Collection

type Collection interface {
	SetCollection(name string)
	Find(ctx context.Context, filter []byte, sort []byte, project []byte, limit int64, skip int64) chan models.QueryResult
	Count(ctx context.Context, filter []byte) chan models.CountResult
	EstimatedCount(ctx context.Context) chan models.CountResult
}

type Connecter

type Connecter interface {
	Connect(ctx context.Context, connection *models.Connection) chan error
	Disconnect(ctx context.Context, connectionURI string) error
	DisconnectAll(ctx context.Context) error
	GetDatabases(ctx context.Context, connectionURI string) ([]string, error)
}

Connecter provides an interface for database connection functions.

type Database

type Database interface {
	UseDatabase(connectionURI string, name string) error
	GetCollections(ctx context.Context) ([]string, error)
	Execute(ctx context.Context, command []byte) (interface{}, error)
	Drop(ctx context.Context) error
	GetCurrentDatabaseName() (string, error)
}

type ResultList

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

func CreateResultList

func CreateResultList() ResultList

func (*ResultList) Add

func (resultList *ResultList) Add(convertSource func() map[string]interface{})

func (*ResultList) Get

func (resultList *ResultList) Get() []document