activities

package
v0.0.0-...-4ae6852 Latest Latest
Warning

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

Go to latest
Published: Oct 25, 2025 License: AGPL-3.0 Imports: 51 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CollectPlatformUsageMetrics

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

func NewCollectPlatformUsageMetrics

func NewCollectPlatformUsageMetrics(logger *slog.Logger, db *pgxpool.Pool) *CollectPlatformUsageMetrics

func (*CollectPlatformUsageMetrics) Do

type CustomDomainIngress

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

func NewCustomDomainIngress

func NewCustomDomainIngress(logger *slog.Logger, db *pgxpool.Pool, k8sClient *k8s.KubernetesClients) *CustomDomainIngress

func (*CustomDomainIngress) Do

type CustomDomainIngressAction

type CustomDomainIngressAction string
const (
	CustomDomainIngressActionSetup  CustomDomainIngressAction = "setup"
	CustomDomainIngressActionDelete CustomDomainIngressAction = "delete"
)

type CustomDomainIngressArgs

type CustomDomainIngressArgs struct {
	OrgID  string
	Domain string
	Action CustomDomainIngressAction
}

type DeployFunctionRunners

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

func NewDeployFunctionRunners

func NewDeployFunctionRunners(
	logger *slog.Logger,
	db *pgxpool.Pool,
	deployer functions.Deployer,
	defaultVersion functions.RunnerVersion,
	enc *encryption.Client,
) *DeployFunctionRunners

func (*DeployFunctionRunners) Do

type DeployFunctionRunnersRequest

type DeployFunctionRunnersRequest struct {
	ProjectID    uuid.UUID
	DeploymentID uuid.UUID
}

type FirePlatformUsageMetrics

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

func NewFirePlatformUsageMetrics

func NewFirePlatformUsageMetrics(logger *slog.Logger, billingTracker billing.Tracker) *FirePlatformUsageMetrics

func (*FirePlatformUsageMetrics) Do

type FreeTierReportingUsageMetrics

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

func NewFreeTierReportingMetrics

func NewFreeTierReportingMetrics(logger *slog.Logger, db *pgxpool.Pool, billingRepository billing.Repository, posthogClient *posthog.Posthog) *FreeTierReportingUsageMetrics

func (*FreeTierReportingUsageMetrics) Do

type GetAllOrganizations

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

func NewGetAllOrganizations

func NewGetAllOrganizations(logger *slog.Logger, db *pgxpool.Pool) *GetAllOrganizations

func (*GetAllOrganizations) Do

type GetSlackProjectContext

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

func NewSlackProjectContextActivity

func NewSlackProjectContextActivity(logger *slog.Logger, db *pgxpool.Pool, client *client.SlackClient) *GetSlackProjectContext

func (*GetSlackProjectContext) Do

type PlatformUsageMetrics

type PlatformUsageMetrics struct {
	OrganizationID      string
	PublicMCPServers    int64
	PrivateMCPServers   int64
	TotalEnabledServers int64
	TotalToolsets       int64
	TotalTools          int64
}

type PostSlackMessage

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

func NewPostSlackMessageActivity

func NewPostSlackMessageActivity(logger *slog.Logger, client *client.SlackClient) *PostSlackMessage

func (*PostSlackMessage) Do

type PostSlackMessageInput

type PostSlackMessageInput struct {
	PostInput client.SlackPostMessageInput
	Event     types.SlackEvent
}

type ProcessDeployment

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

func NewProcessDeployment

func NewProcessDeployment(
	logger *slog.Logger,
	tracerProvider trace.TracerProvider,
	meterProvider metric.MeterProvider,
	db *pgxpool.Pool,
	features feature.Provider,
	assetStorage assets.BlobStore,
	billingRepo billing.Repository,
) *ProcessDeployment

func (*ProcessDeployment) Do

func (p *ProcessDeployment) Do(ctx context.Context, projectID uuid.UUID, deploymentID uuid.UUID) error

type ProvisionFunctionsAccess

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

func NewProvisionFunctionsAccess

func NewProvisionFunctionsAccess(
	logger *slog.Logger,
	db *pgxpool.Pool,
	encryption *encryption.Client,
) *ProvisionFunctionsAccess

func (*ProvisionFunctionsAccess) Do

func (p *ProvisionFunctionsAccess) Do(ctx context.Context, projectID uuid.UUID, deploymentID uuid.UUID) error

type RefreshBillingUsage

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

func NewRefreshBillingUsage

func NewRefreshBillingUsage(logger *slog.Logger, db *pgxpool.Pool, billingRepo billing.Repository) *RefreshBillingUsage

func (*RefreshBillingUsage) Do

func (r *RefreshBillingUsage) Do(ctx context.Context, orgIDs []string) error

type RefreshOpenRouterKey

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

func NewRefreshOpenRouterKey

func NewRefreshOpenRouterKey(logger *slog.Logger, db *pgxpool.Pool, openrouter openrouter.Provisioner) *RefreshOpenRouterKey

func (*RefreshOpenRouterKey) Do

type RefreshOpenRouterKeyArgs

type RefreshOpenRouterKeyArgs struct {
	OrgID string
}

type SlackChatCompletion

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

func NewSlackChatCompletionActivity

func NewSlackChatCompletionActivity(logger *slog.Logger, client *client.SlackClient, chatClient *chat.ChatClient) *SlackChatCompletion

func (*SlackChatCompletion) Do

type SlackChatCompletionInput

type SlackChatCompletionInput struct {
	Event       types.SlackEvent
	Prompt      string
	ToolsetSlug string
}

type SlackProjectContextResponse

type SlackProjectContextResponse struct {
	TeamName           string
	OrganizationID     string
	ProjectID          uuid.UUID
	ProjectSlug        string
	DefaultToolsetSlug *string
	Toolsets           []SlackToolsetSummary
}

type SlackToolsetSummary

type SlackToolsetSummary struct {
	ID            uuid.UUID
	Slug          string
	Description   *string
	NumberOfTools int
	CreatedAt     string
	UpdatedAt     string
}

type TransitionDeployment

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

func NewTransitionDeployment

func NewTransitionDeployment(logger *slog.Logger, db *pgxpool.Pool) *TransitionDeployment

func (*TransitionDeployment) Do

func (t *TransitionDeployment) Do(ctx context.Context, projectID uuid.UUID, deploymentID uuid.UUID, status string) (*TransitionDeploymentResult, error)

type TransitionDeploymentResult

type TransitionDeploymentResult struct {
	Status string
	Moved  bool
}

type ValidateDeployment

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

func NewValidateDeployment

func NewValidateDeployment(
	logger *slog.Logger,
	db *pgxpool.Pool,
	billingRepo billing.Repository,
) *ValidateDeployment

func (*ValidateDeployment) Do

func (v *ValidateDeployment) Do(ctx context.Context, projectID uuid.UUID, deploymentID uuid.UUID) error

type VerifyCustomDomain

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

func NewVerifyCustomDomain

func NewVerifyCustomDomain(logger *slog.Logger, db *pgxpool.Pool, expectedTargetCNAME string) *VerifyCustomDomain

func (*VerifyCustomDomain) Do

type VerifyCustomDomainArgs

type VerifyCustomDomainArgs struct {
	OrgID  string
	Domain string
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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