service

package
v0.19.1069 Latest Latest
Warning

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

Go to latest
Published: Jul 17, 2026 License: AGPL-3.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(params Params) *service

Types

type AdminBackfillBlobsRequest added in v0.19.1024

type AdminBackfillBlobsRequest struct {
	Tables []string `json:"tables"`
}

AdminBackfillBlobsRequest optionally narrows the backfill to a subset of dual-write tables. When empty, every supported table is processed.

type AdminDeleteAccountRequest

type AdminDeleteAccountRequest struct {
	EmailOrSubjectOrID string `json:"email_or_subject_or_id" validate:"required"`
}

func (*AdminDeleteAccountRequest) Validate

type AdminPromotionRequest

type AdminPromotionRequest struct {
	Tag string `json:"tag"`
}

type AdminVerifyBlobsRequest added in v0.19.1024

type AdminVerifyBlobsRequest struct {
	Tables []string `json:"tables"`
}

AdminVerifyBlobsRequest optionally narrows the verification to a subset of dual-write tables. When empty, every supported table is processed.

type BackfillBlobsStatusResponse added in v0.19.1024

type BackfillBlobsStatusResponse struct {
	Running        bool                   `json:"running"`
	Status         string                 `json:"status"`
	RunID          string                 `json:"run_id,omitempty"`
	StartedAt      *time.Time             `json:"started_at,omitempty"`
	ClosedAt       *time.Time             `json:"closed_at,omitempty"`
	ElapsedSeconds float64                `json:"elapsed_seconds,omitempty"`
	Elapsed        string                 `json:"elapsed,omitempty"`
	Progress       *blobbackfill.Progress `json:"progress,omitempty"`
}

type BackfillRunnerHealthcheckEmittersStatusResponse added in v0.19.1062

type BackfillRunnerHealthcheckEmittersStatusResponse struct {
	Running        bool                                `json:"running"`
	Status         string                              `json:"status"`
	RunID          string                              `json:"run_id,omitempty"`
	StartedAt      *time.Time                          `json:"started_at,omitempty"`
	ClosedAt       *time.Time                          `json:"closed_at,omitempty"`
	ElapsedSeconds float64                             `json:"elapsed_seconds,omitempty"`
	Elapsed        string                              `json:"elapsed,omitempty"`
	Progress       *runnerhealthcheckbackfill.Progress `json:"progress,omitempty"`
}

type CLIConfig

type CLIConfig struct {
	AuthDomain      string `json:"auth_domain"`
	AuthClientID    string `json:"auth_client_id"`
	AuthAudience    string `json:"auth_audience"`
	DashboardURL    string `json:"dashboard_url"`
	NuonAuthEnabled bool   `json:"nuon_auth_enabled"`
	RootDomain      string `json:"root_domain"`
}

type CreateCanaryUserRequest

type CreateCanaryUserRequest struct {
	CanaryID string `json:"canary_id"`
}

type CreateCanaryUserResponse

type CreateCanaryUserResponse struct {
	APIToken        string `json:"api_token,omitzero"`
	GithubInstallID string `json:"github_install_id,omitzero"`
	Email           string `json:"email,omitzero"`
}

type CreateIntegrationUserRequest

type CreateIntegrationUserRequest struct{}

type CreateIntegrationUserResponse

type CreateIntegrationUserResponse struct {
	APIToken        string `json:"api_token,omitzero"`
	GithubInstallID string `json:"github_install_id,omitzero"`
	Email           string `json:"email,omitzero"`
}

type CreateSeedUserRequest

type CreateSeedUserRequest struct{}

type CreateSeedUserResponse

type CreateSeedUserResponse struct {
	APIToken        string `json:"api_token,omitzero"`
	GithubInstallID string `json:"github_install_id,omitzero"`
	Email           string `json:"email,omitzero"`
}

type DeprovisionCanaryRequest

type DeprovisionCanaryRequest struct {
	CanaryID string `json:"canary_id"`
}

