grpc

package
v0.0.17 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2025 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RunServer 

func RunServer(baseURL string, encryptor crypto.Encryptor, authService authorization.Authorization, registry *registry.Registry, port int)

Types

type ApplicationService 

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

func NewApplicationService 

func NewApplicationService(encryptor crypto.Encryptor, registry *registry.Registry) *ApplicationService

func (*ApplicationService) ListApplications 

func (s *ApplicationService) ListApplications(ctx context.Context, req *pb.ListApplicationsRequest) (*pb.ListApplicationsResponse, error)

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 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, authService authorization.Authorization, registry *registry.Registry) *IntegrationService

func (*IntegrationService) CreateIntegration 

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

func (*IntegrationService) DescribeIntegration 

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

func (*IntegrationService) ListIntegrations 

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

func (*IntegrationService) ListResources 

func (s *IntegrationService) ListResources(ctx context.Context, req *pb.ListResourcesRequest) (*pb.ListResourcesResponse, error)

func (*IntegrationService) UpdateIntegration 

func (s *IntegrationService) UpdateIntegration(ctx context.Context, req *pb.UpdateIntegrationRequest) (*pb.UpdateIntegrationResponse, 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,
	baseURL string,
) *OrganizationService

func (*OrganizationService) CreateInvitation 

func (s *OrganizationService) CreateInvitation(ctx context.Context, req *pb.CreateInvitationRequest) (*pb.CreateInvitationResponse, error)

func (*OrganizationService) DeleteOrganization 

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

func (*OrganizationService) DescribeApplication 

func (s *OrganizationService) DescribeApplication(ctx context.Context, req *pb.DescribeApplicationRequest) (*pb.DescribeApplicationResponse, error)

func (*OrganizationService) DescribeOrganization 

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

func (*OrganizationService) InstallApplication 

func (s *OrganizationService) InstallApplication(ctx context.Context, req *pb.InstallApplicationRequest) (*pb.InstallApplicationResponse, error)

func (*OrganizationService) ListApplications 

func (s *OrganizationService) ListApplications(ctx context.Context, req *pb.ListApplicationsRequest) (*pb.ListApplicationsResponse, 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 (*OrganizationService) UninstallApplication 

func (s *OrganizationService) UninstallApplication(ctx context.Context, req *pb.UninstallApplicationRequest) (*pb.UninstallApplicationResponse, error)

func (*OrganizationService) UpdateApplication 

func (s *OrganizationService) UpdateApplication(ctx context.Context, req *pb.UpdateApplicationRequest) (*pb.UpdateApplicationResponse, error)

func (*OrganizationService) UpdateOrganization 

func (s *OrganizationService) UpdateOrganization(ctx context.Context, req *pb.UpdateOrganizationRequest) (*pb.UpdateOrganizationResponse, 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) 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) UpdateSecret 

func (s *SecretService) UpdateSecret(ctx context.Context, req *pb.UpdateSecretRequest) (*pb.UpdateSecretResponse, 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 WorkflowService 

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

func NewWorkflowService 

func NewWorkflowService(authService authorization.Authorization, registry *registry.Registry, encryptor crypto.Encryptor) *WorkflowService

func (*WorkflowService) CancelExecution 

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

func (*WorkflowService) CreateWorkflow 

func (s *WorkflowService) CreateWorkflow(ctx context.Context, req *pb.CreateWorkflowRequest) (*pb.CreateWorkflowResponse, error)

func (*WorkflowService) DeleteNodeQueueItem 

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

func (*WorkflowService) DeleteWorkflow 

func (s *WorkflowService) DeleteWorkflow(ctx context.Context, req *pb.DeleteWorkflowRequest) (*pb.DeleteWorkflowResponse, error)

func (*WorkflowService) DescribeWorkflow 

func (s *WorkflowService) DescribeWorkflow(ctx context.Context, req *pb.DescribeWorkflowRequest) (*pb.DescribeWorkflowResponse, error)

func (*WorkflowService) EmitNodeEvent 

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

func (*WorkflowService) InvokeNodeExecutionAction 

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

func (*WorkflowService) ListChildExecutions 

func (s *WorkflowService) ListChildExecutions(ctx context.Context, req *pb.ListChildExecutionsRequest) (*pb.ListChildExecutionsResponse, error)

func (*WorkflowService) ListEventExecutions 

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

func (*WorkflowService) ListNodeEvents 

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

func (*WorkflowService) ListNodeExecutions 

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

func (*WorkflowService) ListNodeQueueItems 

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

func (*WorkflowService) ListWorkflowEvents 

func (s *WorkflowService) ListWorkflowEvents(ctx context.Context, req *pb.ListWorkflowEventsRequest) (*pb.ListWorkflowEventsResponse, error)

func (*WorkflowService) ListWorkflows 

func (s *WorkflowService) ListWorkflows(ctx context.Context, req *pb.ListWorkflowsRequest) (*pb.ListWorkflowsResponse, error)

func (*WorkflowService) UpdateWorkflow 

func (s *WorkflowService) UpdateWorkflow(ctx context.Context, req *pb.UpdateWorkflowRequest) (*pb.UpdateWorkflowResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
applications
auth
blueprints
components
integrations
me
messages
organizations
secrets
triggers
workflows

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.