models

Mar 13, 2026

Changes in this version

+ func ForceDeleteResourcesAndPlacement(dbpool *pgxpool.Pool, serviceUuid string, clusterName string) error

+ func InsertAuditEntry(dbpool *pgxpool.Pool, entry AuditEntry) error

+ func PurgeAuditLog(dbpool *pgxpool.Pool, retention time.Duration) (int64, error)

+ func RecordTokenUsage(dbpool *pgxpool.Pool, tokenID int) error

+ func StartAuditLogPurge(ctx context.Context, dbpool *pgxpool.Pool, retention time.Duration)

+ func ValidateClusterAnnotations(annotations map[string]string) error

+ type AuditEntry struct

+ Actor string

+ CreatedAt time.Time

+ ID int64

+ Method string

+ Path string

+ RequestID string

+ Role string

+ StatusCode int

+ func FetchAuditLogByActor(dbpool *pgxpool.Pool, actor string, limit int) ([]AuditEntry, error)

type ClusterData

+ AllowedUpdateRoles []string

+ CurrentPlacementCount *int

+ type ClusterPlacementInfo struct

+ ClusterNames []string

+ OnlyThisCluster bool

+ PlacementID int

+ ServiceUuid string

+ Status string

type OcpSandboxProvider

+ func (a *OcpSandboxProvider) CreateOffboardJob(ctx context.Context, clusterName string, ...) (*Job, error)

+ func (a *OcpSandboxProvider) ExecuteOffboard(job *Job, clusterName string, placements []ClusterPlacementInfo, ...)

+ func (a *OcpSandboxProvider) GetOffboardJob(ctx context.Context, clusterName string) (*Job, error)

+ func (p *OcpSandboxProvider) GetPlacementsByClusterName(clusterName string) ([]ClusterPlacementInfo, error)

type OcpSharedClusterConfiguration

+ CreatedBy string

+ func (p *OcpSharedClusterConfiguration) CanModify(role, callerName string) bool

+ func (p *OcpSharedClusterConfiguration) SharedView() OcpSharedClusterConfiguration

+ type OffboardDetails struct

+ ClusterName string

+ Report OffboardReport

+ type OffboardPlacementInfo struct

+ ClusterNames []string

+ PlacementID int

+ ServiceUuid string

+ Status string

+ type OffboardReport struct

+ ClusterDeleted bool

+ ClusterDisabled bool

+ Message string

+ PlacementsDeleted []OffboardPlacementInfo

+ PlacementsRequiringManualCleanup []OffboardPlacementInfo

type Token

+ LastUsedAt *time.Time

+ UseCount int

Feb 27, 2026

Changes in this version

+ func KeycloakUsername(prefix, guid string) string

+ func ParseHumanDuration(s string) (time.Duration, error)

+ type ClusterData struct

+ DeployerAdminSATokenRotationCount int

+ DeployerAdminSATokenUpdatedAt time.Time

type OcpSandboxProvider

+ RotateNow chan struct{}

+ func (a *OcpSandboxProvider) RotateDeployerAdminSATokens()

+ func (a *OcpSandboxProvider) StartDeployerAdminSATokenRotation(ctx context.Context)

+ func (a *OcpSandboxProvider) TriggerRotation()

type OcpSharedClusterConfiguration

+ Data ClusterData

+ DeployerAdminSAToken string

+ DeployerAdminSATokenRefreshInterval string

+ DeployerAdminSATokenTTL string

+ DeployerAdminSATokenTargetVar string

+ func (cluster *OcpSharedClusterConfiguration) CreateDeployerAdminSAToken() (string, error)

+ func (p *OcpSharedClusterConfiguration) SaveDeployerAdminSAToken(token string) error

Feb 24, 2026

Changes in this version

type OcpSharedClusterConfiguration

+ MaxPlacements *int

Feb 10, 2026

Changes in this version

type AwsAccount

+ CreationStatus string

+ Stage string

Jan 21, 2026

Changes in this version

type AwsAccount

+ RhssoUsername string

type AwsAccountProvider

+ FetchByNameWithCreds func(name string) (AwsAccountWithCreds, error)

type AwsAccountWithCreds

+ CustomData map[string]any

+ Warnings []string

type OcpSandboxWithCreds

+ func (a *OcpSandboxWithCreds) SetStatusWithMessage(status string, message string) error

Jan 5, 2026

Changes in this version

+ const OriginalReplicasAnnotation

+ const OriginalRunStrategyAnnotation

+ type AwsInstance struct

+ InstanceId string

+ InstanceName string

+ InstanceType string

+ Region string

+ State string

type LifecyclePlacementJob

+ func (j *LifecyclePlacementJob) AggregateLifecycleResults() (Status, error)

+ type OcpResource struct