type InfraTestsDeprovisionRequest

type InfraTestsDeprovisionRequest struct {
	SandboxName      string                 `json:"sandbox_name"`
	SandboxRef       string                 `json:"sandbox_ref"`
	TerraformVersion string                 `json:"terraform_version"`
	Region           string                 `json:"region"`
	SandboxVars      map[string]interface{} `json:"sandbox_vars"`
	OrgID            string                 `json:"org_id"`
	CanaryID         string                 `json:"canary_id"`
	Directory        string                 `json:"directory"`
	ClusterName      string                 `json:"cluster_name"`
	Account          map[string]interface{} `json:"account"`
	Profile          string                 `json:"profile"`
}

consider making this a shared type

type InfraTestsRequests

type InfraTestsRequests struct {
	SandboxName string `json:"sandbox_name"`
}

type Params

type Params struct {
	fx.In

	V              *validator.Validate
	Mw             metrics.Writer
	L              *zap.Logger
	TemporalClient temporal.Client
	Cfg            *internal.Config
	AuthzClient    *authz.Client
	AcctClient     *account.Client
	QueueClient    *queueclient.Client
	GeneralHelpers *generalhelpers.Helpers
	DB             *gorm.DB `name:"psql"`
	MW             metrics.Writer

	TemporalCodecGzip         converter.PayloadCodec `name:"gzip"`
	TemporalCodecLargePayload converter.PayloadCodec `name:"largepayload"`
	EndpointAudit             *apiPkg.EndpointAudit
}

type ProvisionCanaryRequest

type ProvisionCanaryRequest struct {
	SandboxMode bool `json:"sandbox_mode"`
}

type PublishMetricInput

type PublishMetricInput struct {
	Incr   *metrics.Incr   `json:"incr"`
	Decr   *metrics.Decr   `json:"decr"`
	Timing *metrics.Timing `json:"timing"`
	Event  *metrics.Event  `json:"event"`
}

type StartCanaryCronRequest

type StartCanaryCronRequest struct {
	SandboxMode bool `json:"sandbox_mode"`
}

type StaticTokenRequest

type StaticTokenRequest struct {
	// defaults to one year
	Duration string `json:"duration" validate:"required" default:"8760h"`

	EmailOrSubject string `json:"email_or_subject" validate:"required"`
}

func (*StaticTokenRequest) Validate

func (c *StaticTokenRequest) Validate(v *validator.Validate) error

type StaticTokenResponse

type StaticTokenResponse struct {
	APIToken string `json:"api_token,omitzero"`
}

type StopCanaryCronRequest

type StopCanaryCronRequest struct {
	SandboxMode bool `json:"sandbox_mode"`
}

type VerifyBlobsStatusResponse added in v0.19.1024

type VerifyBlobsStatusResponse struct {
	Running        bool                 `json:"running"`
	Status         string               `json:"status"`
	RunID          string               `json:"run_id,omitempty"`
	StartedAt      *time.Time           `json:"started_at,omitempty"`
	ClosedAt       *time.Time           `json:"closed_at,omitempty"`
	ElapsedSeconds float64              `json:"elapsed_seconds,omitempty"`
	Elapsed        string               `json:"elapsed,omitempty"`
	Progress       *blobverify.Progress `json:"progress,omitempty"`
}

type WaitlistRequest

type WaitlistRequest struct {
	OrgName string `json:"org_name" validate:"required"`
}

func (*WaitlistRequest) Validate

func (c *WaitlistRequest) Validate(v *validator.Validate) error

type WaitlistResponse

type WaitlistResponse struct {
	ID             string    `json:"id,omitzero"`
	OrgName        string    `json:"org_name,omitzero"`
	CreatedByID    string    `json:"created_by_id,omitzero"`
	CreatedByEmail string    `json:"created_by_email,omitzero"`
	CreatedAt      time.Time `json:"created_at,omitzero"`
}

Jump to

Keyboard shortcuts

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