gatewayv1connect

package
v0.2.49 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 28, 2026 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// GatewayListServicesProcedure is the fully-qualified name of the Gateway's ListServices RPC.
	GatewayListServicesProcedure = "/mind.gateway.v1.Gateway/ListServices"
	// GatewayReadFileProcedure is the fully-qualified name of the Gateway's ReadFile RPC.
	GatewayReadFileProcedure = "/mind.gateway.v1.Gateway/ReadFile"
	// GatewayWriteFileProcedure is the fully-qualified name of the Gateway's WriteFile RPC.
	GatewayWriteFileProcedure = "/mind.gateway.v1.Gateway/WriteFile"
	// GatewayListFilesProcedure is the fully-qualified name of the Gateway's ListFiles RPC.
	GatewayListFilesProcedure = "/mind.gateway.v1.Gateway/ListFiles"
	// GatewaySubscribeWorkspaceChangesProcedure is the fully-qualified name of the Gateway's
	// SubscribeWorkspaceChanges RPC.
	GatewaySubscribeWorkspaceChangesProcedure = "/mind.gateway.v1.Gateway/SubscribeWorkspaceChanges"
	// GatewayDeleteFileProcedure is the fully-qualified name of the Gateway's DeleteFile RPC.
	GatewayDeleteFileProcedure = "/mind.gateway.v1.Gateway/DeleteFile"
	// GatewayMoveFileProcedure is the fully-qualified name of the Gateway's MoveFile RPC.
	GatewayMoveFileProcedure = "/mind.gateway.v1.Gateway/MoveFile"
	// GatewayCreateFileProcedure is the fully-qualified name of the Gateway's CreateFile RPC.
	GatewayCreateFileProcedure = "/mind.gateway.v1.Gateway/CreateFile"
	// GatewayFixProcedure is the fully-qualified name of the Gateway's Fix RPC.
	GatewayFixProcedure = "/mind.gateway.v1.Gateway/Fix"
	// GatewayApplyEditProcedure is the fully-qualified name of the Gateway's ApplyEdit RPC.
	GatewayApplyEditProcedure = "/mind.gateway.v1.Gateway/ApplyEdit"
	// GatewayBatchApplyEditsProcedure is the fully-qualified name of the Gateway's BatchApplyEdits RPC.
	GatewayBatchApplyEditsProcedure = "/mind.gateway.v1.Gateway/BatchApplyEdits"
	// GatewayConfigureMutationAuthorityProcedure is the fully-qualified name of the Gateway's
	// ConfigureMutationAuthority RPC.
	GatewayConfigureMutationAuthorityProcedure = "/mind.gateway.v1.Gateway/ConfigureMutationAuthority"
	// GatewayPrepareMutationProcedure is the fully-qualified name of the Gateway's PrepareMutation RPC.
	GatewayPrepareMutationProcedure = "/mind.gateway.v1.Gateway/PrepareMutation"
	// GatewayApplyPreparedMutationProcedure is the fully-qualified name of the Gateway's
	// ApplyPreparedMutation RPC.
	GatewayApplyPreparedMutationProcedure = "/mind.gateway.v1.Gateway/ApplyPreparedMutation"
	// GatewaySearchProcedure is the fully-qualified name of the Gateway's Search RPC.
	GatewaySearchProcedure = "/mind.gateway.v1.Gateway/Search"
	// GatewayBuildProcedure is the fully-qualified name of the Gateway's Build RPC.
	GatewayBuildProcedure = "/mind.gateway.v1.Gateway/Build"
	// GatewayLintProcedure is the fully-qualified name of the Gateway's Lint RPC.
	GatewayLintProcedure = "/mind.gateway.v1.Gateway/Lint"
	// GatewayTestProcedure is the fully-qualified name of the Gateway's Test RPC.
	GatewayTestProcedure = "/mind.gateway.v1.Gateway/Test"
	// GatewayFormatProcedure is the fully-qualified name of the Gateway's Format RPC.
	GatewayFormatProcedure = "/mind.gateway.v1.Gateway/Format"
	// GatewayRunCommandProcedure is the fully-qualified name of the Gateway's RunCommand RPC.
	GatewayRunCommandProcedure = "/mind.gateway.v1.Gateway/RunCommand"
	// GatewayListAllCommandsProcedure is the fully-qualified name of the Gateway's ListAllCommands RPC.
	GatewayListAllCommandsProcedure = "/mind.gateway.v1.Gateway/ListAllCommands"
	// GatewayRunChecksProcedure is the fully-qualified name of the Gateway's RunChecks RPC.
	GatewayRunChecksProcedure = "/mind.gateway.v1.Gateway/RunChecks"
	// GatewayGitStatusProcedure is the fully-qualified name of the Gateway's GitStatus RPC.
	GatewayGitStatusProcedure = "/mind.gateway.v1.Gateway/GitStatus"
	// GatewayGitDiffProcedure is the fully-qualified name of the Gateway's GitDiff RPC.
	GatewayGitDiffProcedure = "/mind.gateway.v1.Gateway/GitDiff"
	// GatewayGitLogProcedure is the fully-qualified name of the Gateway's GitLog RPC.
	GatewayGitLogProcedure = "/mind.gateway.v1.Gateway/GitLog"
	// GatewayGitCommitProcedure is the fully-qualified name of the Gateway's GitCommit RPC.
	GatewayGitCommitProcedure = "/mind.gateway.v1.Gateway/GitCommit"
	// GatewayGitBranchProcedure is the fully-qualified name of the Gateway's GitBranch RPC.
	GatewayGitBranchProcedure = "/mind.gateway.v1.Gateway/GitBranch"
	// GatewayGitCheckoutProcedure is the fully-qualified name of the Gateway's GitCheckout RPC.
	GatewayGitCheckoutProcedure = "/mind.gateway.v1.Gateway/GitCheckout"
	// GatewayGitPushProcedure is the fully-qualified name of the Gateway's GitPush RPC.
	GatewayGitPushProcedure = "/mind.gateway.v1.Gateway/GitPush"
	// GatewayGitTagProcedure is the fully-qualified name of the Gateway's GitTag RPC.
	GatewayGitTagProcedure = "/mind.gateway.v1.Gateway/GitTag"
	// GatewayGitMergeProcedure is the fully-qualified name of the Gateway's GitMerge RPC.
	GatewayGitMergeProcedure = "/mind.gateway.v1.Gateway/GitMerge"
	// GatewayGitRevertProcedure is the fully-qualified name of the Gateway's GitRevert RPC.
	GatewayGitRevertProcedure = "/mind.gateway.v1.Gateway/GitRevert"
	// GatewayReleaseProcedure is the fully-qualified name of the Gateway's Release RPC.
	GatewayReleaseProcedure = "/mind.gateway.v1.Gateway/Release"
	// GatewayForgePullRequestStatusProcedure is the fully-qualified name of the Gateway's
	// ForgePullRequestStatus RPC.
	GatewayForgePullRequestStatusProcedure = "/mind.gateway.v1.Gateway/ForgePullRequestStatus"
	// GatewayForgeMergePullRequestProcedure is the fully-qualified name of the Gateway's
	// ForgeMergePullRequest RPC.
	GatewayForgeMergePullRequestProcedure = "/mind.gateway.v1.Gateway/ForgeMergePullRequest"
	// GatewayForgeRequestReviewProcedure is the fully-qualified name of the Gateway's
	// ForgeRequestReview RPC.
	GatewayForgeRequestReviewProcedure = "/mind.gateway.v1.Gateway/ForgeRequestReview"
	// GatewayForgeNormalizeWebhookProcedure is the fully-qualified name of the Gateway's
	// ForgeNormalizeWebhook RPC.
	GatewayForgeNormalizeWebhookProcedure = "/mind.gateway.v1.Gateway/ForgeNormalizeWebhook"
	// GatewayListDependenciesProcedure is the fully-qualified name of the Gateway's ListDependencies
	// RPC.
	GatewayListDependenciesProcedure = "/mind.gateway.v1.Gateway/ListDependencies"
	// GatewayAddDependencyProcedure is the fully-qualified name of the Gateway's AddDependency RPC.
	GatewayAddDependencyProcedure = "/mind.gateway.v1.Gateway/AddDependency"
	// GatewayRemoveDependencyProcedure is the fully-qualified name of the Gateway's RemoveDependency
	// RPC.
	GatewayRemoveDependencyProcedure = "/mind.gateway.v1.Gateway/RemoveDependency"
	// GatewayGetProjectInfoProcedure is the fully-qualified name of the Gateway's GetProjectInfo RPC.
	GatewayGetProjectInfoProcedure = "/mind.gateway.v1.Gateway/GetProjectInfo"
	// GatewayOpenTerminalProcedure is the fully-qualified name of the Gateway's OpenTerminal RPC.
	GatewayOpenTerminalProcedure = "/mind.gateway.v1.Gateway/OpenTerminal"
	// GatewayAttachTerminalProcedure is the fully-qualified name of the Gateway's AttachTerminal RPC.
	GatewayAttachTerminalProcedure = "/mind.gateway.v1.Gateway/AttachTerminal"
	// GatewayResizeTerminalProcedure is the fully-qualified name of the Gateway's ResizeTerminal RPC.
	GatewayResizeTerminalProcedure = "/mind.gateway.v1.Gateway/ResizeTerminal"
	// GatewayCloseTerminalProcedure is the fully-qualified name of the Gateway's CloseTerminal RPC.
	GatewayCloseTerminalProcedure = "/mind.gateway.v1.Gateway/CloseTerminal"
	// GatewayListTerminalsProcedure is the fully-qualified name of the Gateway's ListTerminals RPC.
	GatewayListTerminalsProcedure = "/mind.gateway.v1.Gateway/ListTerminals"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// GatewayName is the fully-qualified name of the Gateway service.
	GatewayName = "mind.gateway.v1.Gateway"
)

