elasticsearch

Documentation

Index

• Variables
• func CreateIndex(es *elasticsearch.Client) error
• func DeleteIndex(es *elasticsearch.Client) error
• func MakeClient(elasticsearchURL string) (*elasticsearch.Client, error)
• func NewEmptyIdentityConfig() *config.IdentityConfig
• func NewGlobalDatabaseCredentials(dbCredentials *config.DatabaseCredentials) *config.GlobalDatabaseCredentialsEnvironmentConfig
• func NewLoggerFactory() *log.Factory
• func UpdateIndex(es *elasticsearch.Client) error
• type AppLister
  • func NewAppLister(ctx context.Context, pool *db.Pool, ...) *AppLister
  • func (l *AppLister) ListApps() (appIDs []string, err error)
• type Item
• type Reindexer
  • func NewReindexer(ctx context.Context, pool *db.Pool, ...) *Reindexer
  • func (q *Reindexer) QueryPage(after model.PageCursor, first uint64) ([]Item, error)
  • func (q *Reindexer) Reindex(es *elasticsearch.Client) (err error)

Variables

var DependencySet = wire.NewSet(
	NewLoggerFactory,
	config.NewDefaultDatabaseEnvironmentConfig,
	NewGlobalDatabaseCredentials,
	NewEmptyIdentityConfig,
	globaldb.DependencySet,
	appdb.NewHandle,
	appdb.DependencySet,
	clock.DependencySet,
	wire.Struct(new(user.Store), "*"),
	wire.Struct(new(identityoauth.Store), "*"),
	wire.Struct(new(identityloginid.Store), "*"),
	wire.Struct(new(rolesgroups.Store), "*"),
	wire.Struct(new(configsource.Store), "*"),
	wire.Struct(new(AppLister), "*"),
	wire.Struct(new(Reindexer), "*"),
)

var IndexMappings = `` /* 2273-byte string literal not displayed */

DO NOT delete or update properties Only add new properties

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 NewEmptyIdentityConfig

func NewEmptyIdentityConfig() *config.IdentityConfig

func NewGlobalDatabaseCredentials

func NewGlobalDatabaseCredentials(dbCredentials *config.DatabaseCredentials) *config.GlobalDatabaseCredentialsEnvironmentConfig

func NewLoggerFactory

func NewLoggerFactory() *log.Factory

func UpdateIndex

func UpdateIndex(es *elasticsearch.Client) error

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 {
	Clock       clock.Clock
	Handle      *appdb.Handle
	AppID       config.AppID
	Users       *user.Store
	OAuth       *identityoauth.Store
	LoginID     *identityloginid.Store
	RolesGroups *rolesgroups.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)