models

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