+ Cluster string

+ Kind string

+ Name string

+ Namespace string

+ ReadyReplicas *int32

+ Replicas *int32

+ RunStrategy string

+ State string

+ UID string

type OcpSandbox

+ func (a OcpSandbox) GetLastStatus(dbpool *pgxpool.Pool) (*LifecycleResourceJob, error)

type OcpSandboxWithCreds

+ func (a *OcpSandboxWithCreds) GetLifecycleStatus(ctx context.Context, job *LifecycleResourceJob) (Status, error)

+ func (a *OcpSandboxWithCreds) Start(ctx context.Context, job *LifecycleResourceJob) error

+ func (a *OcpSandboxWithCreds) Stop(ctx context.Context, job *LifecycleResourceJob) error

type Status

+ AwsInstances []AwsInstance

+ OcpResources []OcpResource

Dec 19, 2025

Changes in this version

+ type PlacementFilter struct

+ Annotations map[string]any

+ Limit *int

+ Offset *int

+ ServiceUuid *string

+ Status *string

+ ToCleanup *bool

type Placements

+ func GetPlacementsFiltered(dbpool *pgxpool.Pool, filter PlacementFilter) (Placements, error)

Nov 25, 2025

Changes in this version

+ var ErrNoJobFound = errors.New("no job found for type")

type OcpSandboxProvider

+ func (a *OcpSandboxProvider) SelfHealStaleFleetStatusJobs(ctx context.Context) error

Nov 19, 2025

Changes in this version

type OcpSandbox

+ Alias string

type ReservationRequest

+ func (r *ReservationRequest) ValidateWithCurrent(h AwsAccountProvider, currentReservation *Reservation) (string, error)

Oct 28, 2025

Changes in this version

+ const ClusterStatusTimeout

+ const DebugForceFailKey

+ const DebugForceTimeoutKey

+ const FleetStatusTimeout

+ const FleetStatusTimeoutKey

Sep 18, 2025

Changes in this version

type PlacementWithCreds

+ func (p *PlacementWithCreds) LoadResourcesWithCreds(awsProvider AwsAccountProvider, ocpProvider OcpSandboxProvider, ...) error

+ func (p *PlacementWithCreds) Render(w http.ResponseWriter, r *http.Request) error

Jul 25, 2025

Changes in this version

+ func GetJobBody[T any](job Job) (T, error)

+ func SetJobBody[T any](job *Job, details T) error

+ type Job struct

+ Body map[string]any

+ CompletedAt time.Time

+ JobType string

+ Locality string

+ ParentJobID int

+ PlacementID int

+ RequestID string

+ Status string

+ func (t *Job) Render(w http.ResponseWriter, r *http.Request) error

+ type JobStore struct

+ DB *pgxpool.Pool

+ func NewJobStore(db *pgxpool.Pool) *JobStore

+ func (s *JobStore) CreateJob(ctx context.Context, job *Job) error

+ func (s *JobStore) DeleteJob(ctx context.Context, id int) error

+ func (s *JobStore) GetJobByID(ctx context.Context, id int) (*Job, error)

+ func (s *JobStore) GetJobByRequestID(ctx context.Context, requestID string) (*Job, error)

+ func (s *JobStore) GetJobsByType(ctx context.Context, jobType string) ([]*Job, error)

+ func (s *JobStore) GetLatestJobByType(ctx context.Context, jobType string) (*Job, error)

+ func (s *JobStore) SaveJob(ctx context.Context, job *Job) error

+ func (s *JobStore) SetJobStatus(ctx context.Context, job *Job, status string) error

+ func (s *JobStore) UpdateJob(ctx context.Context, job *Job) error

+ type OcpClusterStatusBody struct

+ ClusterName string

+ Configuration OcpSharedClusterConfiguration

+ Message string

+ NodeSummary map[string]int

+ OCPUpdateHistory []any

+ OCPVersion string

+ OperatorStatus map[string]OperatorInfo

+ type OcpFleetStatusBody struct

+ Clusters map[string]OcpClusterStatusBody

+ Message string

type OcpSandboxProvider

+ func (a *OcpSandboxProvider) CreateOcpFleetStatusJob(ctx context.Context) (*Job, error)

+ func (a *OcpSandboxProvider) FleetStatus(ctx context.Context, job *Job)

+ func (a *OcpSandboxProvider) GetOcpFleetStatusJob(ctx context.Context) (*Job, error)

+ func (a *OcpSandboxProvider) IsOcpFleetStatusInProgress(ctx context.Context) bool

+ func (a *OcpSandboxProvider) OcpSharedClusterStatus(ctx context.Context, job *Job, conf OcpSharedClusterConfiguration)

type OcpSharedClusterConfiguration

