elasticsearch

type ElasticsearchServiceLogger struct{ *log.Logger }

type Logger struct{ *log.Logger }

type ReindexRequest struct {
	UserID string `json:"user_id"`
}

type ReindexResult struct {
	UserID       string `json:"user_id"`
	IsSuccess    bool   `json:"is_success"`
	ErrorMessage string `json:"error_message,omitempty"`
}

type Service struct {
	Clock       clock.Clock
	Context     context.Context
	Database    *appdb.Handle
	Logger      *ElasticsearchServiceLogger
	AppID       config.AppID
	Client      *elasticsearch.Client
	Users       UserQueries
	UserStore   *user.Store
	OAuth       *identityoauth.Store
	LoginID     *identityloginid.Store
	RolesGroups *rolesgroups.Store
	TaskQueue   task.Queue
	Producer    UserReindexCreateProducer
}

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

type Stats struct {
	TotalCount int
}

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

type UserReindexCreateProducer interface {
	NewTask(appID string, input json.RawMessage) *redisqueue.Task
	EnqueueTask(ctx context.Context, task *redisqueue.Task) error
}