Variables

This section is empty.

Functions

func NewGatewayHandler 

func NewGatewayHandler(svc GatewayHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewGatewayHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type GatewayClient 

type GatewayClient interface {
	// ListServices returns all services known to the gateway.
	ListServices(context.Context, *connect.Request[v1.ListServicesRequest]) (*connect.Response[v1.ListServicesResponse], error)
	// ReadFile reads a file from a service's source tree.
	ReadFile(context.Context, *connect.Request[v1.ReadFileRequest]) (*connect.Response[v1.ReadFileResponse], error)
	// WriteFile writes (creates or overwrites) a file in a service's source tree.
	WriteFile(context.Context, *connect.Request[v1.WriteFileRequest]) (*connect.Response[v1.WriteFileResponse], error)
	// ListFiles lists files in a service's source tree.
	ListFiles(context.Context, *connect.Request[v1.ListFilesRequest]) (*connect.Response[v1.ListFilesResponse], error)
	// SubscribeWorkspaceChanges streams metadata-only filesystem wakeups from
	// the Codefly execution boundary. Events are sequenced and replayable over a
	// bounded window; consumers must still reconcile with authoritative reads.
	SubscribeWorkspaceChanges(context.Context, *connect.Request[v1.SubscribeWorkspaceChangesRequest]) (*connect.ServerStreamForClient[v1.WorkspaceChangeEvent], error)
	// DeleteFile removes a file from a service's source tree.
	DeleteFile(context.Context, *connect.Request[v1.DeleteFileRequest]) (*connect.Response[v1.DeleteFileResponse], error)
	// MoveFile renames or moves a file, optionally updating imports.
	MoveFile(context.Context, *connect.Request[v1.MoveFileRequest]) (*connect.Response[v1.MoveFileResponse], error)
	// CreateFile creates a new file (fails if exists unless overwrite set).
	CreateFile(context.Context, *connect.Request[v1.CreateFileRequest]) (*connect.Response[v1.CreateFileResponse], error)
	// Fix runs language-specific fixers on a file (goimports, gofmt, prettier, etc.).
	Fix(context.Context, *connect.Request[v1.FixRequest]) (*connect.Response[v1.FixResponse], error)
	// ApplyEdit performs a smart FIND/REPLACE on a file.
	ApplyEdit(context.Context, *connect.Request[v1.ApplyEditRequest]) (*connect.Response[v1.ApplyEditResponse], error)
	// BatchApplyEdits applies multiple edits atomically across files/services.
	BatchApplyEdits(context.Context, *connect.Request[v1.BatchApplyEditsRequest]) (*connect.Response[v1.BatchApplyEditsResponse], error)
	// ConfigureMutationAuthority pins the SaaS coordinator verification key and
	// this gateway's workspace identity before prepared mutations are allowed.
	ConfigureMutationAuthority(context.Context, *connect.Request[v1.ConfigureMutationAuthorityRequest]) (*connect.Response[v1.ConfigureMutationAuthorityResponse], error)
	// PrepareMutation resolves one proposed edit against current project bytes
	// without writing them and seals the exact result behind a content digest.
	PrepareMutation(context.Context, *connect.Request[v1.PrepareMutationRequest]) (*connect.Response[v1.PrepareMutationResponse], error)
	// ApplyPreparedMutation verifies the prepared digest, current resource
	// preconditions, and a coordinator-signed fenced permit before one write.
	ApplyPreparedMutation(context.Context, *connect.Request[v1.ApplyPreparedMutationRequest]) (*connect.Response[v1.ApplyPreparedMutationResponse], error)
	// Search performs text search across a service's source tree.
	Search(context.Context, *connect.Request[v1.SearchRequest]) (*connect.Response[v1.SearchResponse], error)
	// Build compiles the service (and its dependencies if needed).
	Build(context.Context, *connect.Request[v1.BuildRequest]) (*connect.Response[v1.BuildResponse], error)
	// Lint runs the configured lint command on the service.
	Lint(context.Context, *connect.Request[v1.LintRequest]) (*connect.Response[v1.LintResponse], error)
	// Test runs the configured test command on the service.
	Test(context.Context, *connect.Request[v1.TestRequest]) (*connect.Response[v1.TestResponse], error)
	// Format applies the service plugin's canonical formatter/import organizer.
	Format(context.Context, *connect.Request[v1.FormatRequest]) (*connect.Response[v1.FormatResponse], error)
	// RunCommand executes an arbitrary command in the service context.
	RunCommand(context.Context, *connect.Request[v1.RunCommandRequest]) (*connect.Response[v1.RunCommandResponse], error)
	// ListAllCommands returns commands from all loaded plugins plus built-in ones.
	ListAllCommands(context.Context, *connect.Request[v1.ListAllCommandsRequest]) (*connect.Response[v1.ListAllCommandsResponse], error)
	// RunChecks executes a set of verification checks against the service.
	RunChecks(context.Context, *connect.Request[v1.RunChecksRequest]) (*connect.Response[v1.RunChecksResponse], error)
	// GitStatus returns the current git status of modified/staged/untracked files.
	GitStatus(context.Context, *connect.Request[v1.GitStatusRequest]) (*connect.Response[v1.GitStatusResponse], error)
	// GitDiff shows changes (unstaged or staged).
	GitDiff(context.Context, *connect.Request[v1.GitDiffRequest]) (*connect.Response[v1.GitDiffResponse], error)
	// GitLog returns recent commit history.
	GitLog(context.Context, *connect.Request[v1.GitLogRequest]) (*connect.Response[v1.GitLogResponse], error)
	// GitCommit commits staged changes.
	GitCommit(context.Context, *connect.Request[v1.GitCommitRequest]) (*connect.Response[v1.GitCommitResponse], error)
	// GitBranch creates a branch at an explicit start point.
	GitBranch(context.Context, *connect.Request[v1.GitBranchRequest]) (*connect.Response[v1.GitBranchResponse], error)
	// GitCheckout switches the worktree to an existing branch or revision.
	GitCheckout(context.Context, *connect.Request[v1.GitCheckoutRequest]) (*connect.Response[v1.GitCheckoutResponse], error)
	// GitPush publishes a local branch to a remote.
	GitPush(context.Context, *connect.Request[v1.GitPushRequest]) (*connect.Response[v1.GitPushResponse], error)
	// GitTag creates an annotated or signed tag.
	GitTag(context.Context, *connect.Request[v1.GitTagRequest]) (*connect.Response[v1.GitTagResponse], error)
	// GitMerge merges one revision into the checked-out branch.
	GitMerge(context.Context, *connect.Request[v1.GitMergeRequest]) (*connect.Response[v1.GitMergeResponse], error)
	// GitRevert creates a commit that reverts one revision.
	GitRevert(context.Context, *connect.Request[v1.GitRevertRequest]) (*connect.Response[v1.GitRevertResponse], error)
	// Release bumps the code unit versions, commits them, creates a signed tag,
	// and publishes the commit and tag as one semantic operation.
	Release(context.Context, *connect.Request[v1.ReleaseRequest]) (*connect.Response[v1.ReleaseResponse], error)
	// ForgePullRequestStatus returns one vendor-neutral PR/check/review snapshot.
	ForgePullRequestStatus(context.Context, *connect.Request[v1.ForgePullRequestStatusRequest]) (*connect.Response[v1.ForgePullRequestStatusResponse], error)
	// ForgeMergePullRequest merges a PR after enforcing its requested check policy.
	ForgeMergePullRequest(context.Context, *connect.Request[v1.ForgeMergePullRequestRequest]) (*connect.Response[v1.ForgeMergePullRequestResponse], error)
	// ForgeRequestReview requests reviewers on a PR.
	ForgeRequestReview(context.Context, *connect.Request[v1.ForgeRequestReviewRequest]) (*connect.Response[v1.ForgeRequestReviewResponse], error)
	// ForgeNormalizeWebhook verifies and normalizes one provider webhook.
	ForgeNormalizeWebhook(context.Context, *connect.Request[v1.ForgeNormalizeWebhookRequest]) (*connect.Response[v1.ForgeNormalizeWebhookResponse], error)
	// ListDependencies returns all dependencies with versions.
	ListDependencies(context.Context, *connect.Request[v1.ListDependenciesRequest]) (*connect.Response[v1.ListDependenciesResponse], error)
	// AddDependency adds a package via the language package manager.
	AddDependency(context.Context, *connect.Request[v1.AddDependencyRequest]) (*connect.Response[v1.AddDependencyResponse], error)
	// RemoveDependency removes a package via the language package manager.
	RemoveDependency(context.Context, *connect.Request[v1.RemoveDependencyRequest]) (*connect.Response[v1.RemoveDependencyResponse], error)
	// GetProjectInfo returns rich project metadata: module, packages, deps, file hashes.
	GetProjectInfo(context.Context, *connect.Request[v1.GetProjectInfoRequest]) (*connect.Response[v1.GetProjectInfoResponse], error)
	// OpenTerminal spawns a PTY-backed shell in the gateway's working directory.
	OpenTerminal(context.Context, *connect.Request[v1.OpenTerminalRequest]) (*connect.Response[v1.OpenTerminalResponse], error)
	// AttachTerminal is a bidirectional stream: client input bytes in,
	// raw PTY output bytes out, until the shell exits or the client detaches.
	AttachTerminal(context.Context) *connect.BidiStreamForClient[v1.TerminalInput, v1.TerminalOutput]
	// ResizeTerminal changes the PTY window size (rows/cols).
	ResizeTerminal(context.Context, *connect.Request[v1.ResizeTerminalRequest]) (*connect.Response[v1.ResizeTerminalResponse], error)
	// CloseTerminal kills the PTY + child process.
	CloseTerminal(context.Context, *connect.Request[v1.CloseTerminalRequest]) (*connect.Response[v1.CloseTerminalResponse], error)
	// ListTerminals lists the open terminals in this gateway.
	ListTerminals(context.Context, *connect.Request[v1.ListTerminalsRequest]) (*connect.Response[v1.ListTerminalsResponse], error)
}

GatewayClient is a client for the mind.gateway.v1.Gateway service.

func NewGatewayClient 

func NewGatewayClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) GatewayClient

