grpc

package
v0.28.0 Latest Latest
Warning

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

 Go to latest Published: Jul 9, 2026 License: Apache-2.0 Imports: 58 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 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,
)

Types

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 (s *ActionService) DescribeAction(ctx context.Context, req *pb.DescribeActionRequest) (*pb.DescribeActionResponse, error)

func (*ActionService) ListActions added in v0.18.0 

func (s *ActionService) ListActions(ctx context.Context, req *pb.ListActionsRequest) (*pb.ListActionsResponse, error)

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 (s *AgentsService) DefineAgentOutcome(ctx context.Context, req *pb.DefineAgentOutcomeRequest) (*pb.DefineAgentOutcomeResponse, error)

func (*AgentsService) GetCanvasAgentChat added in v0.21.0 

func (s *AgentsService) GetCanvasAgentChat(ctx context.Context, req *pb.GetCanvasAgentChatRequest) (*pb.GetCanvasAgentChatResponse, error)

func (*AgentsService) InterruptAgentChat added in v0.22.0 

func (s *AgentsService) InterruptAgentChat(ctx context.Context, req *pb.InterruptAgentChatRequest) (*pb.InterruptAgentChatResponse, error)

func (*AgentsService) ListAgentChatMessages added in v0.14.0 

func (s *AgentsService) ListAgentChatMessages(ctx context.Context, req *pb.ListAgentChatMessagesRequest) (*pb.ListAgentChatMessagesResponse, error)

func (*AgentsService) ResetCanvasAgentChat added in v0.28.0 

func (s *AgentsService) ResetCanvasAgentChat(ctx context.Context, req *pb.ResetCanvasAgentChatRequest) (*pb.ResetCanvasAgentChatResponse, error)

func (*AgentsService) SendAgentChatMessage added in v0.21.0 

func (s *AgentsService) SendAgentChatMessage(ctx context.Context, req *pb.SendAgentChatMessageRequest) (*pb.SendAgentChatMessageResponse, error)

type CanvasFolderService added in v0.20.0 

type CanvasFolderService struct{}

func NewCanvasFolderService added in v0.20.0 

func NewCanvasFolderService() *CanvasFolderService

func (*CanvasFolderService) CreateCanvasFolder added in v0.20.0 

func (s *CanvasFolderService) CreateCanvasFolder(ctx context.Context, req *pb.CreateCanvasFolderRequest) (*pb.CreateCanvasFolderResponse, error)

func (*CanvasFolderService) DeleteCanvasFolder added in v0.20.0 

func (s *CanvasFolderService) DeleteCanvasFolder(ctx context.Context, req *pb.DeleteCanvasFolderRequest) (*pb.DeleteCanvasFolderResponse, error)

func (*CanvasFolderService) ListCanvasFolders added in v0.20.0 

func (s *CanvasFolderService) ListCanvasFolders(ctx context.Context, req *pb.ListCanvasFoldersRequest) (*pb.ListCanvasFoldersResponse, error)

func (*CanvasFolderService) UpdateCanvasFolder added in v0.20.0 

func (s *CanvasFolderService) UpdateCanvasFolder(ctx context.Context, req *pb.UpdateCanvasFolderRequest) (*pb.UpdateCanvasFolderResponse, error)

func (*CanvasFolderService) UpdateCanvasFolderPosition added in v0.20.0 

func (s *CanvasFolderService) UpdateCanvasFolderPosition(
	ctx context.Context,
	req *pb.UpdateCanvasFolderPositionRequest,
) (*pb.UpdateCanvasFolderPositionResponse, error)

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,
	gitProvider git.Provider,
	webhookBaseURL string,
	usageService usage.Service,
) *CanvasService

func (*CanvasService) CancelExecution added in v0.6.0 

func (s *CanvasService) CancelExecution(ctx context.Context, req *pb.CancelExecutionRequest) (*pb.CancelExecutionResponse, error)

func (*CanvasService) CommitCanvasStaging added in v0.26.0 

func (s *CanvasService) CommitCanvasStaging(ctx context.Context, req *pb.CommitCanvasStagingRequest) (*pb.CommitCanvasStagingResponse, error)

func (*CanvasService) CreateCanvas added in v0.6.0 

