worker_v2

package

v0.53.0 Latest Latest Go to latest Published: Sep 4, 2023 License: BSD-3-Clause Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ovh/cds

Links

Open Source Insights

Documentation ¶

Index ¶

func DeleteDisabledWorker(ctx context.Context, store cache.Store, db *gorp.DbMap, workerID string, ...) error
func DeleteDisabledWorkers(ctx context.Context, store cache.Store, DBFunc func() *gorp.DbMap)
func DisableDeadWorker(ctx context.Context, store cache.Store, db *gorp.DbMap, workerID string, ...) error
func DisabledDeadWorkers(ctx context.Context, store cache.Store, DBFunc func() *gorp.DbMap)
func Insert(ctx context.Context, tx gorpmapper.SqlExecutorWithTx, w *sdk.V2Worker) error
func LoadAllWorker(ctx context.Context, db gorp.SqlExecutor) ([]sdk.V2Worker, error)
func LoadByConsumerID(ctx context.Context, db gorp.SqlExecutor, authConsumerID string) (*sdk.V2Worker, error)
func LoadByID(ctx context.Context, db gorp.SqlExecutor, workerID string, ...) (*sdk.V2Worker, error)
func LoadDeadWorkers(ctx context.Context, db gorp.SqlExecutor, timeout float64, status []string) ([]sdk.V2Worker, error)
func LoadWorkerByName(ctx context.Context, db gorp.SqlExecutor, workerName string, ...) (*sdk.V2Worker, error)
func LoadWorkerByStatus(ctx context.Context, db gorp.SqlExecutor, status string) ([]sdk.V2Worker, error)
func RegisterWorker(ctx context.Context, db gorpmapper.SqlExecutorWithTx, ...) (*sdk.V2Worker, error)
func Update(ctx context.Context, tx gorpmapper.SqlExecutorWithTx, w *sdk.V2Worker) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DeleteDisabledWorker ¶

func DeleteDisabledWorker(ctx context.Context, store cache.Store, db *gorp.DbMap, workerID string, workerName string) error

func DeleteDisabledWorkers ¶

func DeleteDisabledWorkers(ctx context.Context, store cache.Store, DBFunc func() *gorp.DbMap)

func DisableDeadWorker ¶

func DisableDeadWorker(ctx context.Context, store cache.Store, db *gorp.DbMap, workerID string, workerName string) error

func DisabledDeadWorkers ¶

func DisabledDeadWorkers(ctx context.Context, store cache.Store, DBFunc func() *gorp.DbMap)

func Insert ¶

func Insert(ctx context.Context, tx gorpmapper.SqlExecutorWithTx, w *sdk.V2Worker) error

func LoadAllWorker ¶

func LoadAllWorker(ctx context.Context, db gorp.SqlExecutor) ([]sdk.V2Worker, error)

func LoadByConsumerID ¶

func LoadByConsumerID(ctx context.Context, db gorp.SqlExecutor, authConsumerID string) (*sdk.V2Worker, error)

func LoadByID ¶

func LoadByID(ctx context.Context, db gorp.SqlExecutor, workerID string, opts ...gorpmapping.GetOptionFunc) (*sdk.V2Worker, error)

func LoadDeadWorkers ¶

func LoadDeadWorkers(ctx context.Context, db gorp.SqlExecutor, timeout float64, status []string) ([]sdk.V2Worker, error)

func LoadWorkerByName ¶

func LoadWorkerByName(ctx context.Context, db gorp.SqlExecutor, workerName string, opts ...gorpmapping.GetOptionFunc) (*sdk.V2Worker, error)

LoadWorkerByName load worker

func LoadWorkerByStatus ¶

func LoadWorkerByStatus(ctx context.Context, db gorp.SqlExecutor, status string) ([]sdk.V2Worker, error)

func RegisterWorker ¶

func RegisterWorker(ctx context.Context, db gorpmapper.SqlExecutorWithTx, spawnArgs hatchery.SpawnArgumentsJWTV2, hatch sdk.Hatchery, workerConsumer *sdk.AuthHatcheryConsumer,
	registrationForm sdk.WorkerRegistrationForm) (*sdk.V2Worker, error)

RegisterWorker Register new worker

func Update ¶

func Update(ctx context.Context, tx gorpmapper.SqlExecutorWithTx, w *sdk.V2Worker) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL