grpc

package
v1.0.0-rc2 Latest Latest
Warning

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

Go to latest
Published: Oct 19, 2026 License: Apache-2.0 Imports: 65 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GatewayAuthorizationMiddleware added in v0.26.0

func GatewayAuthorizationMiddleware(
	authorizer *authorization.GatewayAuthorizer,
) runtime.Middleware

func GatewayRecoveryMiddleware added in v0.26.0

func GatewayRecoveryMiddleware() runtime.Middleware

func ReportableHTTPStatus

func ReportableHTTPStatus(httpStatus int) bool

ReportableHTTPStatus reports whether a response status is a server error worth forwarding to the error tracker.

Only true server errors (5xx) qualify. Some 5xx codes mean the client sent an unsupported request, not that the server failed:

  • 501 Not Implemented is returned by grpc-gateway when a path exists but the HTTP method has no mapping (for example POST /api/v1/triggers/start when only GET /api/v1/triggers/{name} is defined). Those requests should not create issues.
  • 505 HTTP Version Not Supported is likewise a client-caused mismatch.

func SanitizeError added in v0.27.0

func SanitizeError(requestCtx context.Context, err error) error

func SanitizedGatewayErrorHandler added in v0.26.0

func SanitizedGatewayErrorHandler(
	ctx context.Context,
	mux *runtime.ServeMux,
	marshaler runtime.Marshaler,
	w http.ResponseWriter,
	r *http.Request,
	err error,
)

func ServerErrorAlreadyReported

func ServerErrorAlreadyReported(ctx context.Context) bool

ServerErrorAlreadyReported reports whether a panic was already sent to the error tracker.

func SetHTTPHandlerServerError

func SetHTTPHandlerServerError(ctx context.Context, err error, tags map[string]string)

SetHTTPHandlerServerError records a raw handler error for Sentry when the response status is already known (non-gateway handlers such as webhooks).

func WithServerErrorReport

func WithServerErrorReport(r *http.Request) *http.Request

WithServerErrorReport attaches an empty holder to the request. Later writes stay visible after the handler returns.

Types

type APIKeysService added in v0.30.0

type APIKeysService struct {
	pb.UnimplementedApiKeysServer
	// contains filtered or unexported fields
}

func NewAPIKeysService added in v0.30.0

func NewAPIKeysService(authService authorization.Authorization) *APIKeysService

func (*APIKeysService) CreateAPIKey added in v0.30.0

func (*APIKeysService) DeleteAPIKey added in v0.30.0

func (*APIKeysService) DescribeAPIKey added in v0.30.0

func (*APIKeysService) ListAPIKeys added in v0.30.0

func (*APIKeysService) RegenerateAPIKeyToken added in v0.30.0

func (*APIKeysService) UpdateAPIKey added in v0.30.0

type ActionService added in v0.18.0

type ActionService struct {
	// contains filtered or unexported fields
}

func NewActionService added in v0.18.0

func NewActionService(registry *registry.Registry) *ActionService

func (*ActionService) DescribeAction added in v0.18.0

func (*ActionService) ListActions added in v0.18.0

type AdminRunnersService

type AdminRunnersService struct {
	pb.UnimplementedRunnersServer
	// contains filtered or unexported fields
}

func NewAdminRunnersService

func NewAdminRunnersService(actions *runneractions.Service) *AdminRunnersService

func (*AdminRunnersService) CreateFleet

func (*AdminRunnersService) CreateRunner

func (*AdminRunnersService) DeleteRunner

func (*AdminRunnersService) DescribeFleet

func (*AdminRunnersService) DescribeRunner

func (*AdminRunnersService) GetFleetCapacity

func (*AdminRunnersService) ListFleetTasks

func (*AdminRunnersService) ListFleets

func (*AdminRunnersService) ListRunners

func (*AdminRunnersService) UpdateFleet

type AgentsService added in v0.14.0

type AgentsService struct {
	pb.UnimplementedAgentsServer
	// contains filtered or unexported fields
}

func NewAgentsService added in v0.14.0

func NewAgentsService(service agentsActions.AgentsService) *AgentsService

func (*AgentsService) DefineAgentOutcome added in v0.22.0

func (*AgentsService) GetCanvasAgentChat added in v0.21.0

func (*AgentsService) InterruptAgentChat added in v0.22.0

func (*AgentsService) ListAgentChatMessages added in v0.14.0

