Struct GitHubTaskStorage 

pub struct GitHubTaskStorage { /* private fields */ }

GitHub Issues task storage implementation

Implementations

impl GitHubTaskStorage

pub fn new( token: String, repo_owner: String, repo_name: String, ) -> Result<Self, StorageError>

Create a new GitHub task storage

Arguments

• token - GitHub personal access token
• repo_owner - Repository owner (org or user)
• repo_name - Repository name

Trait Implementations

impl TaskStorage for GitHubTaskStorage

fn save_task<'life0, 'async_trait>( &'life0 self, task: A2ATask, ) -> Pin<Box<dyn Future<Output = Result<u64, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Save a new task by creating a GitHub Issue

Creates a GitHub Issue with:

• Title and description from task
• Status label (e.g., a2a:pending)
• Task type label (e.g., a2a:codegen)

Arguments

• task - The task to save

Returns

GitHub Issue number (task ID)

fn get_task<'life0, 'async_trait>( &'life0 self, id: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<A2ATask>, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a task by ID (GitHub Issue number)

Arguments

• id - GitHub Issue number

Returns

• Some(task) if found
• None if not found (404)
• Err for other errors

fn list_tasks<'life0, 'async_trait>( &'life0 self, filter: TaskFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<A2ATask>, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List tasks with optional filtering

Uses GitHub API label filtering for status, combined with in-memory filtering for other criteria.

Arguments

• filter - Filter criteria (status, context_id, agent, updated_after, limit)

Returns

List of tasks matching the filter

Performance

• Status filtering: API-level (reduces network transfer)
• Other filters: In-memory (applied after fetch)

fn list_tasks_paginated<'life0, 'async_trait>( &'life0 self, filter: TaskFilter, ) -> Pin<Box<dyn Future<Output = Result<PaginatedResult<A2ATask>, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List tasks with cursor-based pagination

Implements cursor-based pagination for efficient navigation through large task lists. Cursors encode the (id, updated_at) of the last item, ensuring stable pagination.

Arguments

• filter - Filter criteria including optional cursor

Returns

PaginatedResult with items, next_cursor, previous_cursor, and has_more flag

Pagination Strategy

• Forward: Fetch limit+1 items after cursor to determine if has_more
• Backward: Fetch limit+1 items before cursor
• First page: No cursor provided, start from beginning

Examples

use miyabi_a2a::{GitHubTaskStorage, TaskStorage, TaskFilter};

let storage = GitHubTaskStorage::new("token".into(), "owner".into(), "repo".into())?;

// First page (50 items)
let filter = TaskFilter { limit: Some(50), ..Default::default() };
let page1 = storage.list_tasks_paginated(filter).await?;

// Navigate to next page
if let Some(cursor) = page1.next_cursor {
    let filter = TaskFilter { cursor: Some(cursor), limit: Some(50), ..Default::default() };
    let page2 = storage.list_tasks_paginated(filter).await?;
}

fn update_task<'life0, 'async_trait>( &'life0 self, id: u64, update: TaskUpdate, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update an existing task

Updates task fields via GitHub Issue API:

• Description: Updates Issue body
• Status: Updates labels (removes old status label, adds new one)

Status update process:

1. Fetch current Issue to get existing labels
2. Filter out old status labels (a2a:pending, a2a:in-progress, etc.)
3. Add new status label
4. Update Issue with new label set

Arguments

• id - GitHub Issue number
• update - Fields to update

Returns

Ok(()) on success

fn delete_task<'life0, 'async_trait>( &'life0 self, id: u64, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a task (closes GitHub Issue)

GitHub Issues cannot be permanently deleted, so this method closes the Issue instead. Closed Issues remain in the repository for audit trail purposes.

Arguments

• id - GitHub Issue number

Returns

Ok(()) on success