elasticsearch

Documentation

Index

• Constants
• Variables
• func CursorToSearchAfter(cursor model.PageCursor) (searchAfter interface{}, err error)
• func MakeSearchBody(appID config.AppID, searchKeyword string, sortOption libuser.SortOption) map[string]interface{}
• func NewClient(credentials *config.ElasticsearchCredentials) *elasticsearch.Client
• func RawToSource(raw *model.ElasticsearchUserRaw) *model.ElasticsearchUserSource
• func SortToCursor(sort interface{}) (cursor model.PageCursor, err error)
• type Logger
  • func NewLogger(lf *log.Factory) Logger
• type Service
  • func (s *Service) QueryUser(searchKeyword string, sortOption libuser.SortOption, ...) ([]model.PageItemRef, *Stats, error)
  • func (s *Service) ReindexUser(userID string, isDelete bool) (err error)
• type Sink
  • func (s *Sink) ReceiveBlockingEvent(e *event.Event) error
  • func (s *Sink) ReceiveNonBlockingEvent(e *event.Event) error
• type Stats
• type UserQueries

Constants

const IndexNameUser = "user"

const PrefixMinChars = 3

Variables

var DependencySet = wire.NewSet(
	NewClient,
	wire.Struct(new(Service), "*"),
	NewLogger,
	wire.Struct(new(Sink), "*"),
)

Functions

func CursorToSearchAfter

func CursorToSearchAfter(cursor model.PageCursor) (searchAfter interface{}, err error)

func MakeSearchBody

func MakeSearchBody(
	appID config.AppID,
	searchKeyword string,
	sortOption libuser.SortOption,
) map[string]interface{}

func NewClient

func NewClient(credentials *config.ElasticsearchCredentials) *elasticsearch.Client

func RawToSource

func RawToSource(raw *model.ElasticsearchUserRaw) *model.ElasticsearchUserSource

func SortToCursor

func SortToCursor(sort interface{}) (cursor model.PageCursor, err error)

Types

type Logger

type Logger struct{ *log.Logger }

func NewLogger

func NewLogger(lf *log.Factory) Logger

type Service

type Service struct {
	AppID     config.AppID
	Client    *elasticsearch.Client
	Users     UserQueries
	OAuth     *identityoauth.Store
	LoginID   *identityloginid.Store
	TaskQueue task.Queue
}

func (*Service) QueryUser

func (s *Service) QueryUser(
	searchKeyword string,
	sortOption libuser.SortOption,
	pageArgs graphqlutil.PageArgs,
) ([]model.PageItemRef, *Stats, error)

func (*Service) ReindexUser

func (s *Service) ReindexUser(userID string, isDelete bool) (err error)

type Sink

type Sink struct {
	Logger   Logger
	Service  Service
	Database *appdb.Handle
}

func (*Sink) ReceiveBlockingEvent

func (s *Sink) ReceiveBlockingEvent(e *event.Event) error

func (*Sink) ReceiveNonBlockingEvent

func (s *Sink) ReceiveNonBlockingEvent(e *event.Event) error

type Stats

type Stats struct {
	TotalCount int
}

type UserQueries

type UserQueries interface {
	Get(userID string, role accesscontrol.Role) (*model.User, error)
}