Struct GitLabClient 

pub struct GitLabClient { /* private fields */ }

Implementations

impl GitLabClient

pub fn new(project_id: impl Into<String>, token: SecretString) -> Self

Create a new GitLab client.

pub fn with_base_url( base_url: impl Into<String>, project_id: impl Into<String>, token: SecretString, ) -> Self

Create a new GitLab client with a custom base URL.

pub fn with_auth_scheme(self, scheme: AuthScheme) -> Self

Override the auth header scheme. By default AuthScheme::Auto is used (detect by GitLab token prefix). Use this when the caller already knows whether the token is a PAT or an OAuth access_token — avoids relying on prefix heuristics for tokens from non-standard GitLab distributions.

pub fn base_url(&self) -> &str

Base URL the client was configured against. Public so the liveness probe (and any future sibling module) can build its own requests without re-walking the constructor.

pub fn http_client(&self) -> &Client

Borrow the underlying reqwest::Client. Same rationale as Self::base_url.

pub fn with_proxy(self, headers: HashMap<String, String>) -> Self

Configure proxy mode with extra headers added to every request. When proxy is active, the provider’s own auth header (PRIVATE-TOKEN) is suppressed — the proxy handles authentication.

Trait Implementations

impl IssueProvider for GitLabClient

fn get_issues<'life0, 'async_trait>( &'life0 self, filter: IssueFilter, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<Issue>>> + Send + 'async_trait>>

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

Get a list of issues with optional filters.

fn get_issue<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Issue>> + Send + 'async_trait>>

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

Get a single issue by key (e.g., “gitlab#123”, “gh#456”).

fn create_issue<'life0, 'async_trait>( &'life0 self, input: CreateIssueInput, ) -> Pin<Box<dyn Future<Output = Result<Issue>> + Send + 'async_trait>>

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

Create a new issue.

fn update_issue<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, input: UpdateIssueInput, ) -> Pin<Box<dyn Future<Output = Result<Issue>> + Send + 'async_trait>>

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

Update an existing issue.

fn get_comments<'life0, 'life1, 'async_trait>( &'life0 self, issue_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<Comment>>> + Send + 'async_trait>>

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

fn add_comment<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, issue_key: &'life1 str, body: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Comment>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn upload_attachment<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, issue_key: &'life1 str, filename: &'life2 str, data: &'life3 [u8], ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Upload a file attachment to an issue. Returns the download URL. Default returns ProviderUnsupported — override in providers that support attachments.

fn get_issue_attachments<'life0, 'life1, 'async_trait>( &'life0 self, issue_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<AssetMeta>>> + Send + 'async_trait>>

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

List attachments currently attached to an issue (body + comments).

fn download_attachment<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _issue_key: &'life1 str, asset_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Download the raw bytes of an attachment belonging to an issue.

fn asset_capabilities(&self) -> AssetCapabilities

Describe which asset operations this provider supports for each context. Used by the enricher to surface per-provider capabilities in tool schemas so agents can adapt their behaviour before making calls that would fail with ProviderUnsupported.

fn provider_name(&self) -> &'static str

Get the provider name for logging (e.g., “gitlab”, “github”).

fn get_statuses<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<IssueStatus>, Error>> + Send + 'async_trait>>

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

Get available statuses for the issue tracker. Default returns ProviderUnsupported — override in providers that support statuses.

fn link_issues<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _source_key: &'life1 str, _target_key: &'life2 str, _link_type: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, Self: 'async_trait,

Link two issues together.

fn unlink_issues<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _source_key: &'life1 str, _target_key: &'life2 str, _link_type: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, Self: 'async_trait,

Remove a link between two issues.

fn get_users<'life0, 'async_trait>( &'life0 self, _options: GetUsersOptions, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<User>, Error>> + Send + 'async_trait>>

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

Get users from the issue tracker (Jira only).

fn delete_attachment<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _issue_key: &'life1 str, _asset_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Delete an attachment from an issue.

fn set_custom_fields<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _issue_key: &'life1 str, _fields: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Set custom fields on an issue. Each entry: {"id": "field_id", "value": <value>}. Default is no-op — override in providers that support custom fields (e.g., ClickUp).

fn get_issue_relations<'life0, 'life1, 'async_trait>( &'life0 self, _issue_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<IssueRelations, Error>> + Send + 'async_trait>>

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

Get issue relations (parent, subtasks, linked issues).

fn get_structures<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<Structure>, Error>> + Send + 'async_trait>>

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

List all available structures.

fn get_structure_forest<'life0, 'async_trait>( &'life0 self, _structure_id: u64, _options: GetForestOptions, ) -> Pin<Box<dyn Future<Output = Result<StructureForest, Error>> + Send + 'async_trait>>

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

Get a structure’s forest (hierarchy tree).

fn add_structure_rows<'life0, 'async_trait>( &'life0 self, _structure_id: u64, _input: AddStructureRowsInput, ) -> Pin<Box<dyn Future<Output = Result<ForestModifyResult, Error>> + Send + 'async_trait>>

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

Add rows to a structure’s forest.

fn move_structure_rows<'life0, 'async_trait>( &'life0 self, _structure_id: u64, _input: MoveStructureRowsInput, ) -> Pin<Box<dyn Future<Output = Result<ForestModifyResult, Error>> + Send + 'async_trait>>

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

Move rows within a structure’s forest.

fn remove_structure_row<'life0, 'async_trait>( &'life0 self, _structure_id: u64, _row_id: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Remove a row from a structure’s forest.

fn get_structure_values<'life0, 'async_trait>( &'life0 self, _input: GetStructureValuesInput, ) -> Pin<Box<dyn Future<Output = Result<StructureValues, Error>> + Send + 'async_trait>>

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

Batch-read column values (including formulas) for structure rows.

fn get_structure_views<'life0, 'async_trait>( &'life0 self, _structure_id: u64, _view_id: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Vec<StructureView>, Error>> + Send + 'async_trait>>

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

Get views for a structure, optionally a specific view by ID.

fn save_structure_view<'life0, 'async_trait>( &'life0 self, _input: SaveStructureViewInput, ) -> Pin<Box<dyn Future<Output = Result<StructureView, Error>> + Send + 'async_trait>>

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

Create or update a structure view.

fn create_structure<'life0, 'async_trait>( &'life0 self, _input: CreateStructureInput, ) -> Pin<Box<dyn Future<Output = Result<Structure, Error>> + Send + 'async_trait>>

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

Create a new structure.

fn get_structure_generators<'life0, 'async_trait>( &'life0 self, _structure_id: u64, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<StructureGenerator>, Error>> + Send + 'async_trait>>

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

List generators configured on a structure.

fn add_structure_generator<'life0, 'async_trait>( &'life0 self, _input: AddStructureGeneratorInput, ) -> Pin<Box<dyn Future<Output = Result<StructureGenerator, Error>> + Send + 'async_trait>>

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

Attach a new generator to a structure.

fn sync_structure_generator<'life0, 'async_trait>( &'life0 self, _input: SyncStructureGeneratorInput, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Force a generator to refresh its produced rows.

fn delete_structure<'life0, 'async_trait>( &'life0 self, _structure_id: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Delete a structure permanently.

fn update_structure_automation<'life0, 'async_trait>( &'life0 self, _input: UpdateStructureAutomationInput, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Replace a structure’s automation configuration.

fn trigger_structure_automation<'life0, 'async_trait>( &'life0 self, _structure_id: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Run a structure’s automation pass on demand.

fn list_project_versions<'life0, 'async_trait>( &'life0 self, _params: ListProjectVersionsParams, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<ProjectVersion>, Error>> + Send + 'async_trait>>

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

List versions (“releases” / fixVersion targets) for a project. Default: ProviderUnsupported.

fn upsert_project_version<'life0, 'async_trait>( &'life0 self, _input: UpsertProjectVersionInput, ) -> Pin<Box<dyn Future<Output = Result<ProjectVersion, Error>> + Send + 'async_trait>>

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

Create-or-update a project version, keyed by (project, name). Partial update: optional fields left as None are not touched. Default: ProviderUnsupported.

fn get_board_sprints<'life0, 'async_trait>( &'life0 self, _board_id: u64, _state: SprintState, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<Sprint>, Error>> + Send + 'async_trait>>

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

List sprints visible on a board, optionally filtered by state.

fn assign_to_sprint<'life0, 'async_trait>( &'life0 self, _input: AssignToSprintInput, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Move one or more issues onto a sprint.

fn list_custom_fields<'life0, 'async_trait>( &'life0 self, _params: ListCustomFieldsParams, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<CustomFieldDescriptor>, Error>> + Send + 'async_trait>>

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

List provider-side custom fields. Lets agents (and downstream codegen) discover the customfield_* ids of an instance without hardcoding them. Default impl returns ProviderUnsupported — providers without a real customfield concept (GitHub, GitLab) keep that default.

impl LivenessProbe for GitLabClient

fn provider_name(&self) -> &str

Lower-cased provider name surfaced in the NotImplemented default and in doctor output. Concrete impls override to return e.g. "github", "gitlab".

fn test<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 SecretString, ) -> Pin<Box<dyn Future<Output = Result<LivenessResult>> + Send + 'async_trait>>

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

Probe the upstream with token. The default impl returns NotImplemented so providers without a native introspection endpoint can opt-in trivially.

impl MergeRequestProvider for GitLabClient

fn get_merge_requests<'life0, 'async_trait>( &'life0 self, filter: MrFilter, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<MergeRequest>>> + Send + 'async_trait>>

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

Get a list of merge requests with optional filters.

fn get_merge_request<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<MergeRequest>> + Send + 'async_trait>>

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

Get a single merge request by key (e.g., “mr#123”, “pr#456”).

fn get_discussions<'life0, 'life1, 'async_trait>( &'life0 self, mr_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<Discussion>>> + Send + 'async_trait>>

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

Get discussions/comments for a merge request.

fn get_diffs<'life0, 'life1, 'async_trait>( &'life0 self, mr_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<FileDiff>>> + Send + 'async_trait>>

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

fn add_comment<'life0, 'life1, 'async_trait>( &'life0 self, mr_key: &'life1 str, input: CreateCommentInput, ) -> Pin<Box<dyn Future<Output = Result<Comment>> + Send + 'async_trait>>

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

fn create_merge_request<'life0, 'async_trait>( &'life0 self, input: CreateMergeRequestInput, ) -> Pin<Box<dyn Future<Output = Result<MergeRequest>> + Send + 'async_trait>>

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

Create a new merge request / pull request.

fn update_merge_request<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, input: UpdateMergeRequestInput, ) -> Pin<Box<dyn Future<Output = Result<MergeRequest>> + Send + 'async_trait>>

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

Update an existing merge request / pull request.

fn get_mr_attachments<'life0, 'life1, 'async_trait>( &'life0 self, mr_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<AssetMeta>>> + Send + 'async_trait>>

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

List attachments on a merge request (body + discussions).

fn download_mr_attachment<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _mr_key: &'life1 str, asset_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn provider_name(&self) -> &'static str

Get the provider name for logging.

fn get_releases<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ProviderResult<Release>, Error>> + Send + 'async_trait>>

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

Get releases/tags for the repository.

fn delete_mr_attachment<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _mr_key: &'life1 str, _asset_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

impl PipelineProvider for GitLabClient

fn provider_name(&self) -> &'static str

Get the provider name for logging.

fn get_pipeline<'life0, 'async_trait>( &'life0 self, input: GetPipelineInput, ) -> Pin<Box<dyn Future<Output = Result<PipelineInfo>> + Send + 'async_trait>>

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

fn get_job_logs<'life0, 'life1, 'async_trait>( &'life0 self, job_id: &'life1 str, options: JobLogOptions, ) -> Pin<Box<dyn Future<Output = Result<JobLogOutput>> + Send + 'async_trait>>

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

Get job logs with search, pagination, or smart extraction.

impl Provider for GitLabClient

fn get_current_user<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<User>> + Send + 'async_trait>>

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

Get the current authenticated user.