Struct ChangeClient 

pub struct ChangeClient { /* private fields */ }

Client for change-based file operations (/{org}/{repo}/changes).

Uses the gRPC ControlService to create changes, apply file operations (create, modify, delete, move), and snapshot changes into commits.

Example

use mesa_dev::MesaClient;

let client = MesaClient::builder()
    .build()?;

let org = client.org("my-org");
let repo = org.repos().at("my-repo");
let change_client = repo.change().await?;

// Create a change based on main branch
let change = change_client.create_from_ref("refs/heads/main").await?;
let change_id = change.id.unwrap();

// Apply file operations
change_client.create_file(
    &change_id,
    "hello.txt",
    b"Hello, world!",
    None,
).await?;

// Snapshot to a commit
change_client.snapshot(&change_id, "Add hello.txt").await?;

Implementations

impl ChangeClient

pub async fn create_from_ref( &self, base_ref_name: &str, ) -> Result<Change, Status>

Create a new change based on a ref name (e.g. "refs/heads/main").

Errors

Returns a gRPC error if the request fails.

pub async fn create_from_commit( &self, commit_oid: &[u8], ) -> Result<Change, Status>

Create a new change based on a commit OID.

Errors

Returns a gRPC error if the request fails.

pub async fn create_file( &self, change_id: &ChangeId, path: &str, content: &[u8], mode: Option<u32>, ) -> Result<ApplyOpsResponse, Status>

Create a file in the working copy of a change.

Uses inline data for the file content. For large files, use apply_ops with an OpCreateFile referencing a pre-uploaded blob OID.

mode defaults to 0o100644 (regular file) if None.

Errors

Returns a gRPC error if the request fails.

pub async fn modify_file( &self, change_id: &ChangeId, path: &str, content: &[u8], ) -> Result<ApplyOpsResponse, Status>

Modify an existing file in the working copy of a change.

Replaces the file content with content (inline data).

Errors

Returns a gRPC error if the request fails.

pub async fn delete_path( &self, change_id: &ChangeId, path: &str, recursive: bool, ) -> Result<ApplyOpsResponse, Status>

Delete a path from the working copy of a change.

Set recursive to true to delete a directory and all its contents.

Errors

Returns a gRPC error if the request fails.

pub async fn move_path( &self, change_id: &ChangeId, from_path: &str, to_path: &str, ) -> Result<ApplyOpsResponse, Status>

Move (rename) a path in the working copy of a change.

Errors

Returns a gRPC error if the request fails.

pub async fn apply_ops( &self, change_id: &ChangeId, ops: Vec<Op>, ) -> Result<ApplyOpsResponse, Status>

Apply a batch of operations to a change in a single RPC.

This is the low-level method underlying create_file, modify_file, delete_path, and move_path. Use it when you need to apply multiple operations atomically.

Errors

Returns a gRPC error if the request fails.

pub async fn snapshot( &self, change_id: &ChangeId, message: &str, ) -> Result<SnapshotChangeResponse, Status>

Snapshot the current working-copy state of a change into a commit.

Errors

Returns a gRPC error if the request fails.

Trait Implementations

impl Debug for ChangeClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.