func (*AgentsService) ResetCanvasAgentChat added in v0.28.0

func (*AgentsService) SendAgentChatMessage added in v0.21.0

type CanvasService added in v0.6.0

type CanvasService struct {
	// contains filtered or unexported fields
}

func NewCanvasService added in v0.6.0

func NewCanvasService(
	authService authorization.Authorization,
	registry *registry.Registry,
	encryptor crypto.Encryptor,
	webhookBaseURL string,
) *CanvasService

func (*CanvasService) CancelExecution added in v0.6.0

func (*CanvasService) CancelRun added in v0.30.0

func (*CanvasService) CommitCanvasStaging added in v0.26.0

func (*CanvasService) CreateCanvas added in v0.6.0

func (*CanvasService) CreateCanvasMemoryNamespace added in v0.25.0

func (*CanvasService) DeleteCanvas added in v0.6.0

func (*CanvasService) DeleteCanvasMemory added in v0.10.0

func (*CanvasService) DeleteCanvasStaging added in v0.28.0

func (*CanvasService) DeleteNodeQueueItem added in v0.6.0

func (*CanvasService) DescribeCanvas added in v0.6.0

func (*CanvasService) DescribeCanvasVersion added in v0.11.0

func (*CanvasService) DescribeRun added in v0.26.0

func (*CanvasService) GetCanvasStaging added in v0.28.0

func (*CanvasService) InvokeNodeExecutionHook added in v0.18.0

func (*CanvasService) InvokeNodeTriggerHook added in v0.18.0

func (*CanvasService) ListCanvasMemories added in v0.10.0

func (*CanvasService) ListCanvasVersions added in v0.11.0

func (*CanvasService) ListCanvases added in v0.6.0

func (*CanvasService) ListEventExecutions added in v0.6.0

func (*CanvasService) ListNodeEvents added in v0.6.0

func (*CanvasService) ListNodeExecutions added in v0.6.0

func (*CanvasService) ListNodeQueueItems added in v0.6.0

func (*CanvasService) ListRuns added in v0.21.0

func (*CanvasService) PutCanvasStaging added in v0.28.0

func (*CanvasService) ReemitTriggerEvent added in v0.21.0

func (*CanvasService) ResolveExecutionErrors added in v0.6.0

func (*CanvasService) UpdateCanvas added in v0.6.0

func (*CanvasService) UpdateCanvasMemoryNamespace added in v0.25.0

func (*CanvasService) UpdateCanvasPreference added in v0.28.0

type FactoryService

type FactoryService struct {
	pb.UnimplementedFactoriesServer
	// contains filtered or unexported fields
}

func NewFactoryService

func NewFactoryService(
	reg *registry.Registry,
	encryptor crypto.Encryptor,
	authService authorization.Authorization,
	webhookBaseURL string,
) *FactoryService

func (*FactoryService) AddWorkOrderComment

func (*FactoryService) CloseWorkOrder

func (*FactoryService) CreateFactory

func (*FactoryService) CreateFactoryAutomation

func (*FactoryService) CreateFactoryIntake

func (*FactoryService) CreateFactoryLine

func (*FactoryService) CreateFactoryPullRequest

func (*FactoryService) CreateWorkOrder

func (*FactoryService) CreateWorkOrderArtifact

func (*FactoryService) DeleteFactory

func (*FactoryService) DeleteFactoryAutomation

func (*FactoryService) DeleteFactoryIntake

func (*FactoryService) DescribeFactory

func (*FactoryService) DescribeFactoryUsage

func (*FactoryService) DescribeFactoryVelocity

func (*FactoryService) DescribePlanningSession

func (*FactoryService) DescribeWorkOrder

func (*FactoryService) DispatchWorkOrder

func (*FactoryService) EndPlanningSession

func (*FactoryService) ImportFactoryIntakeItem

func (*FactoryService) ListFactories

func (*FactoryService) ListFactoryAutomations

func (*FactoryService) ListFactoryIntakeRuns

func (*FactoryService) ListFactoryIntakes

func (*FactoryService) ListFactoryLLMModels

func (*FactoryService) ListFactoryMCPClients

func (*FactoryService) ListWorkOrderArtifacts

func (*FactoryService) ListWorkOrderEvents

func (*FactoryService) ListWorkOrders

func (*FactoryService) MergeFactoryPullRequest

func (*FactoryService) PreviewFactorySchedule