func (s *CanvasService) CreateCanvas(ctx context.Context, req *pb.CreateCanvasRequest) (*pb.CreateCanvasResponse, error)

func (*CanvasService) CreateCanvasMemoryNamespace added in v0.25.0 

func (s *CanvasService) CreateCanvasMemoryNamespace(ctx context.Context, req *pb.CreateCanvasMemoryNamespaceRequest) (*pb.CreateCanvasMemoryNamespaceResponse, error)

func (*CanvasService) DeleteCanvas added in v0.6.0 

func (s *CanvasService) DeleteCanvas(ctx context.Context, req *pb.DeleteCanvasRequest) (*pb.DeleteCanvasResponse, error)

func (*CanvasService) DeleteCanvasMemory added in v0.10.0 

func (s *CanvasService) DeleteCanvasMemory(ctx context.Context, req *pb.DeleteCanvasMemoryRequest) (*pb.DeleteCanvasMemoryResponse, error)

func (*CanvasService) DeleteCanvasStaging added in v0.28.0 

func (s *CanvasService) DeleteCanvasStaging(ctx context.Context, req *pb.DeleteCanvasStagingRequest) (*pb.DeleteCanvasStagingResponse, error)

func (*CanvasService) DeleteNodeQueueItem added in v0.6.0 

func (s *CanvasService) DeleteNodeQueueItem(ctx context.Context, req *pb.DeleteNodeQueueItemRequest) (*pb.DeleteNodeQueueItemResponse, error)

func (*CanvasService) DescribeCanvas added in v0.6.0 

func (s *CanvasService) DescribeCanvas(ctx context.Context, req *pb.DescribeCanvasRequest) (*pb.DescribeCanvasResponse, error)

func (*CanvasService) DescribeCanvasVersion added in v0.11.0 

func (s *CanvasService) DescribeCanvasVersion(ctx context.Context, req *pb.DescribeCanvasVersionRequest) (*pb.DescribeCanvasVersionResponse, error)

func (*CanvasService) DescribeRun added in v0.26.0 

func (s *CanvasService) DescribeRun(ctx context.Context, req *pb.DescribeRunRequest) (*pb.DescribeRunResponse, error)

func (*CanvasService) GetCanvasRepository added in v0.24.0 

func (s *CanvasService) GetCanvasRepository(ctx context.Context, req *pb.GetCanvasRepositoryRequest) (*pb.GetCanvasRepositoryResponse, error)

func (*CanvasService) GetCanvasStaging added in v0.28.0 

func (s *CanvasService) GetCanvasStaging(ctx context.Context, req *pb.GetCanvasStagingRequest) (*pb.GetCanvasStagingResponse, error)

func (*CanvasService) InvokeNodeExecutionHook added in v0.18.0 

func (s *CanvasService) InvokeNodeExecutionHook(ctx context.Context, req *pb.InvokeNodeExecutionHookRequest) (*pb.InvokeNodeExecutionHookResponse, error)

func (*CanvasService) InvokeNodeTriggerHook added in v0.18.0 

func (s *CanvasService) InvokeNodeTriggerHook(ctx context.Context, req *pb.InvokeNodeTriggerHookRequest) (*pb.InvokeNodeTriggerHookResponse, error)

func (*CanvasService) ListCanvasMemories added in v0.10.0 

func (s *CanvasService) ListCanvasMemories(ctx context.Context, req *pb.ListCanvasMemoriesRequest) (*pb.ListCanvasMemoriesResponse, error)

func (*CanvasService) ListCanvasRepositoryFiles added in v0.24.0 

func (s *CanvasService) ListCanvasRepositoryFiles(ctx context.Context, req *pb.ListCanvasRepositoryFilesRequest) (*pb.ListCanvasRepositoryFilesResponse, error)

func (*CanvasService) ListCanvasVersions added in v0.11.0 

func (s *CanvasService) ListCanvasVersions(ctx context.Context, req *pb.ListCanvasVersionsRequest) (*pb.ListCanvasVersionsResponse, error)

func (*CanvasService) ListCanvases added in v0.6.0 

func (s *CanvasService) ListCanvases(ctx context.Context, req *pb.ListCanvasesRequest) (*pb.ListCanvasesResponse, error)

func (*CanvasService) ListEventExecutions added in v0.6.0 

