storage

Documentation

Index

• func AddBackend(ctx context.Context, cs *expconf.CheckpointStorageConfig) (model.StorageBackendID, error)
• func Backend(ctx context.Context, id model.StorageBackendID) (expconf.CheckpointStorageConfig, error)
• type CheckpointsGroup
  • func GroupCheckpoints(ctx context.Context, uuids []uuid.UUID) ([]*CheckpointsGroup, error)

Functions

func AddBackend

func AddBackend(
	ctx context.Context, cs *expconf.CheckpointStorageConfig,
) (model.StorageBackendID, error)

AddBackend adds storage backend information. We won't persist the "save_*_best" fields on the expconf struct. If the same storage backend has been persisted before then we will return the ID and not insert another row.

func Backend

func Backend(
	ctx context.Context, id model.StorageBackendID,
) (expconf.CheckpointStorageConfig, error)

Backend returns the checkpoint storage backend information. We won't return the "save_*_best" fields on the expconf struct.

Types

type CheckpointsGroup

type CheckpointsGroup struct {
	StorageID   *model.StorageBackendID
	Checkpoints []uuid.UUID
}

CheckpointsGroup is a grouping of storage ID to checkpoints. This isn't a map[*model.StorageBackendID][]uuid.UUID since it is pretty easy to misuse the *model.StorageBackendID by just doing something like m[ptrs.Ptr(5)].

func GroupCheckpoints

func GroupCheckpoints(
	ctx context.Context, uuids []uuid.UUID,
) ([]*CheckpointsGroup, error)

GroupCheckpoints takes a list of checkpoints and returns a mapping by storageID.