func (*FactoryService) RefreshBacklog

func (*FactoryService) RevokeFactoryMCPClient

func (*FactoryService) SearchFactoryIntakeItems

func (*FactoryService) SendWorkOrderToBacklog

func (*FactoryService) SetFactoryVisibility

func (*FactoryService) SwitchFactoryModelSource

func (*FactoryService) SyncFactoryVelocity

func (*FactoryService) UpdateFactory

func (*FactoryService) UpdateFactoryIntake

func (*FactoryService) UpdateFactoryLLMModels

func (*FactoryService) UpdateFactoryLine

func (*FactoryService) UpdateFactoryOnboarding

func (*FactoryService) UpdateFactoryPullRequest

func (*FactoryService) UpdateFactoryRepository

func (*FactoryService) UpdateWorkOrder

func (*FactoryService) UpdateWorkOrderAssignees

func (*FactoryService) UpdateWorkOrderStatus

type FilesService

type FilesService struct {
	pb.UnimplementedFilesServer
}

func (*FilesService) CreateFactoryFile

func (*FilesService) CreateWorkOrderFile

func (*FilesService) ListFactoryFiles

func (*FilesService) ListWorkOrderFiles

type GroupsService

type GroupsService struct {
	pb.UnimplementedGroupsServer
	// contains filtered or unexported fields
}

func NewGroupsService

func NewGroupsService(authService authorization.Authorization, registry *enterprise.Registry) (*GroupsService, error)

func (*GroupsService) AddUserToGroup

func (*GroupsService) CreateGroup

func (*GroupsService) DeleteGroup

func (*GroupsService) DescribeGroup

func (*GroupsService) ListGroupUsers

func (*GroupsService) ListGroups

func (*GroupsService) RemoveUserFromGroup

func (*GroupsService) UpdateGroup

type IntegrationService

type IntegrationService struct {
	// contains filtered or unexported fields
}

func NewIntegrationService

func NewIntegrationService(encryptor crypto.Encryptor, registry *registry.Registry) *IntegrationService

func (*IntegrationService) ListIntegrations

type MeService

type MeService struct {
	// contains filtered or unexported fields
}

func NewMeService

func NewMeService(authService authorization.Authorization) *MeService

func (*MeService) CreateToken

func (s *MeService) CreateToken(ctx context.Context, req *pb.CreateTokenRequest) (*pb.CreateTokenResponse, error)

func (*MeService) DescribeLastLocation

func (*MeService) ListTokens

func (s *MeService) ListTokens(ctx context.Context, req *pb.ListTokensRequest) (*pb.ListTokensResponse, error)

func (*MeService) Me

func (s *MeService) Me(ctx context.Context, req *pb.MeRequest) (*pb.MeResponse, error)

func (*MeService) RegenerateToken

func (s *MeService) RegenerateToken(ctx context.Context, req *emptypb.Empty) (*pb.RegenerateTokenResponse, error)

func (*MeService) RevokeToken

func (s *MeService) RevokeToken(ctx context.Context, req *pb.RevokeTokenRequest) (*pb.RevokeTokenResponse, error)

func (*MeService) SaveLastLocation

type NotedServerError

type NotedServerError struct {
	Cause           error
	Source          error
	Tags            map[string]string
	OmitRequestBody bool
}

NotedServerError is a server-error cause kept for the error tracker and the access log. Source is the original handler error, when one was present.

func NotedServerErrorFrom

func NotedServerErrorFrom(ctx context.Context) (NotedServerError, bool)

NotedServerErrorFrom returns the cause stored for this request.

type OrganizationService

type OrganizationService struct {
	pb.UnimplementedOrganizationsServer
	// contains filtered or unexported fields
}

func NewOrganizationService

func NewOrganizationService(
	authorizationService authorization.Authorization,
	registry *registry.Registry,
	oidcProvider oidc.Provider,
	baseURL string,
	webhooksBaseURL string,
) *OrganizationService
func (s *OrganizationService) AcceptInviteLink(ctx context.Context, req *pb.InviteLink) (*structpb.Struct, error)

func (*OrganizationService) CancelOrganizationSubscription

func (*OrganizationService) CreateBillingPortalSession

func (*OrganizationService) CreateBusinessCheckout

func (*OrganizationService) CreateHostedCreditCheckout

func (*OrganizationService) CreateIntegration added in v0.5.0

func (*OrganizationService) DeleteIntegration added in v0.5.0