func (s *CanvasService) ListEventExecutions(ctx context.Context, req *pb.ListEventExecutionsRequest) (*pb.ListEventExecutionsResponse, error)

func (*CanvasService) ListNodeEvents added in v0.6.0 

func (s *CanvasService) ListNodeEvents(ctx context.Context, req *pb.ListNodeEventsRequest) (*pb.ListNodeEventsResponse, error)

func (*CanvasService) ListNodeExecutions added in v0.6.0 

func (s *CanvasService) ListNodeExecutions(ctx context.Context, req *pb.ListNodeExecutionsRequest) (*pb.ListNodeExecutionsResponse, error)

func (*CanvasService) ListNodeQueueItems added in v0.6.0 

func (s *CanvasService) ListNodeQueueItems(ctx context.Context, req *pb.ListNodeQueueItemsRequest) (*pb.ListNodeQueueItemsResponse, error)

func (*CanvasService) ListRuns added in v0.21.0 

func (s *CanvasService) ListRuns(ctx context.Context, req *pb.ListRunsRequest) (*pb.ListRunsResponse, error)

func (*CanvasService) PutCanvasStaging added in v0.28.0 

func (s *CanvasService) PutCanvasStaging(ctx context.Context, req *pb.PutCanvasStagingRequest) (*pb.PutCanvasStagingResponse, error)

func (*CanvasService) ReemitTriggerEvent added in v0.21.0 

func (s *CanvasService) ReemitTriggerEvent(ctx context.Context, req *pb.ReemitTriggerEventRequest) (*pb.ReemitTriggerEventResponse, error)

func (*CanvasService) ResolveExecutionErrors added in v0.6.0 

func (s *CanvasService) ResolveExecutionErrors(ctx context.Context, req *pb.ResolveExecutionErrorsRequest) (*pb.ResolveExecutionErrorsResponse, error)

func (*CanvasService) UpdateCanvas added in v0.6.0 

func (s *CanvasService) UpdateCanvas(ctx context.Context, req *pb.UpdateCanvasRequest) (*pb.UpdateCanvasResponse, error)

func (*CanvasService) UpdateCanvasMemoryNamespace added in v0.25.0 

func (s *CanvasService) UpdateCanvasMemoryNamespace(ctx context.Context, req *pb.UpdateCanvasMemoryNamespaceRequest) (*pb.UpdateCanvasMemoryNamespaceResponse, error)

func (*CanvasService) UpdateCanvasPreference added in v0.28.0 

func (s *CanvasService) UpdateCanvasPreference(
	ctx context.Context,
	req *pb.UpdateCanvasPreferenceRequest,
) (*pb.UpdateCanvasPreferenceResponse, error)

type GroupsService 

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

func NewGroupsService 

func NewGroupsService(authService authorization.Authorization) *GroupsService

func (*GroupsService) AddUserToGroup 

func (s *GroupsService) AddUserToGroup(ctx context.Context, req *pb.AddUserToGroupRequest) (*pb.AddUserToGroupResponse, error)

func (*GroupsService) CreateGroup 

func (s *GroupsService) CreateGroup(ctx context.Context, req *pb.CreateGroupRequest) (*pb.CreateGroupResponse, error)

func (*GroupsService) DeleteGroup 

func (s *GroupsService) DeleteGroup(ctx context.Context, req *pb.DeleteGroupRequest) (*pb.DeleteGroupResponse, error)

func (*GroupsService) DescribeGroup 

func (s *GroupsService) DescribeGroup(ctx context.Context, req *pb.DescribeGroupRequest) (*pb.DescribeGroupResponse, error)

func (*GroupsService) ListGroupUsers 

func (s *GroupsService) ListGroupUsers(ctx context.Context, req *pb.ListGroupUsersRequest) (*pb.ListGroupUsersResponse, error)

func (*GroupsService) ListGroups 

func (s *GroupsService) ListGroups(ctx context.Context, req *pb.ListGroupsRequest) (*pb.ListGroupsResponse, error)

func (*GroupsService) RemoveUserFromGroup 

func (s *GroupsService) RemoveUserFromGroup(ctx context.Context, req *pb.RemoveUserFromGroupRequest) (*pb.RemoveUserFromGroupResponse, error)

func (*GroupsService) UpdateGroup 