+ func (p *OcpSharedClusterConfiguration) WithoutCredentials() OcpSharedClusterConfiguration

+ type OperatorInfo struct

+ Status string

+ Version string

Jul 9, 2025

Changes in this version

type OcpSandbox

+ OcpConsoleUrl string

Jul 3, 2025

Changes in this version

type AwsAccountProvider

+ GetCandidates func(reservation string, count int) ([]AwsAccount, error)

Jun 10, 2025

Changes in this version

type AwsAccountProvider

+ CountAll func() (int, error)

+ CountReservation func(reservation string) (int, error)

+ CountReservationAvailable func(reservation string) (int, error)

+ type KeycloakCredential struct

+ Kind string

+ Password string

+ Username string

Mar 24, 2025

Changes in this version

type AwsAccountProvider

+ RenameReservation func(oldName, newName string) error

type Reservation

+ func (r *Reservation) Rename(dbpool *pgxpool.Pool, a AwsAccountProvider, name string)

Feb 27, 2025

Changes in this version

+ var DNSErrNoEnoughAccountsAvailable = errors.New("no enough accounts available")

+ var DNSErrNoSchedule error = errors.New("No DNS account configuration found")

+ var DNSnameRegex = regexp.MustCompile(`^[a-zA-Z0-9-]+$`)

+ var IBMErrNoEnoughAccountsAvailable = errors.New("no enough accounts available")

+ var IBMErrNoSchedule error = errors.New("No IBM resource group account configuration found")

+ var IBMResourceGroupSandboxNameRegex = regexp.MustCompile(`^[a-zA-Z0-9-]+$`)

+ func DNSguessNextGuid(origGuid string, serviceUuid string, dbpool *pgxpool.Pool, multiple bool, ...) (string, error)

+ func IBMResourceGroupSandboxGuessNextGuid(origGuid string, serviceUuid string, dbpool *pgxpool.Pool, ctx context.Context) (string, error)

+ type APIKeyResponse struct

+ AccessAPIKey string

+ type ByWeight []OcpSharedClusterConfiguration

+ func (a ByWeight) Len() int

+ func (a ByWeight) Less(i, j int) bool

+ func (a ByWeight) Swap(i, j int)

+ type ClusterRelation struct

+ Reference string

+ Relation string

+ type DNSAccountConfiguration struct

+ AdditionalVars map[string]any

+ Annotations map[string]string

+ AwsAccessKeyID string

+ AwsSecretAccessKey string

+ CreatedAt time.Time

+ DbPool *pgxpool.Pool

+ HostedZoneID string

+ ID int

+ Name string

+ UpdatedAt time.Time

+ Valid bool

+ VaultSecret string

+ Zone string

+ func MakeDNSAccountConfiguration() *DNSAccountConfiguration

+ func (p *DNSAccountConfiguration) Bind(r *http.Request) error

+ func (p *DNSAccountConfiguration) Delete() error

+ func (p *DNSAccountConfiguration) Disable() error

+ func (p *DNSAccountConfiguration) Enable() error

+ func (p *DNSAccountConfiguration) GetAccountCount() (int, error)

+ func (p *DNSAccountConfiguration) Render(w http.ResponseWriter, r *http.Request) error

+ func (p *DNSAccountConfiguration) Save() error

+ func (p *DNSAccountConfiguration) Update() error

+ type DNSAccountConfigurations []DNSAccountConfiguration

+ func (p *DNSAccountConfigurations) Render(w http.ResponseWriter, r *http.Request) error

+ type DNSSandbox struct

+ AdditionalVars map[string]any

+ Annotations map[string]string

+ CleanupCount int

+ DNSAccountConfigurationName string

+ ErrorMessage string

+ Kind string

+ Name string

+ ServiceUuid string

+ Status string

+ ToCleanup bool

+ func (a *DNSSandbox) Render(w http.ResponseWriter, r *http.Request) error

+ func (a *DNSSandbox) Save(dbpool *pgxpool.Pool) error

+ func (sandbox *DNSSandbox) Delete() error

+ type DNSSandboxProvider struct

+ DbPool *pgxpool.Pool

+ VaultSecret string

+ func NewDNSSandboxProvider(dbpool *pgxpool.Pool, vaultSecret string) DNSSandboxProvider

+ func (a *DNSSandboxProvider) FetchAll() ([]DNSSandbox, error)

+ func (a *DNSSandboxProvider) FetchAllByServiceUuid(serviceUuid string) ([]DNSSandbox, error)

+ func (a *DNSSandboxProvider) FetchAllByServiceUuidWithCreds(serviceUuid string) ([]DNSSandboxWithCreds, error)

+ func (a *DNSSandboxProvider) GetSchedulableAccounts(cloud_selector map[string]string) (DNSAccountConfigurations, error)

