storage

type CachedLocalStorage[T proto.Message] struct {
	// contains filtered or unexported fields
}

type MockStorage[T proto.Message] struct {
	// GetAllFunc is called by GetAll. If nil, GetAll iterates the resources map.
	GetAllFunc func(ctx context.Context) ([]T, error)

	// AddResourceFunc is called by AddResource. If nil, the resource is stored in the map.
	AddResourceFunc func(ctx context.Context, key types.ContainerID, resource T) error

	// GetResourceFunc is called by GetResource. If nil, the resource is looked up in the map.
	// Return os.ErrNotExist (or any error satisfying os.IsNotExist) to simulate a missing file.
	GetResourceFunc func(ctx context.Context, key types.ContainerID) (T, error)

	// RemoveResourceFunc is called by RemoveResource. If nil, the resource is deleted from the map.
	RemoveResourceFunc func(ctx context.Context, key types.ContainerID) error
	// contains filtered or unexported fields
}

type Storage[T proto.Message] interface {
	// Initialize prepares the storage for use, including creating directories
	// and loading initial data if necessary.
	Initialize(ctx context.Context) error
	// WaitUntilReady waits until the storage is ready to serve requests.
	// This may involve waiting for file watching mechanisms to be initialized.
	WaitUntilReady(ctx context.Context) error
	// AddResource stores a new resource with the given key.
	AddResource(ctx context.Context, key types.ContainerID, resource T) error
	// RemoveResource deletes a resource by key.
	RemoveResource(ctx context.Context, key types.ContainerID) error
	// GetResource retrieves a single resource by key.
	GetResource(ctx context.Context, key types.ContainerID) (T, error)
	// GetAll returns all stored resources from the in-memory cache.
	GetAll(_ context.Context) ([]T, error)
	// contains filtered or unexported methods
}