elasticsearch

package
Version: v0.0.0-...-b26cf7d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 24, 2021 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

func CreateIndex

func CreateIndex(es *elasticsearch.Client) error

func DeleteIndex

func DeleteIndex(es *elasticsearch.Client) error

func MakeClient

func MakeClient(elasticsearchURL string) (*elasticsearch.Client, error)

func NewDatabaseConfig

func NewDatabaseConfig() *config.DatabaseConfig

func NewDatabaseEnvironmentConfig

func NewDatabaseEnvironmentConfig(dbCredentials *config.DatabaseCredentials, dbConfig *config.DatabaseConfig) *config.DatabaseEnvironmentConfig

func NewLoggerFactory

func NewLoggerFactory() *log.Factory

Types

type AppLister

type AppLister struct {
	Handle *globaldb.Handle
	Store  *configsource.Store
}

func NewAppLister

func NewAppLister(ctx context.Context, pool *db.Pool, databaseCredentials *config.DatabaseCredentials) *AppLister

func (*AppLister) ListApps

func (l *AppLister) ListApps() (appIDs []string, err error)

type Item

type Item struct {
	Value  interface{}
	Cursor model.PageCursor
}

type Reindexer

type Reindexer struct {
	Handle  *appdb.Handle
	AppID   config.AppID
	Users   *user.Store
	OAuth   *identityoauth.Store
	LoginID *identityloginid.Store
}

func NewReindexer

func NewReindexer(ctx context.Context, pool *db.Pool, databaseCredentials *config.DatabaseCredentials, appID config.AppID) *Reindexer

func (*Reindexer) QueryPage

func (q *Reindexer) QueryPage(after model.PageCursor, first uint64) ([]Item, error)

func (*Reindexer) Reindex

func (q *Reindexer) Reindex(es *elasticsearch.Client) (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL