grpc

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2026 License: Apache-2.0 Imports: 51 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RunServer 

func RunServer(baseURL, webhooksBaseURL, basePath string, encryptor crypto.Encryptor, authService authorization.Authorization, registry *registry.Registry, oidcProvider oidc.Provider, port int)

Types

type BlueprintService 

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

func NewBlueprintService 

func NewBlueprintService(registry *registry.Registry) *BlueprintService

func (*BlueprintService) CreateBlueprint 

func (s *BlueprintService) CreateBlueprint(ctx context.Context, req *pb.CreateBlueprintRequest) (*pb.CreateBlueprintResponse, error)

func (*BlueprintService) DeleteBlueprint 

func (s *BlueprintService) DeleteBlueprint(ctx context.Context, req *pb.DeleteBlueprintRequest) (*pb.DeleteBlueprintResponse, error)

func (*BlueprintService) DescribeBlueprint 

func (s *BlueprintService) DescribeBlueprint(ctx context.Context, req *pb.DescribeBlueprintRequest) (*pb.DescribeBlueprintResponse, error)

func (*BlueprintService) ListBlueprints 

func (s *BlueprintService) ListBlueprints(ctx context.Context, req *pb.ListBlueprintsRequest) (*pb.ListBlueprintsResponse, error)

func (*BlueprintService) UpdateBlueprint 

func (s *BlueprintService) UpdateBlueprint(ctx context.Context, req *pb.UpdateBlueprintRequest) (*pb.UpdateBlueprintResponse, 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, webhookBaseURL string) *CanvasService

func (*CanvasService) CancelExecution added in v0.6.0 

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

func (*CanvasService) CreateCanvas added in v0.6.0 

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

func (*CanvasService) DeleteCanvas added in v0.6.0 

func (s *CanvasService) DeleteCanvas(ctx context.Context, req *pb.DeleteCanvasRequest) (*pb.DeleteCanvasResponse, 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) EmitNodeEvent added in v0.6.0 

func (s *CanvasService) EmitNodeEvent(ctx context.Context, req *pb.EmitNodeEventRequest) (*pb.EmitNodeEventResponse, error)

func (*CanvasService) InvokeNodeExecutionAction added in v0.6.0 

func (s *CanvasService) InvokeNodeExecutionAction(ctx context.Context, req *pb.InvokeNodeExecutionActionRequest) (*pb.InvokeNodeExecutionActionResponse, error)

func (*CanvasService) InvokeNodeTriggerAction added in v0.6.0 

func (s *CanvasService) InvokeNodeTriggerAction(ctx context.Context, req *pb.InvokeNodeTriggerActionRequest) (*pb.InvokeNodeTriggerActionResponse, error)

func (*CanvasService) ListCanvasEvents added in v0.6.0 

func (s *CanvasService) ListCanvasEvents(ctx context.Context, req *pb.ListCanvasEventsRequest) (*pb.ListCanvasEventsResponse, error)

func (*CanvasService) ListCanvases added in v0.6.0 

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

func (*CanvasService) ListChildExecutions added in v0.6.0 

func (s *CanvasService) ListChildExecutions(ctx context.Context, req *pb.ListChildExecutionsRequest) (*pb.ListChildExecutionsResponse, 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) 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) UpdateNodePause added in v0.6.0 

func (s *CanvasService) UpdateNodePause(ctx context.Context, req *pb.UpdateNodePauseRequest) (*pb.UpdateNodePauseResponse, error)

type ComponentService 

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

func NewComponentService 

func NewComponentService(registry *registry.Registry) *ComponentService

func (*ComponentService) DescribeComponent 

func (s *ComponentService) DescribeComponent(ctx context.Context, req *pb.DescribeComponentRequest) (*pb.DescribeComponentResponse, error)

func (*ComponentService) ListComponentActions 

func (s *ComponentService) ListComponentActions(ctx context.Context, req *pb.ListComponentActionsRequest) (*pb.ListComponentActionsResponse, error)

func (*ComponentService) ListComponents 

func (s *ComponentService) ListComponents(ctx context.Context, req *pb.ListComponentsRequest) (*pb.ListComponentsResponse, 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{}

func NewMeService 

func NewMeService() *MeService

func (*MeService) Me 

func (s *MeService) Me(ctx context.Context, req *emptypb.Empty) (*pb.User, 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,
) *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) CreateInvitation 

func (s *OrganizationService) CreateInvitation(ctx context.Context, req *pb.CreateInvitationRequest) (*pb.CreateInvitationResponse, 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 (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) ListInvitations 

func (s *OrganizationService) ListInvitations(ctx context.Context, req *pb.ListInvitationsRequest) (*pb.ListInvitationsResponse, error)

func (*OrganizationService) RemoveInvitation 

func (s *OrganizationService) RemoveInvitation(ctx context.Context, req *pb.RemoveInvitationRequest) (*pb.RemoveInvitationResponse, 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 (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 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) ListUserPermissions 

func (s *UsersService) ListUserPermissions(ctx context.Context, req *pb.ListUserPermissionsRequest) (*pb.ListUserPermissionsResponse, error)

func (*UsersService) ListUserRoles 

func (s *UsersService) ListUserRoles(ctx context.Context, req *pb.ListUserRolesRequest) (*pb.ListUserRolesResponse, error)

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
auth
blueprints
canvases
components
integrations
me
messages
organizations
secrets
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.