NewGatewayClient constructs a client for the mind.gateway.v1.Gateway service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type GatewayHandler 

type GatewayHandler interface {
	// ListServices returns all services known to the gateway.
	ListServices(context.Context, *connect.Request[v1.ListServicesRequest]) (*connect.Response[v1.ListServicesResponse], error)
	// ReadFile reads a file from a service's source tree.
	ReadFile(context.Context, *connect.Request[v1.ReadFileRequest]) (*connect.Response[v1.ReadFileResponse], error)
	// WriteFile writes (creates or overwrites) a file in a service's source tree.
	WriteFile(context.Context, *connect.Request[v1.WriteFileRequest]) (*connect.Response[v1.WriteFileResponse], error)
	// ListFiles lists files in a service's source tree.
	ListFiles(context.Context, *connect.Request[v1.ListFilesRequest]) (*connect.Response[v1.ListFilesResponse], error)
	// SubscribeWorkspaceChanges streams metadata-only filesystem wakeups from
	// the Codefly execution boundary. Events are sequenced and replayable over a
	// bounded window; consumers must still reconcile with authoritative reads.
	SubscribeWorkspaceChanges(context.Context, *connect.Request[v1.SubscribeWorkspaceChangesRequest], *connect.ServerStream[v1.WorkspaceChangeEvent]) error
	// DeleteFile removes a file from a service's source tree.
	DeleteFile(context.Context, *connect.Request[v1.DeleteFileRequest]) (*connect.Response[v1.DeleteFileResponse], error)
	// MoveFile renames or moves a file, optionally updating imports.
	MoveFile(context.Context, *connect.Request[v1.MoveFileRequest]) (*connect.Response[v1.MoveFileResponse], error)
	// CreateFile creates a new file (fails if exists unless overwrite set).
	CreateFile(context.Context, *connect.Request[v1.CreateFileRequest]) (*connect.Response[v1.CreateFileResponse], error)
	// Fix runs language-specific fixers on a file (goimports, gofmt, prettier, etc.).
	Fix(context.Context, *connect.Request[v1.FixRequest]) (*connect.Response[v1.FixResponse], error)
	// ApplyEdit performs a smart FIND/REPLACE on a file.
	ApplyEdit(context.Context, *connect.Request[v1.ApplyEditRequest]) (*connect.Response[v1.ApplyEditResponse], error)
	// BatchApplyEdits applies multiple edits atomically across files/services.
	BatchApplyEdits(context.Context, *connect.Request[v1.BatchApplyEditsRequest]) (*connect.Response[v1.BatchApplyEditsResponse], error)
	// ConfigureMutationAuthority pins the SaaS coordinator verification key and
	// this gateway's workspace identity before prepared mutations are allowed.
	ConfigureMutationAuthority(context.Context, *connect.Request[v1.ConfigureMutationAuthorityRequest]) (*connect.Response[v1.ConfigureMutationAuthorityResponse], error)
	// PrepareMutation resolves one proposed edit against current project bytes
	// without writing them and seals the exact result behind a content digest.
	PrepareMutation(context.Context, *connect.Request[v1.PrepareMutationRequest]) (*connect.Response[v1.PrepareMutationResponse], error)
	// ApplyPreparedMutation verifies the prepared digest, current resource
	// preconditions, and a coordinator-signed fenced permit before one write.
	ApplyPreparedMutation(context.Context, *connect.Request[v1.ApplyPreparedMutationRequest]) (*connect.Response[v1.ApplyPreparedMutationResponse], error)
	// Search performs text search across a service's source tree.
	Search(context.Context, *connect.Request[v1.SearchRequest]) (*connect.Response[v1.SearchResponse], error)
	// Build compiles the service (and its dependencies if needed).
	Build(context.Context, *connect.Request[v1.BuildRequest]) (*connect.Response[v1.BuildResponse], error)
	// Lint runs the configured lint command on the service.
	Lint(context.Context, *connect.Request[v1.LintRequest]) (*connect.Response[v1.LintResponse], error)
	// Test runs the configured test command on the service.
	Test(context.Context, *connect.Request[v1.TestRequest]) (*connect.Response[v1.TestResponse], error)
	// Format applies the service plugin's canonical formatter/import organizer.
	Format(context.Context, *connect.Request[v1.FormatRequest]) (*connect.Response[v1.FormatResponse], error)
	// RunCommand executes an arbitrary command in the service context.
	RunCommand(context.Context, *connect.Request[v1.RunCommandRequest]) (*connect.Response[v1.RunCommandResponse], error)
	// ListAllCommands returns commands from all loaded plugins plus built-in ones.
	ListAllCommands(context.Context, *connect.Request[v1.ListAllCommandsRequest]) (*connect.Response[v1.ListAllCommandsResponse], error)
	// RunChecks executes a set of verification checks against the service.
	RunChecks(context.Context, *connect.Request[v1.RunChecksRequest]) (*connect.Response[v1.RunChecksResponse], error)
	// GitStatus returns the current git status of modified/staged/untracked files.
	GitStatus(context.Context, *connect.Request[v1.GitStatusRequest]) (*connect.Response[v1.GitStatusResponse], error)
	// GitDiff shows changes (unstaged or staged).
	GitDiff(context.Context, *connect.Request[v1.GitDiffRequest]) (*connect.Response[v1.GitDiffResponse], error)
	// GitLog returns recent commit history.
	GitLog(context.Context, *connect.Request[v1.GitLogRequest]) (*connect.Response[v1.GitLogResponse], error)
	// GitCommit commits staged changes.
	GitCommit(context.Context, *connect.Request[v1.GitCommitRequest]) (*connect.Response[v1.GitCommitResponse], error)
	// GitBranch creates a branch at an explicit start point.
	GitBranch(context.Context, *connect.Request[v1.GitBranchRequest]) (*connect.Response[v1.GitBranchResponse], error)
	// GitCheckout switches the worktree to an existing branch or revision.
	GitCheckout(context.Context, *connect.Request[v1.GitCheckoutRequest]) (*connect.Response[v1.GitCheckoutResponse], error)
	// GitPush publishes a local branch to a remote.
	GitPush(context.Context, *connect.Request[v1.GitPushRequest]) (*connect.Response[v1.GitPushResponse], error)
	// GitTag creates an annotated or signed tag.
	GitTag(context.Context, *connect.Request[v1.GitTagRequest]) (*connect.Response[v1.GitTagResponse], error)
	// GitMerge merges one revision into the checked-out branch.
	GitMerge(context.Context, *connect.Request[v1.GitMergeRequest]) (*connect.Response[v1.GitMergeResponse], error)
	// GitRevert creates a commit that reverts one revision.
	GitRevert(context.Context, *connect.Request[v1.GitRevertRequest]) (*connect.Response[v1.GitRevertResponse], error)
	// Release bumps the code unit versions, commits them, creates a signed tag,
	// and publishes the commit and tag as one semantic operation.
	Release(context.Context, *connect.Request[v1.ReleaseRequest]) (*connect.Response[v1.ReleaseResponse], error)
	// ForgePullRequestStatus returns one vendor-neutral PR/check/review snapshot.
	ForgePullRequestStatus(context.Context, *connect.Request[v1.ForgePullRequestStatusRequest]) (*connect.Response[v1.ForgePullRequestStatusResponse], error)
	// ForgeMergePullRequest merges a PR after enforcing its requested check policy.
	ForgeMergePullRequest(context.Context, *connect.Request[v1.ForgeMergePullRequestRequest]) (*connect.Response[v1.ForgeMergePullRequestResponse], error)
	// ForgeRequestReview requests reviewers on a PR.
	ForgeRequestReview(context.Context, *connect.Request[v1.ForgeRequestReviewRequest]) (*connect.Response[v1.ForgeRequestReviewResponse], error)
	// ForgeNormalizeWebhook verifies and normalizes one provider webhook.
	ForgeNormalizeWebhook(context.Context, *connect.Request[v1.ForgeNormalizeWebhookRequest]) (*connect.Response[v1.ForgeNormalizeWebhookResponse], error)
	// ListDependencies returns all dependencies with versions.
	ListDependencies(context.Context, *connect.Request[v1.ListDependenciesRequest]) (*connect.Response[v1.ListDependenciesResponse], error)
	// AddDependency adds a package via the language package manager.
	AddDependency(context.Context, *connect.Request[v1.AddDependencyRequest]) (*connect.Response[v1.AddDependencyResponse], error)
	// RemoveDependency removes a package via the language package manager.
	RemoveDependency(context.Context, *connect.Request[v1.RemoveDependencyRequest]) (*connect.Response[v1.RemoveDependencyResponse], error)
	// GetProjectInfo returns rich project metadata: module, packages, deps, file hashes.
	GetProjectInfo(context.Context, *connect.Request[v1.GetProjectInfoRequest]) (*connect.Response[v1.GetProjectInfoResponse], error)
	// OpenTerminal spawns a PTY-backed shell in the gateway's working directory.
	OpenTerminal(context.Context, *connect.Request[v1.OpenTerminalRequest]) (*connect.Response[v1.OpenTerminalResponse], error)
	// AttachTerminal is a bidirectional stream: client input bytes in,
	// raw PTY output bytes out, until the shell exits or the client detaches.
	AttachTerminal(context.Context, *connect.BidiStream[v1.TerminalInput, v1.TerminalOutput]) error
	// ResizeTerminal changes the PTY window size (rows/cols).
	ResizeTerminal(context.Context, *connect.Request[v1.ResizeTerminalRequest]) (*connect.Response[v1.ResizeTerminalResponse], error)
	// CloseTerminal kills the PTY + child process.
	CloseTerminal(context.Context, *connect.Request[v1.CloseTerminalRequest]) (*connect.Response[v1.CloseTerminalResponse], error)
	// ListTerminals lists the open terminals in this gateway.
	ListTerminals(context.Context, *connect.Request[v1.ListTerminalsRequest]) (*connect.Response[v1.ListTerminalsResponse], error)
}