+ func (a *DNSSandboxProvider) Release(service_uuid string) error

+ func (a *DNSSandboxProvider) Request(serviceUuid string, cloud_selector map[string]string, ...) (DNSSandboxWithCreds, error)

+ func (p *DNSSandboxProvider) FetchById(id int) (DNSSandbox, error)

+ func (p *DNSSandboxProvider) FetchByName(name string) (DNSSandbox, error)

+ func (p *DNSSandboxProvider) GetDNSAccountConfigurationByAnnotations(annotations map[string]string) ([]DNSAccountConfiguration, error)

+ func (p *DNSSandboxProvider) GetDNSAccountConfigurationByName(name string) (DNSAccountConfiguration, error)

+ func (p *DNSSandboxProvider) GetDNSAccountConfigurations() (DNSAccountConfigurations, error)

+ type DNSSandboxWithCreds struct

+ Credentials []any

+ Provider *DNSSandboxProvider

+ func (a *DNSSandboxWithCreds) GetStatus() (string, error)

+ func (a *DNSSandboxWithCreds) IncrementCleanupCount() error

+ func (a *DNSSandboxWithCreds) MarkForCleanup() error

+ func (a *DNSSandboxWithCreds) Reload() error

+ func (a *DNSSandboxWithCreds) Render(w http.ResponseWriter, r *http.Request) error

+ func (a *DNSSandboxWithCreds) Save() error

+ func (a *DNSSandboxWithCreds) SetStatus(status string) error

+ func (a *DNSSandboxWithCreds) Update() error

+ func (sandbox *DNSSandboxWithCreds) Delete() error

+ type DNSSandboxes []DNSSandbox

+ type DNSServiceAccount struct

+ AwsAccessKeyID string

+ AwsSecretAccessKey string

+ HostedZoneID string

+ Kind string

+ Zone string

+ type IBMResourceGroupSandbox struct

+ Annotations map[string]string

+ CleanupCount int

+ DeployerAdditionalVars map[string]any

+ ErrorMessage string

+ IBMResourceGroupSandboxConfigurationName string

+ Kind string

+ Name string

+ ResourceGroup string

+ ServiceUuid string

+ Status string

+ ToCleanup bool

+ func (a *IBMResourceGroupSandbox) Render(w http.ResponseWriter, r *http.Request) error

+ type IBMResourceGroupSandboxConfiguration struct

+ APIKey string

+ AdditionalVars map[string]any

+ Annotations map[string]string

+ CreatedAt time.Time

+ DbPool *pgxpool.Pool

+ ID int

+ Name string

+ UpdatedAt time.Time

+ Valid bool

+ VaultSecret string

+ func MakeIBMResourceGroupSandboxConfiguration() *IBMResourceGroupSandboxConfiguration

+ func (p *IBMResourceGroupSandboxConfiguration) Bind(r *http.Request) error

+ func (p *IBMResourceGroupSandboxConfiguration) Delete() error

+ func (p *IBMResourceGroupSandboxConfiguration) Disable() error

+ func (p *IBMResourceGroupSandboxConfiguration) Enable() error

+ func (p *IBMResourceGroupSandboxConfiguration) GetAccountCount() (int, error)

+ func (p *IBMResourceGroupSandboxConfiguration) Render(w http.ResponseWriter, r *http.Request) error

+ func (p *IBMResourceGroupSandboxConfiguration) Save() error

+ func (p *IBMResourceGroupSandboxConfiguration) Update() error

+ type IBMResourceGroupSandboxConfigurations []IBMResourceGroupSandboxConfiguration

+ func (p *IBMResourceGroupSandboxConfigurations) Render(w http.ResponseWriter, r *http.Request) error

+ type IBMResourceGroupSandboxProvider struct

+ DbPool *pgxpool.Pool

+ VaultSecret string

+ func NewIBMResourceGroupSandboxProvider(dbpool *pgxpool.Pool, vaultSecret string) IBMResourceGroupSandboxProvider

+ func (a *IBMResourceGroupSandboxProvider) FetchAll() ([]IBMResourceGroupSandbox, error)

+ func (a *IBMResourceGroupSandboxProvider) FetchAllByServiceUuid(serviceUuid string) ([]IBMResourceGroupSandbox, error)

+ func (a *IBMResourceGroupSandboxProvider) FetchAllByServiceUuidWithCreds(serviceUuid string) ([]IBMResourceGroupSandboxWithCreds, error)

+ func (a *IBMResourceGroupSandboxProvider) GetSchedulableAccounts(cloud_selector map[string]string) (IBMResourceGroupSandboxConfigurations, error)

+ func (a *IBMResourceGroupSandboxProvider) Release(service_uuid string) error

