grpc

package
v0.22.0 Latest Latest
Warning

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

Go to latest
Published: May 25, 2026 License: Apache-2.0 Imports: 60 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,
	jwtSigner *jwt.Signer,
	authService authorization.Authorization,
	registry *registry.Registry,
	oidcProvider oidc.Provider,
	agentService agentsActions.AgentsService,
	port int,
)

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 (*ActionService) ListActions added in v0.18.0

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) SendAgentChatMessage added in v0.21.0

type BlueprintService

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

func NewBlueprintService

func NewBlueprintService(registry *registry.Registry) *BlueprintService

func (*BlueprintService) CreateBlueprint

func (*BlueprintService) DeleteBlueprint

func (*BlueprintService) DescribeBlueprint

func (*BlueprintService) ListBlueprints

func (*BlueprintService) UpdateBlueprint

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 (*CanvasFolderService) DeleteCanvasFolder added in v0.20.0

func (*CanvasFolderService) ListCanvasFolders added in v0.20.0

func (*CanvasFolderService) UpdateCanvasFolder added in v0.20.0

func (*CanvasFolderService) UpdateCanvasFolderPosition added in v0.20.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,
	usageService usage.Service,
) *CanvasService

func (*CanvasService) ActOnCanvasChangeRequest added in v0.12.0

func (*CanvasService) ApplyCanvasVersionChangeset added in v0.17.0

func (*CanvasService) CancelExecution added in v0.6.0

func (*CanvasService) CreateCanvas added in v0.6.0

func (*CanvasService) CreateCanvasChangeRequest added in v0.11.0

func (*CanvasService) CreateCanvasVersion added in v0.11.0

func (*CanvasService) DeleteCanvas added in v0.6.0

func (*CanvasService) DeleteCanvasMemory added in v0.10.0

func (*CanvasService) DeleteCanvasVersion added in v0.17.0

func (*CanvasService) DeleteNodeQueueItem added in v0.6.0

func (*CanvasService) DescribeCanvas added in v0.6.0

func (*CanvasService) DescribeCanvasChangeRequest added in v0.11.0

func (*CanvasService) DescribeCanvasVersion added in v0.11.0

func (*CanvasService) GetCanvasDashboard added in v0.21.0

func (*CanvasService) InvokeNodeExecutionHook added in v0.18.0

func (*CanvasService) InvokeNodeTriggerHook added in v0.18.0

func (*CanvasService) ListCanvasChangeRequests added in v0.11.0

func (*CanvasService) ListCanvasEvents added in v0.6.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) ListChildExecutions 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) PublishCanvasVersion added in v0.17.0

func (*CanvasService) ReemitTriggerEvent added in v0.21.0

func (*CanvasService) ResolveCanvasChangeRequest added in v0.12.0

func (*CanvasService) ResolveExecutionErrors added in v0.6.0

func (*CanvasService) UpdateCanvas added in v0.6.0

func (*CanvasService) UpdateCanvasDashboard added in v0.21.0

func (*CanvasService) UpdateCanvasVersion added in v0.11.0

func (*CanvasService) UpdateNodePause added in v0.6.0

func (*CanvasService) ValidateCanvasVersionChangeset added in v0.17.0

type GroupsService

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

func NewGroupsService

func NewGroupsService(authService authorization.Authorization) *GroupsService

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) 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 (*OrganizationService) CreateInvitation

func (*OrganizationService) DeleteIntegration added in v0.5.0

func (*OrganizationService) DeleteOrganization

func (*OrganizationService) DescribeIntegration added in v0.5.0

func (*OrganizationService) DescribeOrganization

func (*OrganizationService) DescribeUsage added in v0.13.0

func (*OrganizationService) ListIntegrationResources added in v0.5.0

func (*OrganizationService) ListIntegrations added in v0.5.0

func (*OrganizationService) ListInvitations

func (*OrganizationService) NextIntegrationSetupStep added in v0.19.0

func (*OrganizationService) PreviousIntegrationSetupStep added in v0.19.0

func (*OrganizationService) RemoveInvitation

func (*OrganizationService) RemoveUser

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

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 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 (*ServiceAccountsService) DeleteServiceAccount added in v0.9.0

func (*ServiceAccountsService) DescribeServiceAccount added in v0.9.0

func (*ServiceAccountsService) ListServiceAccounts added in v0.9.0

func (*ServiceAccountsService) RegenerateServiceAccountToken added in v0.9.0

func (*ServiceAccountsService) UpdateServiceAccount added in v0.9.0

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