GatewayHandler is an implementation of the mind.gateway.v1.Gateway service.

type UnimplementedGatewayHandler 

type UnimplementedGatewayHandler struct{}

UnimplementedGatewayHandler returns CodeUnimplemented from all methods.

func (UnimplementedGatewayHandler) AddDependency 

func (UnimplementedGatewayHandler) AddDependency(context.Context, *connect.Request[v1.AddDependencyRequest]) (*connect.Response[v1.AddDependencyResponse], error)

func (UnimplementedGatewayHandler) ApplyEdit 

func (UnimplementedGatewayHandler) ApplyEdit(context.Context, *connect.Request[v1.ApplyEditRequest]) (*connect.Response[v1.ApplyEditResponse], error)

func (UnimplementedGatewayHandler) ApplyPreparedMutation added in v0.2.27 

func (UnimplementedGatewayHandler) ApplyPreparedMutation(context.Context, *connect.Request[v1.ApplyPreparedMutationRequest]) (*connect.Response[v1.ApplyPreparedMutationResponse], error)

func (UnimplementedGatewayHandler) AttachTerminal added in v0.2.12 

func (UnimplementedGatewayHandler) AttachTerminal(context.Context, *connect.BidiStream[v1.TerminalInput, v1.TerminalOutput]) error

func (UnimplementedGatewayHandler) BatchApplyEdits 