+ func (a *IBMResourceGroupSandboxProvider) Request(serviceUuid string, cloud_selector map[string]string, ...) (IBMResourceGroupSandboxWithCreds, error)

+ func (p *IBMResourceGroupSandboxProvider) FetchById(id int) (IBMResourceGroupSandbox, error)

+ func (p *IBMResourceGroupSandboxProvider) FetchByName(name string) (IBMResourceGroupSandbox, error)

+ func (p *IBMResourceGroupSandboxProvider) GetIBMResourceGroupSandboxConfigurationByAnnotations(annotations map[string]string) ([]IBMResourceGroupSandboxConfiguration, error)

+ func (p *IBMResourceGroupSandboxProvider) GetIBMResourceGroupSandboxConfigurationByName(name string) (IBMResourceGroupSandboxConfiguration, error)

+ func (p *IBMResourceGroupSandboxProvider) GetIBMResourceGroupSandboxConfigurations() (IBMResourceGroupSandboxConfigurations, error)

+ type IBMResourceGroupSandboxWithCreds struct

+ Credentials []any

+ Provider *IBMResourceGroupSandboxProvider

+ func (a *IBMResourceGroupSandboxWithCreds) GetStatus() (string, error)

+ func (a *IBMResourceGroupSandboxWithCreds) IncrementCleanupCount() error

+ func (a *IBMResourceGroupSandboxWithCreds) MarkForCleanup() error

+ func (a *IBMResourceGroupSandboxWithCreds) Reload() error

+ func (a *IBMResourceGroupSandboxWithCreds) Render(w http.ResponseWriter, r *http.Request) error

+ func (a *IBMResourceGroupSandboxWithCreds) Save() error

+ func (a *IBMResourceGroupSandboxWithCreds) SetStatus(status string) error

+ func (a *IBMResourceGroupSandboxWithCreds) Update() error

+ func (account *IBMResourceGroupSandboxWithCreds) Delete() error

+ type IBMResourceGroupSandboxes []IBMResourceGroupSandbox

+ type IBMResourceGroupServiceAccount struct

+ APIKey string

+ Name string

+ type MultipleOcpAccount struct

+ Account OcpSandbox

+ Alias string

type OcpSharedClusterConfiguration

+ Weight int

+ func ApplyPriorityWeight(clusters []OcpSharedClusterConfiguration, preferences map[string]string, ...) []OcpSharedClusterConfiguration

+ type PolicyDocument struct

+ Statement []PolicyStatement

+ Version string

+ type PolicyStatement struct

+ Action interface{}

+ Effect string

+ Principal map[string]string

+ Resource interface{}

Nov 5, 2024

Changes in this version

type OcpSharedClusterConfiguration

+ UsageNodeSelector string

Oct 21, 2024

Changes in this version

type OcpSharedClusterConfiguration

+ func (a *OcpSharedClusterConfiguration) TestConnection() error

Sep 25, 2024

Changes in this version

+ func ApplyQuota(requestedQuotaOrig *v1.ResourceQuota, defaultQuota *v1.ResourceQuota, ...) *v1.ResourceQuota

type OcpSandbox

+ ErrorMessage string

+ LimitRange *v1.LimitRange

+ Quota v1.ResourceList

type OcpSharedClusterConfiguration

+ DefaultSandboxQuota *v1.ResourceQuota

+ LimitRange *v1.LimitRange

+ QuotaRequired bool

+ SkipQuota bool

+ StrictDefaultSandboxQuota bool

+ func MakeOcpSharedClusterConfiguration() *OcpSharedClusterConfiguration

type Resource

+ ErrorMessage string

Jul 1, 2024

Changes in this version

type OcpSharedClusterConfiguration

+ func (p *OcpSharedClusterConfiguration) Enable() error

Jun 18, 2024

Changes in this version

type OcpSharedClusterConfiguration

+ MaxCpuUsagePercentage float64

+ MaxMemoryUsagePercentage float64

Jun 7, 2024

Changes in this version

type OcpSharedClusterConfiguration

+ Token string

+ func (a *OcpSharedClusterConfiguration) CreateRestConfig() (*rest.Config, error)

Jun 3, 2024

Changes in this version

type OcpSandbox

+ ToCleanup bool

type Placement

+ DbPool *pgxpool.Pool

+ FailOnDelete bool

+ ToCleanup bool

+ func (p *Placement) Create() error

+ func (p *Placement) MarkForCleanup() error

May 27, 2024

Changes in this version

+ var ErrNoSchedule error = errors.New("No OCP shared cluster configuration found")

+ var OcpErrNoEnoughAccountsAvailable = errors.New("no enough accounts available")

+ type Annotations map[string]string

+ func (a Annotations) Merge(b Annotations) Annotations

type AwsAccountWithCreds

