Last returns the last (most recent) timestamp for a specific context

NewDaemon creates a new daemon manager

if bucket type Object

Remove removes a container

RunCLIWithDirAndCwdWithAuthMock is like RunCLIWithDirAndCwd but sets TAUBYTE_AUTH_URL and session SelectedCloud("test") for the auth mock (test cloud)

RunCommand builds a minimal cli.App with the given command as the only subcommand and runs it with args. The first element of args is the program name

State returns the current Raft state (Follower, Candidate, Leader)

Type returns the backend type this input is for

Start displacement of the course.

* List TNS paths * @param depth Depth of paths to list * @returns AsyncIterable of paths

Set up configuration for testing.

Start the Spore Drive service and return the port.

Barrier ensures all preceding operations are committed

id: provided as string even if it's an int

GetCustomCloudUrl returns the cloud value: FQDN when type=remote, universe name when type=dream.

GetSelectedCloud returns the selected cloud type from the session ("remote" | "dream").

RenameById extracts the "id" field, sets "name" to the provided name, deletes the "id" field, and renames the selector to use the id value. Returns an

RenameByName reverses RenameById - swaps ID/name back. Extracts the "name" field, sets "id" to the current key, deletes the "name" field, and renames

if bucket type Streaming

encryptResponse encrypts a response for stream service

Factory method to create a new empty configuration. Args: url: Optional service URL Returns

pidSetIntersection returns the count of PIDs that appear in both a and b (set intersection).

Get progress updates for the course. Yields: Progress updates

Main request service handler

Stop the service.

Stop the Spore Drive service.

Instantiate sets given options and creates the container from the docker image.