func (UnimplementedGatewayHandler) BatchApplyEdits(context.Context, *connect.Request[v1.BatchApplyEditsRequest]) (*connect.Response[v1.BatchApplyEditsResponse], error)

func (UnimplementedGatewayHandler) Build 

func (UnimplementedGatewayHandler) Build(context.Context, *connect.Request[v1.BuildRequest]) (*connect.Response[v1.BuildResponse], error)

func (UnimplementedGatewayHandler) CloseTerminal added in v0.2.12 

func (UnimplementedGatewayHandler) CloseTerminal(context.Context, *connect.Request[v1.CloseTerminalRequest]) (*connect.Response[v1.CloseTerminalResponse], error)

func (UnimplementedGatewayHandler) ConfigureMutationAuthority added in v0.2.27 

func (UnimplementedGatewayHandler) ConfigureMutationAuthority(context.Context, *connect.Request[v1.ConfigureMutationAuthorityRequest]) (*connect.Response[v1.ConfigureMutationAuthorityResponse], error)

func (UnimplementedGatewayHandler) CreateFile 

func (UnimplementedGatewayHandler) CreateFile(context.Context, *connect.Request[v1.CreateFileRequest]) (*connect.Response[v1.CreateFileResponse], error)

func (UnimplementedGatewayHandler) DeleteFile 