+ Provider AwsAccountProvider

+ func (a *AwsAccountWithCreds) Delete() error

+ func (a *AwsAccountWithCreds) Render(w http.ResponseWriter, r *http.Request) error

+ type Deletable interface

+ Delete func() error

+ type OcpSandbox struct

+ Annotations map[string]string

+ CleanupCount int

+ ClusterAdditionalVars map[string]any

+ Kind string

+ Name string

+ Namespace string

+ OcpApiUrl string

+ OcpIngressDomain string

+ OcpSharedClusterConfigurationName string

+ ServiceUuid string

+ Status string

+ func (a *OcpSandbox) Render(w http.ResponseWriter, r *http.Request) error

+ func (a *OcpSandbox) Save(dbpool *pgxpool.Pool) error

+ type OcpSandboxProvider struct

+ DbPool *pgxpool.Pool

+ VaultSecret string

+ func NewOcpSandboxProvider(dbpool *pgxpool.Pool, vaultSecret string) OcpSandboxProvider

+ func (a *OcpSandboxProvider) FetchAll() ([]OcpSandbox, error)

+ func (a *OcpSandboxProvider) FetchAllByServiceUuid(serviceUuid string) ([]OcpSandbox, error)

+ func (a *OcpSandboxProvider) FetchAllByServiceUuidWithCreds(serviceUuid string) ([]OcpSandboxWithCreds, error)

+ func (a *OcpSandboxProvider) GetSchedulableClusters(cloud_selector map[string]string) (OcpSharedClusterConfigurations, error)

+ func (a *OcpSandboxProvider) Release(service_uuid string) error

+ func (a *OcpSandboxProvider) Request(serviceUuid string, cloud_selector map[string]string, ...) (OcpSandboxWithCreds, error)

+ func (p *OcpSandboxProvider) FetchById(id int) (OcpSandbox, error)

+ func (p *OcpSandboxProvider) FetchByName(name string) (OcpSandbox, error)

+ func (p *OcpSandboxProvider) GetOcpSharedClusterConfigurationByAnnotations(annotations map[string]string) ([]OcpSharedClusterConfiguration, error)

+ func (p *OcpSandboxProvider) GetOcpSharedClusterConfigurationByName(name string) (OcpSharedClusterConfiguration, error)

+ func (p *OcpSandboxProvider) GetOcpSharedClusterConfigurations() (OcpSharedClusterConfigurations, error)

+ type OcpSandboxWithCreds struct

+ Credentials []any

+ Provider *OcpSandboxProvider

+ func (a *OcpSandboxWithCreds) GetStatus() (string, error)

+ func (a *OcpSandboxWithCreds) IncrementCleanupCount() error

+ func (a *OcpSandboxWithCreds) MarkForCleanup() error

+ func (a *OcpSandboxWithCreds) Reload() error

+ func (a *OcpSandboxWithCreds) Render(w http.ResponseWriter, r *http.Request) error

+ func (a *OcpSandboxWithCreds) Save() error

+ func (a *OcpSandboxWithCreds) SetStatus(status string) error

+ func (a *OcpSandboxWithCreds) Update() error

+ func (account *OcpSandboxWithCreds) Delete() error

+ type OcpSandboxes []OcpSandbox

+ type OcpServiceAccount struct

+ Kind string

+ Name string

+ Token string

+ type OcpSharedClusterConfiguration struct

+ AdditionalVars map[string]any

+ Annotations map[string]string

+ ApiUrl string

+ CreatedAt time.Time

+ DbPool *pgxpool.Pool

+ ID int

+ IngressDomain string

+ Kubeconfig string

+ Name string

+ UpdatedAt time.Time

+ Valid bool

+ VaultSecret string

+ func (p *OcpSharedClusterConfiguration) Bind(r *http.Request) error

+ func (p *OcpSharedClusterConfiguration) Delete() error

+ func (p *OcpSharedClusterConfiguration) Disable() error

+ func (p *OcpSharedClusterConfiguration) GetAccountCount() (int, error)

+ func (p *OcpSharedClusterConfiguration) Render(w http.ResponseWriter, r *http.Request) error

+ func (p *OcpSharedClusterConfiguration) Save() error

+ func (p *OcpSharedClusterConfiguration) Update() error

+ type OcpSharedClusterConfigurations []OcpSharedClusterConfiguration

+ func (p *OcpSharedClusterConfigurations) Render(w http.ResponseWriter, r *http.Request) error

type Placement

+ Status string

+ func (p *Placement) SetStatus(dbpool *pgxpool.Pool, status string) error

+ type TokenResponse struct

+ AccessToken string

Feb 18, 2024

Changes in this version

type AwsAccount

+ ConanCleanupCount int