func (*OrganizationService) DeleteOrganization

func (*OrganizationService) DescribeIntegration added in v0.5.0

func (*OrganizationService) DescribeOrganization

func (*OrganizationService) DescribeOrganizationBilling

func (*OrganizationService) ListBYOKLLMModels

func (*OrganizationService) ListHostedCreditProducts

func (*OrganizationService) ListHostedLLMModels

func (*OrganizationService) ListIntegrationResources added in v0.5.0

func (*OrganizationService) ListIntegrations added in v0.5.0

func (*OrganizationService) ListOrganizationCreditGrants

func (*OrganizationService) ListSelectableLLMModels

func (*OrganizationService) NextIntegrationSetupStep added in v0.19.0

func (*OrganizationService) PreviousIntegrationSetupStep added in v0.19.0

func (*OrganizationService) RemoveUser

func (*OrganizationService) ResumeOrganizationSubscription

func (*OrganizationService) SetUserOwner

func (*OrganizationService) SyncOrganizationBilling

func (*OrganizationService) UpdateBYOKLLMModels

func (*OrganizationService) UpdateIntegration added in v0.5.0

func (*OrganizationService) UpdateIntegrationCapabilities added in v0.19.0

func (*OrganizationService) UpdateIntegrationProperty added in v0.19.0

func (*OrganizationService) UpdateIntegrationSecret added in v0.19.0

func (*OrganizationService) UpdateOrganization

type QueryParser added in v0.7.0

type QueryParser struct{}

func (*QueryParser) Parse added in v0.7.0

func (p *QueryParser) Parse(target proto.Message, values url.Values, filter *utilities.DoubleArray) error

type RoleService

type RoleService struct {
	pb.UnimplementedRolesServer
	// contains filtered or unexported fields
}

func NewRoleService

func NewRoleService(
	authService authorization.Authorization,
	entitlements licensing.Entitlements,
	registry *enterprise.Registry,
) (*RoleService, error)

func (*RoleService) AssignRole

func (*RoleService) CreateRole

func (*RoleService) DeleteRole

func (*RoleService) DescribeRole

func (*RoleService) ListRoles

func (*RoleService) UpdateRole

type SecretService

type SecretService struct {
	// contains filtered or unexported fields
}

func NewSecretService

func NewSecretService(encryptor crypto.Encryptor, authService authorization.Authorization) *SecretService

func (*SecretService) CreateSecret

func (*SecretService) DeleteSecret

func (*SecretService) DeleteSecretKey added in v0.7.0

func (*SecretService) DescribeSecret

func (*SecretService) ListSecrets

func (*SecretService) SetSecretKey added in v0.7.0

func (*SecretService) UpdateSecret

func (*SecretService) UpdateSecretName added in v0.7.0

type ServicesConfig added in v0.26.0

type ServicesConfig struct {
	BaseURL          string
	WebhooksBaseURL  string
	RunnerAPIBaseURL string
	Encryptor        crypto.Encryptor
	AuthService      authorization.Authorization
	Registry         *registry.Registry
	OIDCProvider     oidc.Provider
	AgentService     agentsActions.AgentsService
	JWTSigner        *jwt.Signer

	// Entitlements defaults to Community mode. Enterprise defaults to a
	// registry whose Community implementations refuse every operation.
	Entitlements licensing.Entitlements
	Enterprise   *enterprise.Registry
}

type TriggerService

type TriggerService struct {
	// contains filtered or unexported fields
}

func NewTriggerService

func NewTriggerService(registry *registry.Registry) *TriggerService

func (*TriggerService) DescribeTrigger

func (*TriggerService) ListTriggers

type UsersService

type UsersService struct {
	pb.UnimplementedUsersServer
	// contains filtered or unexported fields
}

func NewUsersService

func NewUsersService(authService authorization.Authorization) *UsersService

func (*UsersService) ListUsers

type WidgetService added in v0.0.18

type WidgetService struct {
	// contains filtered or unexported fields
}

func NewWidgetService added in v0.0.18

func NewWidgetService(registry *registry.Registry) *WidgetService

func (*WidgetService) DescribeWidget added in v0.0.18

func (*WidgetService) ListWidgets added in v0.0.18

Directories

Path Synopsis
agents
Package agents implements the gRPC handlers for the public Agents service.
Package agents implements the gRPC handlers for the public Agents service.
me

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL