Documentation
¶
Index ¶
- func New(params Params) *service
- type AdminBackfillBlobsRequest
- type AdminDeleteAccountRequest
- type AdminPromotionRequest
- type AdminVerifyBlobsRequest
- type BackfillBlobsStatusResponse
- type BackfillRunnerHealthcheckEmittersStatusResponse
- type CLIConfig
- type CreateCanaryUserRequest
- type CreateCanaryUserResponse
- type CreateIntegrationUserRequest
- type CreateIntegrationUserResponse
- type CreateSeedUserRequest
- type CreateSeedUserResponse
- type DeprovisionCanaryRequest
- type InfraTestsDeprovisionRequest
- type InfraTestsRequests
- type Params
- type ProvisionCanaryRequest
- type PublishMetricInput
- type StartCanaryCronRequest
- type StaticTokenRequest
- type StaticTokenResponse
- type StopCanaryCronRequest
- type VerifyBlobsStatusResponse
- type WaitlistRequest
- type WaitlistResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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"`
}
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 CreateCanaryUserRequest ¶
type CreateCanaryUserRequest struct {
CanaryID string `json:"canary_id"`
}
type CreateIntegrationUserRequest ¶
type CreateIntegrationUserRequest struct{}
type CreateSeedUserRequest ¶
type CreateSeedUserRequest struct{}
type CreateSeedUserResponse ¶
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 StartCanaryCronRequest ¶
type StartCanaryCronRequest struct {
SandboxMode bool `json:"sandbox_mode"`
}
type StaticTokenRequest ¶
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"`
}
Source Files
¶
- admin_backfill_blobs.go
- admin_backfill_runner_healthcheck_emitters.go
- admin_delete_account.go
- admin_get_waitlist.go
- admin_promotion.go
- admin_slack_auto_link.go
- admin_static_token.go
- admin_verify_blobs.go
- canary_deprovision.go
- canary_provision.go
- canary_start_cron.go
- canary_stop_cron.go
- canary_user.go
- cli_config.go
- cloud_platform_regions.go
- config_schema.go
- create_waitlist.go
- get_current_user.go
- infra_tests.go
- infra_tests_deprovision.go
- integration_user.go
- metrics.go
- migrations.go
- seed_user.go
- service.go
- temporal_codec_decode.go
Click to show internal directories.
Click to hide internal directories.