inmemorytaskdb

package

v0.0.0-...-90deddd Latest Latest Go to latest Published: Oct 18, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type InmemoryTaskDB struct {
	taskdb.TaskDB
	// contains filtered or unexported fields
}

func GetInmemoryTaskDB(tableName, repoName string) *InmemoryTaskDB

func NewInmemoryTaskDB(tableName, repoName string) *InmemoryTaskDB

func (t *InmemoryTaskDB) CreateRun(ctx context.Context, id taskdb.RunID, user string) error

func (t *InmemoryTaskDB) CreateTask(ctx context.Context, task taskdb.Task) error

CreateTask creates a new task in the taskdb with the provided task.

func (t *InmemoryTaskDB) KeepRunAlive(ctx context.Context, id taskdb.RunID, keepalive time.Time) error

func (t *InmemoryTaskDB) KeepTaskAlive(ctx context.Context, id taskdb.TaskID, keepalive time.Time) error

func (t *InmemoryTaskDB) NumCalls(callType string) int

func (t *InmemoryTaskDB) Repository() reflow.Repository

func (t *InmemoryTaskDB) SetRunAttrs(ctx context.Context, id taskdb.RunID, bundle digest.Digest, args []string) error

func (t *InmemoryTaskDB) SetRunComplete(ctx context.Context, id taskdb.RunID, runlog, evalGraph, trace digest.Digest, end time.Time) error

func (t *InmemoryTaskDB) SetTaskAttrs(ctx context.Context, id taskdb.TaskID, stdout, stderr, inspect digest.Digest) error

func (t *InmemoryTaskDB) SetTaskComplete(ctx context.Context, id taskdb.TaskID, err error, end time.Time) error

SetTaskComplete mark the task as completed as of the given end time with the error (if any)

func (t *InmemoryTaskDB) SetTaskResult(ctx context.Context, id taskdb.TaskID, result digest.Digest) error

SetTaskResult sets the result of the task post completion.

func (t *InmemoryTaskDB) SetTaskUri(ctx context.Context, id taskdb.TaskID, uri string) error

SetTaskUri updates the task URI.

func (t *InmemoryTaskDB) Tasks(ctx context.Context, taskQuery taskdb.TaskQuery) ([]taskdb.Task, error)

type TaskDB struct {
	taskdb.TaskDB
	infra2.TableNameFlagsTrait
	infra2.BucketNameFlagsTrait
}

func (t *TaskDB) Flags(flags *flag.FlagSet)

Flags implements infra.Provider.

func (t *TaskDB) Init() error

Init implements infra.Provider