func (s *GroupsService) UpdateGroup(ctx context.Context, req *pb.UpdateGroupRequest) (*pb.UpdateGroupResponse, error)

type HealthCheckServer 

type HealthCheckServer struct {
	grpc_health_v1.UnimplementedHealthServer
}

func (*HealthCheckServer) Check 

func (h *HealthCheckServer) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*HealthCheckServer) Watch 

func (h *HealthCheckServer) Watch(req *grpc_health_v1.HealthCheckRequest, srv grpc_health_v1.Health_WatchServer) error

type IntegrationService 

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

func NewIntegrationService 

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

func (*IntegrationService) ListIntegrations 

func (s *IntegrationService) ListIntegrations(ctx context.Context, req *pb.ListIntegrationsRequest) (*pb.ListIntegrationsResponse, error)

type MeService 

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

func NewMeService 

func NewMeService(authService authorization.Authorization) *MeService

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)

type OrganizationService 

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

func NewOrganizationService 

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

func (*OrganizationService) CreateIntegration added in v0.5.0 

func (s *OrganizationService) CreateIntegration(ctx context.Context, req *pb.CreateIntegrationRequest) (*pb.CreateIntegrationResponse, error)

func (*OrganizationService) DeleteIntegration added in v0.5.0 

func (s *OrganizationService) DeleteIntegration(ctx context.Context, req *pb.DeleteIntegrationRequest) (*pb.DeleteIntegrationResponse, error)

func (*OrganizationService) DeleteOrganization 

func (s *OrganizationService) DeleteOrganization(ctx context.Context, req *pb.DeleteOrganizationRequest) (*pb.DeleteOrganizationResponse, error)

func (*OrganizationService) DescribeIntegration added in v0.5.0 

func (s *OrganizationService) DescribeIntegration(ctx context.Context, req *pb.DescribeIntegrationRequest) (*pb.DescribeIntegrationResponse, error)

func (*OrganizationService) DescribeOrganization 

func (s *OrganizationService) DescribeOrganization(ctx context.Context, req *pb.DescribeOrganizationRequest) (*pb.DescribeOrganizationResponse, error)

func (*OrganizationService) DescribeUsage added in v0.13.0 

func (s *OrganizationService) DescribeUsage(
	ctx context.Context,
	req *pb.DescribeUsageRequest,
) (*pb.DescribeUsageResponse, error)
func (s *OrganizationService) GetInviteLink(ctx context.Context, req *pb.GetInviteLinkRequest) (*pb.GetInviteLinkResponse, error)

func (*OrganizationService) ListIntegrationResources added in v0.5.0 

func (s *OrganizationService) ListIntegrationResources(ctx context.Context, req *pb.ListIntegrationResourcesRequest) (*pb.ListIntegrationResourcesResponse, error)

func (*OrganizationService) ListIntegrations added in v0.5.0 

func (s *OrganizationService) ListIntegrations(ctx context.Context, req *pb.ListIntegrationsRequest) (*pb.ListIntegrationsResponse, error)

func (*OrganizationService) NextIntegrationSetupStep added in v0.19.0 

func (s *OrganizationService) NextIntegrationSetupStep(ctx context.Context, req *pb.NextIntegrationSetupStepRequest) (*pb.NextIntegrationSetupStepResponse, error)

func (*OrganizationService) PreviousIntegrationSetupStep added in v0.19.0 

func (s *OrganizationService) PreviousIntegrationSetupStep(ctx context.Context, req *pb.PreviousIntegrationSetupStepRequest) (*pb.PreviousIntegrationSetupStepResponse, error)

func (*OrganizationService) RemoveUser 

func (s *OrganizationService) RemoveUser(ctx context.Context, req *pb.RemoveUserRequest) (*pb.RemoveUserResponse, error)
func (s *OrganizationService) ResetInviteLink(ctx context.Context, req *pb.ResetInviteLinkRequest) (*pb.ResetInviteLinkResponse, error)

func (*OrganizationService) UpdateIntegration added in v0.5.0 

func (s *OrganizationService) UpdateIntegration(ctx context.Context, req *pb.UpdateIntegrationRequest) (*pb.UpdateIntegrationResponse, error)

func (*OrganizationService) UpdateIntegrationCapabilities added in v0.19.0 