func (UnimplementedGatewayHandler) DeleteFile(context.Context, *connect.Request[v1.DeleteFileRequest]) (*connect.Response[v1.DeleteFileResponse], error)

func (UnimplementedGatewayHandler) Fix 

func (UnimplementedGatewayHandler) Fix(context.Context, *connect.Request[v1.FixRequest]) (*connect.Response[v1.FixResponse], error)

func (UnimplementedGatewayHandler) ForgeMergePullRequest added in v0.2.37 

func (UnimplementedGatewayHandler) ForgeMergePullRequest(context.Context, *connect.Request[v1.ForgeMergePullRequestRequest]) (*connect.Response[v1.ForgeMergePullRequestResponse], error)

func (UnimplementedGatewayHandler) ForgeNormalizeWebhook added in v0.2.37 

func (UnimplementedGatewayHandler) ForgeNormalizeWebhook(context.Context, *connect.Request[v1.ForgeNormalizeWebhookRequest]) (*connect.Response[v1.ForgeNormalizeWebhookResponse], error)

func (UnimplementedGatewayHandler) ForgePullRequestStatus added in v0.2.37 

func (UnimplementedGatewayHandler) ForgePullRequestStatus(context.Context, *connect.Request[v1.ForgePullRequestStatusRequest]) (*connect.Response[v1.ForgePullRequestStatusResponse], error)

