Method LeaderInsert

riverdriver/riversqlite/river_sqlite_driver.go:1017–1029

(ctx context.Context, params *riverdriver.LeaderInsertParams)

}

func (e *Executor) LeaderInsert(ctx context.Context, params *riverdriver.LeaderInsertParams) (*riverdriver.Leader, error) {
	leader, err := dbsqlc.New().LeaderInsert(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.LeaderInsertParams{
		ElectedAt: timeStringNullable(params.ElectedAt),
		ExpiresAt: timeStringNullable(params.ExpiresAt),
		Now:       timeStringNullable(params.Now),
		LeaderID:  params.LeaderID,
		TTL:       durationAsString(params.TTL),
	})
	if err != nil {
		return nil, interpretError(err)
	}
	return leaderFromInternal(leader), nil
}

func (e *Executor) LeaderResign(ctx context.Context, params *riverdriver.LeaderResignParams) (bool, error) {
	numResigned, err := dbsqlc.New().LeaderResign(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.LeaderResignParams{