db

package

v0.9.237-test Latest Latest Go to latest Published: Jan 10, 2025 License: AGPL-3.0 Imports: 14 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 DB
type LocalDB
- func NewLocalDB(ctx context.Context, path string) (*LocalDB, error)
type RemoteDB
- func NewRemoteDB(ctx context.Context, connection config.Connection) *RemoteDB
type UnimplementedDB

Constants ¶

This section is empty.

Variables ¶

View Source

var Ddl string

Functions ¶

This section is empty.

Types ¶

type DB ¶

type DB 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

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

	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 LocalDB ¶

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

func NewLocalDB ¶

func NewLocalDB(ctx context.Context, path string) (*LocalDB, error)

func (*LocalDB) DeleteCheckpoint ¶

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

func (*LocalDB) DeleteHost ¶

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

func (*LocalDB) DeleteJob ¶

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

func (*LocalDB) ListCheckpoints ¶

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

func (*LocalDB) ListCheckpointsByJIDs ¶

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

func (*LocalDB) ListHosts ¶

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

func (*LocalDB) ListJobs ¶

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

func (*LocalDB) ListJobsByHostIDs ¶

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

func (*LocalDB) PutCheckpoint ¶

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

func (*LocalDB) PutHost ¶

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

func (*LocalDB) PutJob ¶

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

type RemoteDB ¶

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

func NewRemoteDB ¶

func NewRemoteDB(ctx context.Context, connection config.Connection) *RemoteDB

func (*RemoteDB) DeleteCheckpoint ¶

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

func (*RemoteDB) DeleteJob ¶

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

func (*RemoteDB) ListCheckpoints ¶

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

func (*RemoteDB) ListCheckpointsByJIDs ¶

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

func (*RemoteDB) ListJobs ¶

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

func (*RemoteDB) ListJobsByHostIDs ¶

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

func (*RemoteDB) PutCheckpoint ¶

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

func (*RemoteDB) PutJob ¶

func (db *RemoteDB) 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