func (UnimplementedGatewayHandler) ForgeRequestReview added in v0.2.37 

func (UnimplementedGatewayHandler) ForgeRequestReview(context.Context, *connect.Request[v1.ForgeRequestReviewRequest]) (*connect.Response[v1.ForgeRequestReviewResponse], error)

func (UnimplementedGatewayHandler) Format added in v0.2.37 

func (UnimplementedGatewayHandler) Format(context.Context, *connect.Request[v1.FormatRequest]) (*connect.Response[v1.FormatResponse], error)

func (UnimplementedGatewayHandler) GetProjectInfo 

func (UnimplementedGatewayHandler) GetProjectInfo(context.Context, *connect.Request[v1.GetProjectInfoRequest]) (*connect.Response[v1.GetProjectInfoResponse], error)

func (UnimplementedGatewayHandler) GitBranch added in v0.2.37 

func (UnimplementedGatewayHandler) GitBranch(context.Context, *connect.Request[v1.GitBranchRequest]) (*connect.Response[v1.GitBranchResponse], error)

func (UnimplementedGatewayHandler) GitCheckout added in v0.2.37 

func (UnimplementedGatewayHandler) GitCheckout(context.Context, *connect.Request[v1.GitCheckoutRequest]) (*connect.Response[v1.GitCheckoutResponse], error)

func (UnimplementedGatewayHandler) GitCommit 

func (UnimplementedGatewayHandler) GitCommit(context.Context, *connect.Request[v1.GitCommitRequest]) (*connect.Response[v1.GitCommitResponse], error)

func (UnimplementedGatewayHandler) GitDiff 

func (UnimplementedGatewayHandler) GitDiff(context.Context, *connect.Request[v1.GitDiffRequest]) (*connect.Response[v1.GitDiffResponse], error)

func (UnimplementedGatewayHandler) GitLog 

func (UnimplementedGatewayHandler) GitLog(context.Context, *connect.Request[v1.GitLogRequest]) (*connect.Response[v1.GitLogResponse], error)

func (UnimplementedGatewayHandler) GitMerge added in v0.2.37 

func (UnimplementedGatewayHandler) GitMerge(context.Context, *connect.Request[v1.GitMergeRequest]) (*connect.Response[v1.GitMergeResponse], error)

func (UnimplementedGatewayHandler) GitPush added in v0.2.37 

func (UnimplementedGatewayHandler) GitPush(context.Context, *connect.Request[v1.GitPushRequest]) (*connect.Response[v1.GitPushResponse], error)

func (UnimplementedGatewayHandler) GitRevert added in v0.2.37 

