indexworker

Documentation

Index

• Variables
• func CreateIndexes(ctx context.Context, config *conf.GlobalConfiguration, le *logrus.Entry) error
• type Outcome

Variables

var ErrAdvisoryLockAlreadyAcquired = errors.New("advisory lock already acquired by another process")

ErrAdvisoryLockAlreadyAcquired is returned when another process already holds the advisory lock

var ErrExtensionNotFound = errors.New("extension not found")

Functions

func CreateIndexes

func CreateIndexes(ctx context.Context, config *conf.GlobalConfiguration, le *logrus.Entry) error

CreateIndexes ensures that the necessary indexes on the users table exist. If the indexes already exist and are valid, it skips creation. It uses a Postgres advisory lock to prevent concurrent index creation by multiple processes. Returns an error either from index creation failure (partial or complete) or if the advisory lock could not be acquired.

Types

type Outcome

type Outcome string

const (
	OutcomeSuccess Outcome = "success"
	OutcomeFailure Outcome = "failure"
	OutcomeSkipped Outcome = "skipped"
)