+ func (a AwsAccount) CloseAccount() error

type AwsAccountProvider

+ Delete func(name string) error

Oct 12, 2023

Changes in this version

+ func FilterByReservation(resources []T, reservation string) []T

type AvailabilityMarker

+ GetReservation func() string

type AwsAccount

+ Reservation string

+ func (a *AwsAccount) Render(w http.ResponseWriter, r *http.Request) error

+ func (a AwsAccount) GetReservation() string

type AwsAccountProvider

+ Count func() (int, error)

+ CountAvailable func(reservation string) (int, error)

+ FetchAllActiveByServiceUuid func(serviceUuid string) ([]AwsAccount, error)

+ FetchAllActiveByServiceUuidWithCreds func(serviceUuid string) ([]AwsAccountWithCreds, error)

+ FetchAllAvailable func() ([]AwsAccount, error)

+ FetchAllByReservation func(reservation string) ([]AwsAccount, error)

+ Reserve func(reservation string, count int) ([]AwsAccount, error)

+ ScaleDownReservation func(reservation string, count int) error

+ type AwsAccounts []AwsAccount

+ func (a *AwsAccounts) Render(w http.ResponseWriter, r *http.Request) error

type LifecyclePlacementJob

+ Locality string

type LifecycleResourceJob

+ Locality string

type Placement

+ func (p *Placement) LoadActiveResources(accountProvider AwsAccountProvider) error

+ func (p *Placement) LoadActiveResourcesWithCreds(accountProvider AwsAccountProvider) error

+ type Reservation struct

+ Name string

+ Request ReservationRequest

+ Status string

+ func GetReservationByName(dbpool *pgxpool.Pool, name string) (Reservation, error)

+ func (o *Reservation) Render(w http.ResponseWriter, r *http.Request) error

+ func (r *Reservation) Delete(dbpool *pgxpool.Pool) error

+ func (r *Reservation) Initialize(dbpool *pgxpool.Pool, a AwsAccountProvider)

+ func (r *Reservation) Remove(dbpool *pgxpool.Pool, a AwsAccountProvider)

+ func (r *Reservation) Save(dbpool *pgxpool.Pool) error

+ func (r *Reservation) Update(dbpool *pgxpool.Pool, a AwsAccountProvider, req ReservationRequest)

+ func (r *Reservation) UpdateStatus(dbpool *pgxpool.Pool, status string) error

+ type ReservationRequest struct

+ Name string

+ Resources []ResourceRequest

+ func (r *ReservationRequest) Bind(r2 *http.Request) error

+ func (r *ReservationRequest) Validate(h AwsAccountProvider) (string, error)

+ type Reservations []Reservation

+ func (o Reservations) Render(w http.ResponseWriter, r *http.Request) error

+ type ResourceRequest struct

+ Count int

+ Kind string

Jul 20, 2023

Changes in this version

type LifecyclePlacementJob

+ func GetLifecyclePlacementJobByRequestID(dbpool *pgxpool.Pool, requestID string) (*LifecyclePlacementJob, error)

+ func (j *LifecyclePlacementJob) Create() error

+ func (j *LifecyclePlacementJob) GlobalStatus() (string, error)

type LifecycleResourceJob

+ func GetLifecycleResourceJobByRequestID(dbpool *pgxpool.Pool, requestID string) (*LifecycleResourceJob, error)

type Placement

+ func (p *Placement) GetLastStatus(dbpool *pgxpool.Pool) ([]*LifecycleResourceJob, error)

type Status

+ AccountKind string

+ AccountName string

+ Status string

+ UpdatedAt time.Time

+ func MakeStatus(job *LifecycleResourceJob) Status

Jun 28, 2023

Changes in this version

type AwsAccountProvider

+ FetchAllByServiceUuidWithCreds func(serviceUuid string) ([]AwsAccountWithCreds, error)

type Placement

+ func (p *Placement) LoadResourcesWithCreds(accountProvider AwsAccountProvider) error

Jun 13, 2023

Changes in this version

+ var ErrNoClaim = errors.New("no claim")

type AwsAccount

+ func (a AwsAccount) GetLastStatus(dbpool *pgxpool.Pool) (*LifecycleResourceJob, error)

+ func (a AwsAccount) Start(creds *ststypes.Credentials) error

+ func (a AwsAccount) Status(creds *ststypes.Credentials, job *LifecycleResourceJob) (Status, error)

+ func (a AwsAccount) Stop(creds *ststypes.Credentials) error

+ type Instance struct

+ InstanceId string

+ InstanceName string

+ InstanceType string

+ Region string

+ State string

+ type LifecyclePlacementJob struct

+ Action string

+ DbPool *pgxpool.Pool

+ PlacementID int

+ Request any

+ RequestID string

+ Status string