func (UnimplementedGatewayHandler) GitRevert(context.Context, *connect.Request[v1.GitRevertRequest]) (*connect.Response[v1.GitRevertResponse], error)

func (UnimplementedGatewayHandler) GitStatus 

func (UnimplementedGatewayHandler) GitStatus(context.Context, *connect.Request[v1.GitStatusRequest]) (*connect.Response[v1.GitStatusResponse], error)

func (UnimplementedGatewayHandler) GitTag added in v0.2.37 

func (UnimplementedGatewayHandler) GitTag(context.Context, *connect.Request[v1.GitTagRequest]) (*connect.Response[v1.GitTagResponse], error)

func (UnimplementedGatewayHandler) Lint 

func (UnimplementedGatewayHandler) Lint(context.Context, *connect.Request[v1.LintRequest]) (*connect.Response[v1.LintResponse], error)

func (UnimplementedGatewayHandler) ListAllCommands 

func (UnimplementedGatewayHandler) ListAllCommands(context.Context, *connect.Request[v1.ListAllCommandsRequest]) (*connect.Response[v1.ListAllCommandsResponse], error)

func (UnimplementedGatewayHandler) ListDependencies 

func (UnimplementedGatewayHandler) ListDependencies(context.Context, *connect.Request[v1.ListDependenciesRequest]) (*connect.Response[v1.ListDependenciesResponse], error)

func (UnimplementedGatewayHandler) ListFiles 

func (UnimplementedGatewayHandler) ListFiles(context.Context, *connect.Request[v1.ListFilesRequest]) (*connect.Response[v1.ListFilesResponse], error)

func (UnimplementedGatewayHandler) ListServices 

func (UnimplementedGatewayHandler) ListServices(context.Context, *connect.Request[v1.ListServicesRequest]) (*connect.Response[v1.ListServicesResponse], error)

func (UnimplementedGatewayHandler) ListTerminals added in v0.2.12 

func (UnimplementedGatewayHandler) ListTerminals(context.Context, *connect.Request[v1.ListTerminalsRequest]) (*connect.Response[v1.ListTerminalsResponse], error)

func (UnimplementedGatewayHandler) MoveFile 

func (UnimplementedGatewayHandler) MoveFile(context.Context, *connect.Request[v1.MoveFileRequest]) (*connect.Response[v1.MoveFileResponse], error)

func (UnimplementedGatewayHandler) OpenTerminal added in v0.2.12 

func (UnimplementedGatewayHandler) OpenTerminal(context.Context, *connect.Request[v1.OpenTerminalRequest]) (*connect.Response[v1.OpenTerminalResponse], error)

func (UnimplementedGatewayHandler) PrepareMutation added in v0.2.27 

func (UnimplementedGatewayHandler) PrepareMutation(context.Context, *connect.Request[v1.PrepareMutationRequest]) (*connect.Response[v1.PrepareMutationResponse], error)

func (UnimplementedGatewayHandler) ReadFile 

func (UnimplementedGatewayHandler) ReadFile(context.Context, *connect.Request[v1.ReadFileRequest]) (*connect.Response[v1.ReadFileResponse], error)

func (UnimplementedGatewayHandler) Release added in v0.2.37 

func (UnimplementedGatewayHandler) Release(context.Context, *connect.Request[v1.ReleaseRequest]) (*connect.Response[v1.ReleaseResponse], error)

func (UnimplementedGatewayHandler) RemoveDependency 

func (UnimplementedGatewayHandler) RemoveDependency(context.Context, *connect.Request[v1.RemoveDependencyRequest]) (*connect.Response[v1.RemoveDependencyResponse], error)

func (UnimplementedGatewayHandler) ResizeTerminal added in v0.2.12 

func (UnimplementedGatewayHandler) ResizeTerminal(context.Context, *connect.Request[v1.ResizeTerminalRequest]) (*connect.Response[v1.ResizeTerminalResponse], error)

func (UnimplementedGatewayHandler) RunChecks 

func (UnimplementedGatewayHandler) RunChecks(context.Context, *connect.Request[v1.RunChecksRequest]) (*connect.Response[v1.RunChecksResponse], error)

func (UnimplementedGatewayHandler) RunCommand 

func (UnimplementedGatewayHandler) RunCommand(context.Context, *connect.Request[v1.RunCommandRequest]) (*connect.Response[v1.RunCommandResponse], error)

func (UnimplementedGatewayHandler) Search 

func (UnimplementedGatewayHandler) Search(context.Context, *connect.Request[v1.SearchRequest]) (*connect.Response[v1.SearchResponse], error)

func (UnimplementedGatewayHandler) SubscribeWorkspaceChanges added in v0.2.24 

func (UnimplementedGatewayHandler) SubscribeWorkspaceChanges(context.Context, *connect.Request[v1.SubscribeWorkspaceChangesRequest], *connect.ServerStream[v1.WorkspaceChangeEvent]) error

func (UnimplementedGatewayHandler) Test 

func (UnimplementedGatewayHandler) Test(context.Context, *connect.Request[v1.TestRequest]) (*connect.Response[v1.TestResponse], error)

func (UnimplementedGatewayHandler) WriteFile 

func (UnimplementedGatewayHandler) WriteFile(context.Context, *connect.Request[v1.WriteFileRequest]) (*connect.Response[v1.WriteFileResponse], error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.