db

package

v0.9.261 Latest Latest Go to latest Published: Sep 5, 2025 License: AGPL-3.0 Imports: 16 Imported by: 0

Details

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

Repository

github.com/cedana/cedana

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Checkpoint
type DB
type Host
type Job
type PropagatorDB
- func NewPropagatorDB(ctx context.Context, connection config.Connection, fallback ...DB) *PropagatorDB
type SqliteDB
- func NewSqliteDB(ctx context.Context, path string) (*SqliteDB, error)
type UnimplementedDB

Constants ¶

This section is empty.

Variables ¶

View Source

var Ddl string

Functions ¶

This section is empty.

Types ¶

type Checkpoint ¶ added in v0.9.244

type Checkpoint interface {
	PutCheckpoint(ctx context.Context, checkpoint *daemon.Checkpoint) error
	ListCheckpoints(ctx context.Context, ids ...string) ([]*daemon.Checkpoint, error)
	ListCheckpointsByJIDs(ctx context.Context, jids ...string) ([]*daemon.Checkpoint, error)
	DeleteCheckpoint(ctx context.Context, id string) error
}

type DB ¶

type DB interface {
	Job
	Host
	Checkpoint
}

type Host ¶ added in v0.9.244

type Host interface {
	PutHost(ctx context.Context, host *daemon.Host) error
	ListHosts(ctx context.Context, ids ...string) ([]*daemon.Host, error)
	DeleteHost(ctx context.Context, id string) error
}

type Job ¶ added in v0.9.244

type Job interface {
	PutJob(ctx context.Context, job *daemon.Job) error
	ListJobs(ctx context.Context, jids ...string) ([]*daemon.Job, error)
	ListJobsByHostIDs(ctx context.Context, hostIDs ...string) ([]*daemon.Job, error)
	DeleteJob(ctx context.Context, jid string) error
}

type PropagatorDB ¶

type PropagatorDB struct {
	config.Connection
	// contains filtered or unexported fields
}

func NewPropagatorDB ¶

func NewPropagatorDB(ctx context.Context, connection config.Connection, fallback ...DB) *PropagatorDB

func (*PropagatorDB) DeleteCheckpoint ¶

func (db *PropagatorDB) DeleteCheckpoint(ctx context.Context, id string) error

func (*PropagatorDB) DeleteHost ¶

func (db *PropagatorDB) DeleteHost(ctx context.Context, id string) error

func (*PropagatorDB) DeleteJob ¶

func (db *PropagatorDB) DeleteJob(ctx context.Context, jid string) error

func (*PropagatorDB) ListCheckpoints ¶

func (db *PropagatorDB) ListCheckpoints(ctx context.Context, ids ...string) ([]*daemon.Checkpoint, error)

func (*PropagatorDB) ListCheckpointsByJIDs ¶

func (db *PropagatorDB) ListCheckpointsByJIDs(ctx context.Context, jids ...string) ([]*daemon.Checkpoint, error)

func (*PropagatorDB) ListHosts ¶

func (db *PropagatorDB) ListHosts(ctx context.Context, ids ...string) ([]*daemon.Host, error)

func (*PropagatorDB) ListJobs ¶

func (db *PropagatorDB) ListJobs(ctx context.Context, jids ...string) ([]*daemon.Job, error)

func (*PropagatorDB) ListJobsByHostIDs ¶

func (db *PropagatorDB) ListJobsByHostIDs(ctx context.Context, hostIDs ...string) ([]*daemon.Job, error)

func (*PropagatorDB) PutCheckpoint ¶

func (db *PropagatorDB) PutCheckpoint(ctx context.Context, checkpoint *daemon.Checkpoint) error

func (*PropagatorDB) PutHost ¶

func (db *PropagatorDB) PutHost(ctx context.Context, host *daemon.Host) error

func (*PropagatorDB) PutJob ¶

func (db *PropagatorDB) PutJob(ctx context.Context, job *daemon.Job) error

type SqliteDB ¶

type SqliteDB struct {
	UnimplementedDB
	// contains filtered or unexported fields
}

func NewSqliteDB ¶

func NewSqliteDB(ctx context.Context, path string) (*SqliteDB, error)

func (*SqliteDB) DeleteCheckpoint ¶

func (db *SqliteDB) DeleteCheckpoint(ctx context.Context, id string) error

func (*SqliteDB) DeleteHost ¶

func (db *SqliteDB) DeleteHost(ctx context.Context, id string) error

func (*SqliteDB) DeleteJob ¶

func (db *SqliteDB) DeleteJob(ctx context.Context, jid string) error

func (*SqliteDB) ListCheckpoints ¶

func (db *SqliteDB) ListCheckpoints(ctx context.Context, ids ...string) ([]*daemon.Checkpoint, error)

func (*SqliteDB) ListCheckpointsByJIDs ¶

func (db *SqliteDB) ListCheckpointsByJIDs(ctx context.Context, jids ...string) ([]*daemon.Checkpoint, error)

func (*SqliteDB) ListHosts ¶

func (db *SqliteDB) ListHosts(ctx context.Context, ids ...string) ([]*daemon.Host, error)

func (*SqliteDB) ListJobs ¶

func (db *SqliteDB) ListJobs(ctx context.Context, jids ...string) ([]*daemon.Job, error)

func (*SqliteDB) ListJobsByHostIDs ¶

func (db *SqliteDB) ListJobsByHostIDs(ctx context.Context, hostIDs ...string) ([]*daemon.Job, error)

func (*SqliteDB) PutCheckpoint ¶

func (db *SqliteDB) PutCheckpoint(ctx context.Context, checkpoint *daemon.Checkpoint) error

func (*SqliteDB) PutHost ¶

func (db *SqliteDB) PutHost(ctx context.Context, host *daemon.Host) error

func (*SqliteDB) PutJob ¶

func (db *SqliteDB) PutJob(ctx context.Context, job *daemon.Job) error

type UnimplementedDB ¶

type UnimplementedDB struct{}

func (UnimplementedDB) DeleteCheckpoint ¶

func (UnimplementedDB) DeleteCheckpoint(ctx context.Context, id string) error

func (UnimplementedDB) DeleteHost ¶

func (UnimplementedDB) DeleteHost(ctx context.Context, id string) error

func (UnimplementedDB) DeleteJob ¶

func (UnimplementedDB) DeleteJob(ctx context.Context, jid string) error

func (UnimplementedDB) ListCheckpoints ¶

func (UnimplementedDB) ListCheckpoints(ctx context.Context, ids ...string) ([]*daemon.Checkpoint, error)

func (UnimplementedDB) ListCheckpointsByJID ¶

func (UnimplementedDB) ListCheckpointsByJID(ctx context.Context, jids ...string) ([]*daemon.Checkpoint, error)

func (UnimplementedDB) ListHosts ¶

func (UnimplementedDB) ListHosts(ctx context.Context, ids ...string) ([]*daemon.Host, error)

func (UnimplementedDB) ListJobs ¶

func (UnimplementedDB) ListJobs(ctx context.Context, jids ...string) ([]*daemon.Job, error)

func (UnimplementedDB) PutCheckpoint ¶

func (UnimplementedDB) PutCheckpoint(ctx context.Context, checkpoint *daemon.Checkpoint) error

func (UnimplementedDB) PutHost ¶

func (UnimplementedDB) PutHost(ctx context.Context, host *daemon.Host) error

func (UnimplementedDB) PutJob ¶

func (UnimplementedDB) PutJob(ctx context.Context, job *daemon.Job) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
sql

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