func (s *OrganizationService) UpdateIntegrationCapabilities(ctx context.Context, req *pb.UpdateIntegrationCapabilitiesRequest) (*pb.UpdateIntegrationCapabilitiesResponse, error)

func (*OrganizationService) UpdateIntegrationProperty added in v0.19.0 

func (s *OrganizationService) UpdateIntegrationProperty(ctx context.Context, req *pb.UpdateIntegrationPropertyRequest) (*pb.UpdateIntegrationPropertyResponse, error)

func (*OrganizationService) UpdateIntegrationSecret added in v0.19.0 

func (s *OrganizationService) UpdateIntegrationSecret(ctx context.Context, req *pb.UpdateIntegrationSecretRequest) (*pb.UpdateIntegrationSecretResponse, error)
func (s *OrganizationService) UpdateInviteLink(ctx context.Context, req *pb.UpdateInviteLinkRequest) (*pb.UpdateInviteLinkResponse, error)

func (*OrganizationService) UpdateOrganization 

func (s *OrganizationService) UpdateOrganization(ctx context.Context, req *pb.UpdateOrganizationRequest) (*pb.UpdateOrganizationResponse, error)

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) *RoleService

func (*RoleService) AssignRole 

func (s *RoleService) AssignRole(ctx context.Context, req *pb.AssignRoleRequest) (*pb.AssignRoleResponse, error)

func (*RoleService) CreateRole 

func (s *RoleService) CreateRole(ctx context.Context, req *pb.CreateRoleRequest) (*pb.CreateRoleResponse, error)

func (*RoleService) DeleteRole 

func (s *RoleService) DeleteRole(ctx context.Context, req *pb.DeleteRoleRequest) (*pb.DeleteRoleResponse, error)

func (*RoleService) DescribeRole 

func (s *RoleService) DescribeRole(ctx context.Context, req *pb.DescribeRoleRequest) (*pb.DescribeRoleResponse, error)

func (*RoleService) ListRoles 

func (s *RoleService) ListRoles(ctx context.Context, req *pb.ListRolesRequest) (*pb.ListRolesResponse, error)

func (*RoleService) UpdateRole 

func (s *RoleService) UpdateRole(ctx context.Context, req *pb.UpdateRoleRequest) (*pb.UpdateRoleResponse, error)

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 (s *SecretService) CreateSecret(ctx context.Context, req *pb.CreateSecretRequest) (*pb.CreateSecretResponse, error)

func (*SecretService) DeleteSecret 

func (s *SecretService) DeleteSecret(ctx context.Context, req *pb.DeleteSecretRequest) (*pb.DeleteSecretResponse, error)

func (*SecretService) DeleteSecretKey added in v0.7.0 

func (s *SecretService) DeleteSecretKey(ctx context.Context, req *pb.DeleteSecretKeyRequest) (*pb.DeleteSecretKeyResponse, error)

func (*SecretService) DescribeSecret 

func (s *SecretService) DescribeSecret(ctx context.Context, req *pb.DescribeSecretRequest) (*pb.DescribeSecretResponse, error)

func (*SecretService) ListSecrets 

func (s *SecretService) ListSecrets(ctx context.Context, req *pb.ListSecretsRequest) (*pb.ListSecretsResponse, error)

func (*SecretService) SetSecretKey added in v0.7.0 

func (s *SecretService) SetSecretKey(ctx context.Context, req *pb.SetSecretKeyRequest) (*pb.SetSecretKeyResponse, error)

func (*SecretService) UpdateSecret 

func (s *SecretService) UpdateSecret(ctx context.Context, req *pb.UpdateSecretRequest) (*pb.UpdateSecretResponse, error)

func (*SecretService) UpdateSecretName added in v0.7.0 

func (s *SecretService) UpdateSecretName(ctx context.Context, req *pb.UpdateSecretNameRequest) (*pb.UpdateSecretNameResponse, error)

type ServiceAccountsService added in v0.9.0 

type ServiceAccountsService struct {
	pb.UnimplementedServiceAccountsServer
	// contains filtered or unexported fields
}

func NewServiceAccountsService added in v0.9.0 

func NewServiceAccountsService(authService authorization.Authorization) *ServiceAccountsService

