Documentation
¶
Index ¶
- type AITokensSinceParams
- type AiJob
- type AiProvider
- type AiUsage
- type ApiToken
- type AuditLog
- type ClaimScheduleParams
- type CreateAIJobParams
- type CreateAIProviderParams
- type CreateDriftResultParams
- type CreateIntegrationParams
- type CreateMembershipParams
- type CreateNotificationChannelParams
- type CreateOrgParams
- type CreateProjectParams
- type CreateRunParams
- type CreateScenarioParams
- type CreateScenarioVersionParams
- type CreateScheduleParams
- type CreateSessionParams
- type CreateTargetParams
- type CreateTokenParams
- type CreateUserParams
- type DBTX
- type DeleteAIProviderParams
- type DeleteIntegrationParams
- type DeleteNotificationChannelParams
- type DeleteProjectParams
- type DeleteProjectRoleParams
- type DeleteScenarioParams
- type DeleteSecretParams
- type DeleteTargetParams
- type DeleteTokenParams
- type DriftResult
- type FinishAIJobParams
- type FinishRunParams
- type GetAIJobParams
- type GetAIProviderByNameParams
- type GetAIProviderParams
- type GetDriftResultParams
- type GetDriftResultRow
- type GetIntegrationByNameParams
- type GetIntegrationParams
- type GetMemberParams
- type GetMemberRow
- type GetMembershipForUserRow
- type GetNotificationChannelParams
- type GetProjectParams
- type GetProjectRoleParams
- type GetRunParams
- type GetRunRow
- type GetScenarioParams
- type GetScenarioVersionParams
- type GetScheduleParams
- type GetScheduleRow
- type GetSessionRow
- type GetTargetParams
- type GetTokenByHashRow
- type InsertAuditParams
- type InsertNotificationDeliveryParams
- type InsertRunEventParams
- type InsertRunMetricParams
- type Integration
- type ListAIJobsParams
- type ListAIJobsRow
- type ListAuditParams
- type ListDriftResultsParams
- type ListDriftResultsRow
- type ListDueSchedulesRow
- type ListMembersRow
- type ListNotificationChannelsForEventParams
- type ListNotificationDeliveriesParams
- type ListProjectRolesRow
- type ListRunPointsRow
- type ListRunsParams
- type ListRunsRow
- type ListSchedulesRow
- type ListSecretNamesRow
- type ListUserProjectRolesParams
- type ListUserProjectRolesRow
- type MarkRunStartedParams
- type Membership
- type NotificationChannel
- type NotificationDelivery
- type Org
- type OrgCap
- type Project
- type ProjectRole
- type ProjectSetting
- type PruneNotificationDeliveriesParams
- type PutOrgCapsParams
- type PutProjectSettingsParams
- type PutSecretParams
- type Queries
- func (q *Queries) AITokensSince(ctx context.Context, arg AITokensSinceParams) (int64, error)
- func (q *Queries) ClaimAIJobApproval(ctx context.Context, id uuid.UUID) (int64, error)
- func (q *Queries) ClaimSchedule(ctx context.Context, arg ClaimScheduleParams) (uuid.UUID, error)
- func (q *Queries) CountOwners(ctx context.Context, orgID uuid.UUID) (int64, error)
- func (q *Queries) CountUsers(ctx context.Context) (int64, error)
- func (q *Queries) CreateAIJob(ctx context.Context, arg CreateAIJobParams) error
- func (q *Queries) CreateAIProvider(ctx context.Context, arg CreateAIProviderParams) error
- func (q *Queries) CreateDriftResult(ctx context.Context, arg CreateDriftResultParams) error
- func (q *Queries) CreateIntegration(ctx context.Context, arg CreateIntegrationParams) error
- func (q *Queries) CreateMembership(ctx context.Context, arg CreateMembershipParams) error
- func (q *Queries) CreateNotificationChannel(ctx context.Context, arg CreateNotificationChannelParams) error
- func (q *Queries) CreateOrg(ctx context.Context, arg CreateOrgParams) error
- func (q *Queries) CreateProject(ctx context.Context, arg CreateProjectParams) error
- func (q *Queries) CreateRun(ctx context.Context, arg CreateRunParams) error
- func (q *Queries) CreateScenario(ctx context.Context, arg CreateScenarioParams) error
- func (q *Queries) CreateScenarioVersion(ctx context.Context, arg CreateScenarioVersionParams) error
- func (q *Queries) CreateSchedule(ctx context.Context, arg CreateScheduleParams) error
- func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) error
- func (q *Queries) CreateTarget(ctx context.Context, arg CreateTargetParams) error
- func (q *Queries) CreateToken(ctx context.Context, arg CreateTokenParams) error
- func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) error
- func (q *Queries) DeleteAIProvider(ctx context.Context, arg DeleteAIProviderParams) (int64, error)
- func (q *Queries) DeleteExpiredSessions(ctx context.Context) error
- func (q *Queries) DeleteIntegration(ctx context.Context, arg DeleteIntegrationParams) (int64, error)
- func (q *Queries) DeleteNotificationChannel(ctx context.Context, arg DeleteNotificationChannelParams) (int64, error)
- func (q *Queries) DeleteProject(ctx context.Context, arg DeleteProjectParams) (int64, error)
- func (q *Queries) DeleteProjectRole(ctx context.Context, arg DeleteProjectRoleParams) (int64, error)
- func (q *Queries) DeleteReplica(ctx context.Context, id uuid.UUID) error
- func (q *Queries) DeleteScenario(ctx context.Context, arg DeleteScenarioParams) (int64, error)
- func (q *Queries) DeleteSchedule(ctx context.Context, id uuid.UUID) (int64, error)
- func (q *Queries) DeleteSecret(ctx context.Context, arg DeleteSecretParams) (int64, error)
- func (q *Queries) DeleteSession(ctx context.Context, tokenHash []byte) error
- func (q *Queries) DeleteStaleReplicas(ctx context.Context, lastSeen time.Time) error
- func (q *Queries) DeleteTarget(ctx context.Context, arg DeleteTargetParams) (int64, error)
- func (q *Queries) DeleteToken(ctx context.Context, arg DeleteTokenParams) (int64, error)
- func (q *Queries) DeleteUser(ctx context.Context, id uuid.UUID) error
- func (q *Queries) DeleteUserSessions(ctx context.Context, userID uuid.UUID) error
- func (q *Queries) FailInterruptedAIJobs(ctx context.Context) (int64, error)
- func (q *Queries) FailOrphanedAIJobs(ctx context.Context, lastSeen time.Time) (int64, error)
- func (q *Queries) FinishAIJob(ctx context.Context, arg FinishAIJobParams) error
- func (q *Queries) FinishRun(ctx context.Context, arg FinishRunParams) error
- func (q *Queries) FirstOrg(ctx context.Context) (Org, error)
- func (q *Queries) GetAIJob(ctx context.Context, arg GetAIJobParams) (AiJob, error)
- func (q *Queries) GetAIProvider(ctx context.Context, arg GetAIProviderParams) (AiProvider, error)
- func (q *Queries) GetAIProviderByName(ctx context.Context, arg GetAIProviderByNameParams) (AiProvider, error)
- func (q *Queries) GetDriftResult(ctx context.Context, arg GetDriftResultParams) (GetDriftResultRow, error)
- func (q *Queries) GetIntegration(ctx context.Context, arg GetIntegrationParams) (Integration, error)
- func (q *Queries) GetIntegrationByName(ctx context.Context, arg GetIntegrationByNameParams) (Integration, error)
- func (q *Queries) GetLatestScenarioVersion(ctx context.Context, scenarioID uuid.UUID) (ScenarioVersion, error)
- func (q *Queries) GetMember(ctx context.Context, arg GetMemberParams) (GetMemberRow, error)
- func (q *Queries) GetMembershipForUser(ctx context.Context, userID uuid.UUID) (GetMembershipForUserRow, error)
- func (q *Queries) GetNotificationChannel(ctx context.Context, arg GetNotificationChannelParams) (NotificationChannel, error)
- func (q *Queries) GetOrg(ctx context.Context, id uuid.UUID) (Org, error)
- func (q *Queries) GetOrgCaps(ctx context.Context, orgID uuid.UUID) (OrgCap, error)
- func (q *Queries) GetProject(ctx context.Context, arg GetProjectParams) (Project, error)
- func (q *Queries) GetProjectRole(ctx context.Context, arg GetProjectRoleParams) (string, error)
- func (q *Queries) GetProjectSettings(ctx context.Context, projectID uuid.UUID) (ProjectSetting, error)
- func (q *Queries) GetReport(ctx context.Context, runID uuid.UUID) (json.RawMessage, error)
- func (q *Queries) GetRun(ctx context.Context, arg GetRunParams) (GetRunRow, error)
- func (q *Queries) GetRunOwner(ctx context.Context, id uuid.UUID) (*uuid.UUID, error)
- func (q *Queries) GetScenario(ctx context.Context, arg GetScenarioParams) (Scenario, error)
- func (q *Queries) GetScenarioVersion(ctx context.Context, arg GetScenarioVersionParams) (ScenarioVersion, error)
- func (q *Queries) GetSchedule(ctx context.Context, arg GetScheduleParams) (GetScheduleRow, error)
- func (q *Queries) GetSession(ctx context.Context, tokenHash []byte) (GetSessionRow, error)
- func (q *Queries) GetTarget(ctx context.Context, arg GetTargetParams) (Target, error)
- func (q *Queries) GetTokenByHash(ctx context.Context, tokenHash []byte) (GetTokenByHashRow, error)
- func (q *Queries) GetUser(ctx context.Context, id uuid.UUID) (User, error)
- func (q *Queries) GetUserByEmail(ctx context.Context, email string) (User, error)
- func (q *Queries) InsertAudit(ctx context.Context, arg InsertAuditParams) error
- func (q *Queries) InsertNotificationDelivery(ctx context.Context, arg InsertNotificationDeliveryParams) error
- func (q *Queries) InsertRunEvent(ctx context.Context, arg InsertRunEventParams) error
- func (q *Queries) InsertRunMetric(ctx context.Context, arg InsertRunMetricParams) error
- func (q *Queries) LastDriftSpec(ctx context.Context, scheduleID *uuid.UUID) (json.RawMessage, error)
- func (q *Queries) ListAIJobs(ctx context.Context, arg ListAIJobsParams) ([]ListAIJobsRow, error)
- func (q *Queries) ListAIProviders(ctx context.Context, orgID uuid.UUID) ([]AiProvider, error)
- func (q *Queries) ListActiveRuns(ctx context.Context, orgID uuid.UUID) ([]uuid.UUID, error)
- func (q *Queries) ListAudit(ctx context.Context, arg ListAuditParams) ([]AuditLog, error)
- func (q *Queries) ListDriftResults(ctx context.Context, arg ListDriftResultsParams) ([]ListDriftResultsRow, error)
- func (q *Queries) ListDueSchedules(ctx context.Context, now time.Time) ([]ListDueSchedulesRow, error)
- func (q *Queries) ListIntegrations(ctx context.Context, orgID uuid.UUID) ([]Integration, error)
- func (q *Queries) ListMembers(ctx context.Context, orgID uuid.UUID) ([]ListMembersRow, error)
- func (q *Queries) ListNotificationChannels(ctx context.Context, orgID uuid.UUID) ([]NotificationChannel, error)
- func (q *Queries) ListNotificationChannelsForEvent(ctx context.Context, arg ListNotificationChannelsForEventParams) ([]NotificationChannel, error)
- func (q *Queries) ListNotificationDeliveries(ctx context.Context, arg ListNotificationDeliveriesParams) ([]NotificationDelivery, error)
- func (q *Queries) ListOrphanedRuns(ctx context.Context, lastSeen time.Time) ([]uuid.UUID, error)
- func (q *Queries) ListProjectRoles(ctx context.Context, projectID uuid.UUID) ([]ListProjectRolesRow, error)
- func (q *Queries) ListProjects(ctx context.Context, orgID uuid.UUID) ([]Project, error)
- func (q *Queries) ListReplicas(ctx context.Context) ([]Replica, error)
- func (q *Queries) ListRunEvents(ctx context.Context, runID uuid.UUID) ([]RunEvent, error)
- func (q *Queries) ListRunPoints(ctx context.Context, runID uuid.UUID) ([]ListRunPointsRow, error)
- func (q *Queries) ListRunSnapshots(ctx context.Context, runID uuid.UUID) ([][]byte, error)
- func (q *Queries) ListRuns(ctx context.Context, arg ListRunsParams) ([]ListRunsRow, error)
- func (q *Queries) ListScenarioVersions(ctx context.Context, scenarioID uuid.UUID) ([]ScenarioVersion, error)
- func (q *Queries) ListScenarios(ctx context.Context, projectID uuid.UUID) ([]Scenario, error)
- func (q *Queries) ListSchedules(ctx context.Context, projectID uuid.UUID) ([]ListSchedulesRow, error)
- func (q *Queries) ListSecretNames(ctx context.Context, projectID uuid.UUID) ([]ListSecretNamesRow, error)
- func (q *Queries) ListSecrets(ctx context.Context, projectID uuid.UUID) ([]Secret, error)
- func (q *Queries) ListTargets(ctx context.Context, projectID uuid.UUID) ([]Target, error)
- func (q *Queries) ListTokens(ctx context.Context, userID uuid.UUID) ([]ApiToken, error)
- func (q *Queries) ListUnfinishedRuns(ctx context.Context) ([]uuid.UUID, error)
- func (q *Queries) ListUserProjectRoles(ctx context.Context, arg ListUserProjectRolesParams) ([]ListUserProjectRolesRow, error)
- func (q *Queries) MarkRunStarted(ctx context.Context, arg MarkRunStartedParams) error
- func (q *Queries) NextScenarioVersion(ctx context.Context, scenarioID uuid.UUID) (int32, error)
- func (q *Queries) PruneNotificationDeliveries(ctx context.Context, arg PruneNotificationDeliveriesParams) error
- func (q *Queries) PutOrgCaps(ctx context.Context, arg PutOrgCapsParams) error
- func (q *Queries) PutProjectSettings(ctx context.Context, arg PutProjectSettingsParams) error
- func (q *Queries) PutSecret(ctx context.Context, arg PutSecretParams) (time.Time, error)
- func (q *Queries) RecordAIUsage(ctx context.Context, arg RecordAIUsageParams) error
- func (q *Queries) RecordScheduleDrift(ctx context.Context, arg RecordScheduleDriftParams) error
- func (q *Queries) RecordScheduleRun(ctx context.Context, arg RecordScheduleRunParams) error
- func (q *Queries) RecordScheduleSkip(ctx context.Context, arg RecordScheduleSkipParams) error
- func (q *Queries) ReleaseAIJobApproval(ctx context.Context, id uuid.UUID) error
- func (q *Queries) SaveReport(ctx context.Context, arg SaveReportParams) error
- func (q *Queries) SetAIJobApproved(ctx context.Context, arg SetAIJobApprovedParams) error
- func (q *Queries) SetAIJobOwner(ctx context.Context, arg SetAIJobOwnerParams) error
- func (q *Queries) SetDriftRepairJob(ctx context.Context, arg SetDriftRepairJobParams) error
- func (q *Queries) SetProjectRole(ctx context.Context, arg SetProjectRoleParams) error
- func (q *Queries) SetRunOwner(ctx context.Context, arg SetRunOwnerParams) error
- func (q *Queries) SetRunStatus(ctx context.Context, arg SetRunStatusParams) error
- func (q *Queries) SetRunWorkers(ctx context.Context, arg SetRunWorkersParams) error
- func (q *Queries) SetTargetVerified(ctx context.Context, arg SetTargetVerifiedParams) error
- func (q *Queries) StartAIJob(ctx context.Context, id uuid.UUID) error
- func (q *Queries) TouchReplica(ctx context.Context, id uuid.UUID) error
- func (q *Queries) TouchToken(ctx context.Context, id uuid.UUID) error
- func (q *Queries) TouchUserLogin(ctx context.Context, id uuid.UUID) error
- func (q *Queries) UpdateAIJobProgress(ctx context.Context, arg UpdateAIJobProgressParams) error
- func (q *Queries) UpdateAIProvider(ctx context.Context, arg UpdateAIProviderParams) error
- func (q *Queries) UpdateMembershipRole(ctx context.Context, arg UpdateMembershipRoleParams) error
- func (q *Queries) UpdateProject(ctx context.Context, arg UpdateProjectParams) error
- func (q *Queries) UpdateScenarioMeta(ctx context.Context, arg UpdateScenarioMetaParams) error
- func (q *Queries) UpdateSchedule(ctx context.Context, arg UpdateScheduleParams) error
- func (q *Queries) UpdateTarget(ctx context.Context, arg UpdateTargetParams) error
- func (q *Queries) UpdateUserName(ctx context.Context, arg UpdateUserNameParams) error
- func (q *Queries) UpdateUserPassword(ctx context.Context, arg UpdateUserPasswordParams) error
- func (q *Queries) UpsertReplica(ctx context.Context, arg UpsertReplicaParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type RecordAIUsageParams
- type RecordScheduleDriftParams
- type RecordScheduleRunParams
- type RecordScheduleSkipParams
- type Replica
- type Report
- type Run
- type RunEvent
- type RunMetric
- type SaveReportParams
- type Scenario
- type ScenarioVersion
- type Schedule
- type Secret
- type Session
- type SetAIJobApprovedParams
- type SetAIJobOwnerParams
- type SetDriftRepairJobParams
- type SetProjectRoleParams
- type SetRunOwnerParams
- type SetRunStatusParams
- type SetRunWorkersParams
- type SetTargetVerifiedParams
- type Target
- type UpdateAIJobProgressParams
- type UpdateAIProviderParams
- type UpdateMembershipRoleParams
- type UpdateProjectParams
- type UpdateScenarioMetaParams
- type UpdateScheduleParams
- type UpdateTargetParams
- type UpdateUserNameParams
- type UpdateUserPasswordParams
- type UpsertReplicaParams
- type User
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AiJob ¶
type AiJob struct {
ID uuid.UUID
OrgID uuid.UUID
ProjectID uuid.UUID
ProviderID *uuid.UUID
ProviderKind string
Model string
Status string
Stage string
Round int32
TargetID *uuid.UUID
ScenarioID *uuid.UUID
DryRun bool
Inputs json.RawMessage
Yaml string
Diff string
Result json.RawMessage
Error string
InputTokens int64
OutputTokens int64
CreatedBy *uuid.UUID
CreatedAt time.Time
StartedAt *time.Time
FinishedAt *time.Time
ApprovedAt *time.Time
ApprovedScenarioID *uuid.UUID
ApprovedVersion *int32
OwnerReplica *uuid.UUID
}
type AiProvider ¶
type ClaimScheduleParams ¶
type CreateAIJobParams ¶
type CreateAIProviderParams ¶
type CreateDriftResultParams ¶
type CreateIntegrationParams ¶
type CreateMembershipParams ¶
type CreateOrgParams ¶
type CreateProjectParams ¶
type CreateRunParams ¶
type CreateScenarioParams ¶
type CreateScheduleParams ¶
type CreateScheduleParams struct {
ID uuid.UUID
ProjectID uuid.UUID
Name string
ScenarioID uuid.UUID
TargetID uuid.UUID
Cron string
Timezone string
Overrides json.RawMessage
Env json.RawMessage
Workers int32
Enabled bool
Note string
OwnerID *uuid.UUID
NextRunAt *time.Time
Kind string
SpecUrl string
}
type CreateSessionParams ¶
type CreateTargetParams ¶
type CreateTokenParams ¶
type CreateUserParams ¶
type DeleteProjectRoleParams ¶
type DeleteSecretParams ¶
type DriftResult ¶
type FinishAIJobParams ¶
type FinishRunParams ¶
type GetDriftResultRow ¶
type GetDriftResultRow struct {
ID uuid.UUID
ProjectID uuid.UUID
ScheduleID *uuid.UUID
ScenarioID uuid.UUID
ScenarioVersion int32
TargetID uuid.UUID
Status string
Error string
Broken []string
Result json.RawMessage
Spec json.RawMessage
RepairJobID *uuid.UUID
CreatedBy *uuid.UUID
CreatedAt time.Time
ScenarioName string
TargetUrl string
ScheduleName *string
}
type GetMemberRow ¶
type GetMembershipForUserRow ¶
type GetProjectRoleParams ¶
type GetRunRow ¶
type GetRunRow struct {
ID uuid.UUID
ProjectID uuid.UUID
ScenarioID uuid.UUID
ScenarioVersion int32
TargetID uuid.UUID
Status string
Verdict *string
StopReason *string
Error *string
Overrides json.RawMessage
Plan json.RawMessage
Env json.RawMessage
Workers int32
Note string
Summary json.RawMessage
CreatedBy *uuid.UUID
CreatedAt time.Time
StartedAt *time.Time
EndedAt *time.Time
OwnerReplica *uuid.UUID
ScenarioName string
TargetUrl string
}
type GetScheduleRow ¶
type GetScheduleRow struct {
ID uuid.UUID
ProjectID uuid.UUID
Name string
ScenarioID uuid.UUID
TargetID uuid.UUID
Cron string
Timezone string
Overrides json.RawMessage
Env json.RawMessage
Workers int32
Enabled bool
Note string
OwnerID *uuid.UUID
CreatedAt time.Time
UpdatedAt time.Time
NextRunAt *time.Time
LastFiredAt *time.Time
LastRunID *uuid.UUID
LastSkipReason string
Kind string
SpecUrl string
LastDriftID *uuid.UUID
OrgID uuid.UUID
ScenarioName string
TargetName string
OwnerEmail *string
LastRunStatus *string
LastRunVerdict *string
LastRunAt *time.Time
LastDriftStatus *string
LastDriftBroken []string
}
type GetSessionRow ¶
type GetTokenByHashRow ¶
type InsertAuditParams ¶
type InsertRunEventParams ¶
type InsertRunMetricParams ¶
type Integration ¶
type ListAIJobsParams ¶
type ListAIJobsRow ¶
type ListDriftResultsParams ¶
type ListDriftResultsRow ¶
type ListDueSchedulesRow ¶
type ListMembersRow ¶
type ListProjectRolesRow ¶
type ListRunPointsRow ¶
type ListRunsParams ¶
type ListRunsRow ¶
type ListRunsRow struct {
ID uuid.UUID
ProjectID uuid.UUID
ScenarioID uuid.UUID
ScenarioVersion int32
TargetID uuid.UUID
Status string
Verdict *string
StopReason *string
Error *string
Overrides json.RawMessage
Plan json.RawMessage
Env json.RawMessage
Workers int32
Note string
Summary json.RawMessage
CreatedBy *uuid.UUID
CreatedAt time.Time
StartedAt *time.Time
EndedAt *time.Time
OwnerReplica *uuid.UUID
ScenarioName string
TargetUrl string
}
type ListSchedulesRow ¶
type ListSchedulesRow struct {
ID uuid.UUID
ProjectID uuid.UUID
Name string
ScenarioID uuid.UUID
TargetID uuid.UUID
Cron string
Timezone string
Overrides json.RawMessage
Env json.RawMessage
Workers int32
Enabled bool
Note string
OwnerID *uuid.UUID
CreatedAt time.Time
UpdatedAt time.Time
NextRunAt *time.Time
LastFiredAt *time.Time
LastRunID *uuid.UUID
LastSkipReason string
Kind string
SpecUrl string
LastDriftID *uuid.UUID
OrgID uuid.UUID
ScenarioName string
TargetName string
OwnerEmail *string
LastRunStatus *string
LastRunVerdict *string
LastRunAt *time.Time
LastDriftStatus *string
LastDriftBroken []string
}
type ListSecretNamesRow ¶
type ListUserProjectRolesRow ¶
type Membership ¶
type NotificationChannel ¶
type NotificationDelivery ¶
type ProjectRole ¶
type ProjectSetting ¶
type PutOrgCapsParams ¶
type PutSecretParams ¶
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AITokensSince ¶
func (*Queries) ClaimAIJobApproval ¶
func (*Queries) ClaimSchedule ¶
Moves a due schedule to its next firing. Only one caller can match the old next_run_at, so concurrent claimers fire it once.
func (*Queries) CountOwners ¶
func (*Queries) CreateAIJob ¶
func (q *Queries) CreateAIJob(ctx context.Context, arg CreateAIJobParams) error
func (*Queries) CreateAIProvider ¶
func (q *Queries) CreateAIProvider(ctx context.Context, arg CreateAIProviderParams) error
func (*Queries) CreateDriftResult ¶
func (q *Queries) CreateDriftResult(ctx context.Context, arg CreateDriftResultParams) error
func (*Queries) CreateIntegration ¶
func (q *Queries) CreateIntegration(ctx context.Context, arg CreateIntegrationParams) error
func (*Queries) CreateMembership ¶
func (q *Queries) CreateMembership(ctx context.Context, arg CreateMembershipParams) error
func (*Queries) CreateNotificationChannel ¶
func (q *Queries) CreateNotificationChannel(ctx context.Context, arg CreateNotificationChannelParams) error
func (*Queries) CreateOrg ¶
func (q *Queries) CreateOrg(ctx context.Context, arg CreateOrgParams) error
func (*Queries) CreateProject ¶
func (q *Queries) CreateProject(ctx context.Context, arg CreateProjectParams) error
func (*Queries) CreateRun ¶
func (q *Queries) CreateRun(ctx context.Context, arg CreateRunParams) error
func (*Queries) CreateScenario ¶
func (q *Queries) CreateScenario(ctx context.Context, arg CreateScenarioParams) error
func (*Queries) CreateScenarioVersion ¶
func (q *Queries) CreateScenarioVersion(ctx context.Context, arg CreateScenarioVersionParams) error
func (*Queries) CreateSchedule ¶
func (q *Queries) CreateSchedule(ctx context.Context, arg CreateScheduleParams) error
func (*Queries) CreateSession ¶
func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) error
func (*Queries) CreateTarget ¶
func (q *Queries) CreateTarget(ctx context.Context, arg CreateTargetParams) error
func (*Queries) CreateToken ¶
func (q *Queries) CreateToken(ctx context.Context, arg CreateTokenParams) error
func (*Queries) CreateUser ¶
func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) error
func (*Queries) DeleteAIProvider ¶
func (*Queries) DeleteExpiredSessions ¶
func (*Queries) DeleteIntegration ¶
func (*Queries) DeleteNotificationChannel ¶
func (*Queries) DeleteProject ¶
func (*Queries) DeleteProjectRole ¶
func (*Queries) DeleteReplica ¶
func (*Queries) DeleteScenario ¶
func (*Queries) DeleteSchedule ¶
func (*Queries) DeleteSecret ¶
func (*Queries) DeleteSession ¶
func (*Queries) DeleteStaleReplicas ¶
func (*Queries) DeleteTarget ¶
func (*Queries) DeleteToken ¶
func (*Queries) DeleteUserSessions ¶
func (*Queries) FailInterruptedAIJobs ¶
func (*Queries) FailOrphanedAIJobs ¶
func (*Queries) FinishAIJob ¶
func (q *Queries) FinishAIJob(ctx context.Context, arg FinishAIJobParams) error
func (*Queries) FinishRun ¶
func (q *Queries) FinishRun(ctx context.Context, arg FinishRunParams) error
func (*Queries) GetAIProvider ¶
func (q *Queries) GetAIProvider(ctx context.Context, arg GetAIProviderParams) (AiProvider, error)
func (*Queries) GetAIProviderByName ¶
func (q *Queries) GetAIProviderByName(ctx context.Context, arg GetAIProviderByNameParams) (AiProvider, error)
func (*Queries) GetDriftResult ¶
func (q *Queries) GetDriftResult(ctx context.Context, arg GetDriftResultParams) (GetDriftResultRow, error)
func (*Queries) GetIntegration ¶
func (q *Queries) GetIntegration(ctx context.Context, arg GetIntegrationParams) (Integration, error)
func (*Queries) GetIntegrationByName ¶
func (q *Queries) GetIntegrationByName(ctx context.Context, arg GetIntegrationByNameParams) (Integration, error)
func (*Queries) GetLatestScenarioVersion ¶
func (*Queries) GetMember ¶
func (q *Queries) GetMember(ctx context.Context, arg GetMemberParams) (GetMemberRow, error)
func (*Queries) GetMembershipForUser ¶
func (*Queries) GetNotificationChannel ¶
func (q *Queries) GetNotificationChannel(ctx context.Context, arg GetNotificationChannelParams) (NotificationChannel, error)
func (*Queries) GetOrgCaps ¶
func (*Queries) GetProject ¶
func (*Queries) GetProjectRole ¶
func (*Queries) GetProjectSettings ¶
func (*Queries) GetRunOwner ¶
func (*Queries) GetScenario ¶
func (*Queries) GetScenarioVersion ¶
func (q *Queries) GetScenarioVersion(ctx context.Context, arg GetScenarioVersionParams) (ScenarioVersion, error)
func (*Queries) GetSchedule ¶
func (q *Queries) GetSchedule(ctx context.Context, arg GetScheduleParams) (GetScheduleRow, error)
func (*Queries) GetSession ¶
func (*Queries) GetTokenByHash ¶
func (*Queries) GetUserByEmail ¶
func (*Queries) InsertAudit ¶
func (q *Queries) InsertAudit(ctx context.Context, arg InsertAuditParams) error
func (*Queries) InsertNotificationDelivery ¶
func (q *Queries) InsertNotificationDelivery(ctx context.Context, arg InsertNotificationDeliveryParams) error
func (*Queries) InsertRunEvent ¶
func (q *Queries) InsertRunEvent(ctx context.Context, arg InsertRunEventParams) error
func (*Queries) InsertRunMetric ¶
func (q *Queries) InsertRunMetric(ctx context.Context, arg InsertRunMetricParams) error
func (*Queries) LastDriftSpec ¶
func (q *Queries) LastDriftSpec(ctx context.Context, scheduleID *uuid.UUID) (json.RawMessage, error)
The spec endpoints recorded by a schedule's latest check that fetched one.
func (*Queries) ListAIJobs ¶
func (q *Queries) ListAIJobs(ctx context.Context, arg ListAIJobsParams) ([]ListAIJobsRow, error)
func (*Queries) ListAIProviders ¶
func (*Queries) ListActiveRuns ¶
func (*Queries) ListDriftResults ¶
func (q *Queries) ListDriftResults(ctx context.Context, arg ListDriftResultsParams) ([]ListDriftResultsRow, error)
func (*Queries) ListDueSchedules ¶
func (*Queries) ListIntegrations ¶
func (*Queries) ListMembers ¶
func (*Queries) ListNotificationChannels ¶
func (*Queries) ListNotificationChannelsForEvent ¶
func (q *Queries) ListNotificationChannelsForEvent(ctx context.Context, arg ListNotificationChannelsForEventParams) ([]NotificationChannel, error)
func (*Queries) ListNotificationDeliveries ¶
func (q *Queries) ListNotificationDeliveries(ctx context.Context, arg ListNotificationDeliveriesParams) ([]NotificationDelivery, error)
func (*Queries) ListOrphanedRuns ¶
Unfinished runs whose owner has no fresh heartbeat (or no owner at all).
func (*Queries) ListProjectRoles ¶
func (*Queries) ListProjects ¶
func (*Queries) ListReplicas ¶
func (*Queries) ListRunEvents ¶
func (*Queries) ListRunPoints ¶
func (*Queries) ListRunSnapshots ¶
func (*Queries) ListRuns ¶
func (q *Queries) ListRuns(ctx context.Context, arg ListRunsParams) ([]ListRunsRow, error)
func (*Queries) ListScenarioVersions ¶
func (*Queries) ListScenarios ¶
func (*Queries) ListSchedules ¶
func (*Queries) ListSecretNames ¶
func (*Queries) ListSecrets ¶
func (*Queries) ListTargets ¶
func (*Queries) ListTokens ¶
func (*Queries) ListUnfinishedRuns ¶
func (*Queries) ListUserProjectRoles ¶
func (q *Queries) ListUserProjectRoles(ctx context.Context, arg ListUserProjectRolesParams) ([]ListUserProjectRolesRow, error)
The caller's overrides across an organisation's projects.
func (*Queries) MarkRunStarted ¶
func (q *Queries) MarkRunStarted(ctx context.Context, arg MarkRunStartedParams) error
func (*Queries) NextScenarioVersion ¶
func (*Queries) PruneNotificationDeliveries ¶
func (q *Queries) PruneNotificationDeliveries(ctx context.Context, arg PruneNotificationDeliveriesParams) error
func (*Queries) PutOrgCaps ¶
func (q *Queries) PutOrgCaps(ctx context.Context, arg PutOrgCapsParams) error
func (*Queries) PutProjectSettings ¶
func (q *Queries) PutProjectSettings(ctx context.Context, arg PutProjectSettingsParams) error
func (*Queries) RecordAIUsage ¶
func (q *Queries) RecordAIUsage(ctx context.Context, arg RecordAIUsageParams) error
func (*Queries) RecordScheduleDrift ¶
func (q *Queries) RecordScheduleDrift(ctx context.Context, arg RecordScheduleDriftParams) error
func (*Queries) RecordScheduleRun ¶
func (q *Queries) RecordScheduleRun(ctx context.Context, arg RecordScheduleRunParams) error
func (*Queries) RecordScheduleSkip ¶
func (q *Queries) RecordScheduleSkip(ctx context.Context, arg RecordScheduleSkipParams) error
func (*Queries) ReleaseAIJobApproval ¶
func (*Queries) SaveReport ¶
func (q *Queries) SaveReport(ctx context.Context, arg SaveReportParams) error
func (*Queries) SetAIJobApproved ¶
func (q *Queries) SetAIJobApproved(ctx context.Context, arg SetAIJobApprovedParams) error
func (*Queries) SetAIJobOwner ¶
func (q *Queries) SetAIJobOwner(ctx context.Context, arg SetAIJobOwnerParams) error
func (*Queries) SetDriftRepairJob ¶
func (q *Queries) SetDriftRepairJob(ctx context.Context, arg SetDriftRepairJobParams) error
func (*Queries) SetProjectRole ¶
func (q *Queries) SetProjectRole(ctx context.Context, arg SetProjectRoleParams) error
func (*Queries) SetRunOwner ¶
func (q *Queries) SetRunOwner(ctx context.Context, arg SetRunOwnerParams) error
func (*Queries) SetRunStatus ¶
func (q *Queries) SetRunStatus(ctx context.Context, arg SetRunStatusParams) error
func (*Queries) SetRunWorkers ¶
func (q *Queries) SetRunWorkers(ctx context.Context, arg SetRunWorkersParams) error
func (*Queries) SetTargetVerified ¶
func (q *Queries) SetTargetVerified(ctx context.Context, arg SetTargetVerifiedParams) error
func (*Queries) TouchReplica ¶
func (*Queries) TouchUserLogin ¶
func (*Queries) UpdateAIJobProgress ¶
func (q *Queries) UpdateAIJobProgress(ctx context.Context, arg UpdateAIJobProgressParams) error
func (*Queries) UpdateAIProvider ¶
func (q *Queries) UpdateAIProvider(ctx context.Context, arg UpdateAIProviderParams) error
func (*Queries) UpdateMembershipRole ¶
func (q *Queries) UpdateMembershipRole(ctx context.Context, arg UpdateMembershipRoleParams) error
func (*Queries) UpdateProject ¶
func (q *Queries) UpdateProject(ctx context.Context, arg UpdateProjectParams) error
func (*Queries) UpdateScenarioMeta ¶
func (q *Queries) UpdateScenarioMeta(ctx context.Context, arg UpdateScenarioMetaParams) error
func (*Queries) UpdateSchedule ¶
func (q *Queries) UpdateSchedule(ctx context.Context, arg UpdateScheduleParams) error
func (*Queries) UpdateTarget ¶
func (q *Queries) UpdateTarget(ctx context.Context, arg UpdateTargetParams) error
func (*Queries) UpdateUserName ¶
func (q *Queries) UpdateUserName(ctx context.Context, arg UpdateUserNameParams) error
func (*Queries) UpdateUserPassword ¶
func (q *Queries) UpdateUserPassword(ctx context.Context, arg UpdateUserPasswordParams) error
func (*Queries) UpsertReplica ¶
func (q *Queries) UpsertReplica(ctx context.Context, arg UpsertReplicaParams) error
type RecordAIUsageParams ¶
type RecordScheduleRunParams ¶
type Run ¶
type Run struct {
ID uuid.UUID
ProjectID uuid.UUID
ScenarioID uuid.UUID
ScenarioVersion int32
TargetID uuid.UUID
Status string
Verdict *string
StopReason *string
Error *string
Overrides json.RawMessage
Plan json.RawMessage
Env json.RawMessage
Workers int32
Note string
Summary json.RawMessage
CreatedBy *uuid.UUID
CreatedAt time.Time
StartedAt *time.Time
EndedAt *time.Time
OwnerReplica *uuid.UUID
}
type SaveReportParams ¶
type SaveReportParams struct {
RunID uuid.UUID
Report json.RawMessage
}
type ScenarioVersion ¶
type Schedule ¶
type Schedule struct {
ID uuid.UUID
ProjectID uuid.UUID
Name string
ScenarioID uuid.UUID
TargetID uuid.UUID
Cron string
Timezone string
Overrides json.RawMessage
Env json.RawMessage
Workers int32
Enabled bool
Note string
OwnerID *uuid.UUID
CreatedAt time.Time
UpdatedAt time.Time
NextRunAt *time.Time
LastFiredAt *time.Time
LastRunID *uuid.UUID
LastSkipReason string
Kind string
SpecUrl string
LastDriftID *uuid.UUID
}
type SetAIJobApprovedParams ¶
type SetDriftRepairJobParams ¶
type SetProjectRoleParams ¶
type SetRunStatusParams ¶
type SetRunWorkersParams ¶
type SetTargetVerifiedParams ¶
type UpdateAIProviderParams ¶
type UpdateProjectParams ¶
type UpdateScheduleParams ¶
type UpdateTargetParams ¶
type UpdateUserNameParams ¶
type UpsertReplicaParams ¶
Click to show internal directories.
Click to hide internal directories.