+ func GetLifecyclePlacementJob(dbpool *pgxpool.Pool, id int) (*LifecyclePlacementJob, error)

+ func (j *LifecyclePlacementJob) Claim() error

+ func (j *LifecyclePlacementJob) SetStatus(status string) error

+ type LifecycleResourceJob struct

+ Action string

+ DbPool *pgxpool.Pool

+ ParentID int

+ Request any

+ RequestID string

+ ResourceName string

+ ResourceType string

+ Result Status

+ Status string

+ func GetLifecycleResourceJob(dbpool *pgxpool.Pool, id int) (*LifecycleResourceJob, error)

+ func (j *LifecycleResourceJob) Claim() error

+ func (j *LifecycleResourceJob) Create() error

+ func (j *LifecycleResourceJob) SetStatus(status string) error

+ type Status struct

+ Instances []Instance

Apr 28, 2023

Changes in this version

+ var ErrAccountNotFound = errors.New("account not found")

+ var ErrNoEnoughAccountsAvailable = errors.New("no enough accounts available")

+ func CountAvailable(resources []T) int

+ func CountOlder(duration time.Duration, accounts []Resource) (int, error)

+ func CountToCleanup(resources []T) int

+ func CountUsed(resources []T) int

+ func DeletePlacementByServiceUuid(dbpool *pgxpool.Pool, accountProvider AwsAccountProvider, serviceUuid string) error

+ func Sort(accounts []T, by string) []T

+ func Used(resources []T) []T

+ type Account struct

+ type AvailabilityMarker interface

+ type AwsAccount struct

+ AccountID string

+ ConanHostname string

+ ConanStatus string

+ ConanTimestamp time.Time

+ HostedZoneID string

+ Kind string

+ Name string

+ Zone string

+ func (a AwsAccount) GetUpdatedAt() time.Time

+ func (a AwsAccount) NameInt() int

+ type AwsAccountProvider interface

+ DecryptSecret func(encrypted string) (string, error)

+ FetchAll func() ([]AwsAccount, error)

+ FetchAllByServiceUuid func(serviceUuid string) ([]AwsAccount, error)

+ FetchAllSorted func(by string) ([]AwsAccount, error)

+ FetchAllToCleanup func() ([]AwsAccount, error)

+ FetchByName func(name string) (AwsAccount, error)

+ MarkForCleanup func(name string) error

+ MarkForCleanupByServiceUuid func(serviceUuid string) error

+ Request func(service_uuid string, count int, annotations map[string]string) ([]AwsAccountWithCreds, error)

+ type AwsAccountWithCreds struct

+ Credentials []any

+ type AwsIamKey struct

+ AwsAccessKeyID string

+ AwsSecretAccessKey string

+ Kind string

+ Name string

+ type Model struct

+ CreatedAt time.Time

+ ID int

+ UpdatedAt time.Time

+ type Placement struct

+ Annotations map[string]string

+ Request any

+ Resources []any

+ ServiceUuid string

+ func GetPlacement(dbpool *pgxpool.Pool, id int) (*Placement, error)

+ func GetPlacementByServiceUuid(dbpool *pgxpool.Pool, serviceUuid string) (*Placement, error)

+ func (p *Placement) Delete(dbpool *pgxpool.Pool, accountProvider AwsAccountProvider) error

+ func (p *Placement) LoadResources(accountProvider AwsAccountProvider) error

+ func (p *Placement) Render(w http.ResponseWriter, r *http.Request) error

+ func (p *Placement) Save(dbpool *pgxpool.Pool) error

+ type PlacementWithCreds struct

+ Resources []any

+ type Placements []Placement

+ func GetAllPlacements(dbpool *pgxpool.Pool) (Placements, error)

+ func (p Placements) Render(w http.ResponseWriter, r *http.Request) error

+ type Resource struct

+ Annotations map[string]string

+ Available bool

+ ServiceUuid string

+ ToCleanup bool

+ type ResourceWithCreds struct

+ Credentials []any

+ type Sortable interface

+ GetUpdatedAt func() time.Time

+ NameInt func() int

+ type Token struct

+ Exp int64

+ Expiration time.Time

+ Iat int64

+ Kind string

+ Name string

+ Role string

+ Valid bool

+ func CreateToken(claims map[string]any) (Token, error)

+ func FetchTokenById(dbpool *pgxpool.Pool, id int) (Token, error)

+ func (t Token) Invalidate(dbpool *pgxpool.Pool) error

+ func (t Token) Save(dbpool *pgxpool.Pool) (id int, err error)

+ type Tokens []Token

+ func FetchAllTokens(dbpool *pgxpool.Pool) (Tokens, error)

+ func (t *Tokens) Render(w http.ResponseWriter, r *http.Request) error