func (*ServiceAccountsService) CreateServiceAccount added in v0.9.0 

func (s *ServiceAccountsService) CreateServiceAccount(ctx context.Context, req *pb.CreateServiceAccountRequest) (*pb.CreateServiceAccountResponse, error)

func (*ServiceAccountsService) DeleteServiceAccount added in v0.9.0 

func (s *ServiceAccountsService) DeleteServiceAccount(ctx context.Context, req *pb.DeleteServiceAccountRequest) (*pb.DeleteServiceAccountResponse, error)

func (*ServiceAccountsService) DescribeServiceAccount added in v0.9.0 

func (s *ServiceAccountsService) DescribeServiceAccount(ctx context.Context, req *pb.DescribeServiceAccountRequest) (*pb.DescribeServiceAccountResponse, error)

func (*ServiceAccountsService) ListServiceAccounts added in v0.9.0 

func (s *ServiceAccountsService) ListServiceAccounts(ctx context.Context, req *pb.ListServiceAccountsRequest) (*pb.ListServiceAccountsResponse, error)

func (*ServiceAccountsService) RegenerateServiceAccountToken added in v0.9.0 

func (s *ServiceAccountsService) RegenerateServiceAccountToken(ctx context.Context, req *pb.RegenerateServiceAccountTokenRequest) (*pb.RegenerateServiceAccountTokenResponse, error)

func (*ServiceAccountsService) UpdateServiceAccount added in v0.9.0 

func (s *ServiceAccountsService) UpdateServiceAccount(ctx context.Context, req *pb.UpdateServiceAccountRequest) (*pb.UpdateServiceAccountResponse, error)

type Services added in v0.26.0 

type Services struct {
	Users           pbUsers.UsersServer
	Groups          pbGroups.GroupsServer
	Roles           pbRoles.RolesServer
	Organizations   pbOrganizations.OrganizationsServer
	Integrations    pbIntegrations.IntegrationsServer
	Secrets         pbSecrets.SecretsServer
	Me              pbMe.MeServer
	Actions         pbActions.ActionsServer
	Triggers        pbTriggers.TriggersServer
	Widgets         pbWidgets.WidgetsServer
	Canvases        pbCanvases.CanvasesServer
	CanvasFolders   pbCanvasFolders.CanvasFoldersServer
	ServiceAccounts pbServiceAccounts.ServiceAccountsServer
	Agents          pbAgents.AgentsServer
}

func NewServices added in v0.26.0 

func NewServices(cfg ServicesConfig) (*Services, error)

type ServicesConfig added in v0.26.0 

type ServicesConfig struct {
	BaseURL         string
	WebhooksBaseURL string
	Encryptor       crypto.Encryptor
	AuthService     authorization.Authorization
	Registry        *registry.Registry
	OIDCProvider    oidc.Provider
	GitProvider     git.Provider
	AgentService    agentsActions.AgentsService
	UsageService    usage.Service
}

type TriggerService 

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

func NewTriggerService 

func NewTriggerService(registry *registry.Registry) *TriggerService

func (*TriggerService) DescribeTrigger 

func (s *TriggerService) DescribeTrigger(ctx context.Context, req *pb.DescribeTriggerRequest) (*pb.DescribeTriggerResponse, error)

func (*TriggerService) ListTriggers 

func (s *TriggerService) ListTriggers(ctx context.Context, req *pb.ListTriggersRequest) (*pb.ListTriggersResponse, error)

type UsersService 

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

func NewUsersService 

func NewUsersService(authService authorization.Authorization) *UsersService

func (*UsersService) ListUsers 

func (s *UsersService) ListUsers(ctx context.Context, req *pb.ListUsersRequest) (*pb.ListUsersResponse, error)

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 (s *WidgetService) DescribeWidget(ctx context.Context, req *pb.DescribeWidgetRequest) (*pb.DescribeWidgetResponse, error)

func (*WidgetService) ListWidgets added in v0.0.18 

func (s *WidgetService) ListWidgets(ctx context.Context, req *pb.ListWidgetsRequest) (*pb.ListWidgetsResponse, error)

Source Files

View all Source files

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.
auth
canvases
canvases/changesets
canvases/layout
canvasfolders
integrations
me
messages
organizations
secrets
serviceaccounts
triggers
widgets

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.