model

package
v0.0.0-...-03a9efe Latest Latest
Warning

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

 Go to latest Published: Jun 25, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CRDComponent      = "CRDs"
	CleanupComponent  = "cleaner"
	DeleteStrategyKey = "delete_strategy"

	SkippedComponentEnvVarPrefix = "SKIP_COMPONENT_"
)
View Source 
const DefaultBucket = "default"

Variables

This section is empty.

Functions

func IsInvalidValueError 

func IsInvalidValueError(err error) bool

func ValidateBucketName 

func ValidateBucketName(bucket string) error

Types

type BucketEntity 

type BucketEntity struct {
	Bucket   string    `db:"readOnly"`
	Created  time.Time `db:"readOnly"`
	Username string    `db:"readOnly"`
}

func (*BucketEntity) Equal 

func (b *BucketEntity) Equal(other db.DatabaseEntity) bool

func (*BucketEntity) Marshaller 

func (b *BucketEntity) Marshaller() *db.EntityMarshaller

func (*BucketEntity) New 

func (b *BucketEntity) New() db.DatabaseEntity

func (*BucketEntity) String 

func (b *BucketEntity) String() string

func (*BucketEntity) Table 

func (b *BucketEntity) Table() string

type CacheDependencyEntity 

type CacheDependencyEntity struct {
	Bucket    string    `db:"notNull"`
	Key       string    `db:"notNull"`
	Label     string    `db:"notNull"`
	RuntimeID string    `db:"notNull"`
	CacheID   int64     `db:"notNull"`
	Created   time.Time `db:"readOnly"`
}

func (*CacheDependencyEntity) Equal 

func (cde *CacheDependencyEntity) Equal(other db.DatabaseEntity) bool

func (*CacheDependencyEntity) Marshaller 

func (cde *CacheDependencyEntity) Marshaller() *db.EntityMarshaller

func (*CacheDependencyEntity) New 

func (cde *CacheDependencyEntity) New() db.DatabaseEntity

func (*CacheDependencyEntity) String 

func (cde *CacheDependencyEntity) String() string

func (*CacheDependencyEntity) Table 

func (cde *CacheDependencyEntity) Table() string

type CacheEntryEntity 

type CacheEntryEntity struct {
	ID        int64     `db:"readOnly"`
	Label     string    `db:"notNull"`
	RuntimeID string    `db:"notNull"`
	Data      string    `db:"notNull"`
	Checksum  string    `db:"notNull"`
	Created   time.Time `db:"readOnly"`
}

func (*CacheEntryEntity) Equal 

func (ce *CacheEntryEntity) Equal(other db.DatabaseEntity) bool

func (*CacheEntryEntity) Marshaller 

func (ce *CacheEntryEntity) Marshaller() *db.EntityMarshaller

func (*CacheEntryEntity) New 

func (ce *CacheEntryEntity) New() db.DatabaseEntity

func (*CacheEntryEntity) NewChecksum 

func (ce *CacheEntryEntity) NewChecksum() string

func (*CacheEntryEntity) String 

func (ce *CacheEntryEntity) String() string

func (*CacheEntryEntity) Table 

func (ce *CacheEntryEntity) Table() string

type ClusterCleanupEntity 

type ClusterCleanupEntity struct {
	StatusID  int64     `db:"notNull"`
	RuntimeID string    `db:"notNull"`
	ClusterID int64     `db:"notNull"`
	ConfigID  int64     `db:"notNull"`
	Status    string    `db:"notNull"`
	Created   time.Time `db:"readOnly"`
}

func (*ClusterCleanupEntity) Equal 

func (cce *ClusterCleanupEntity) Equal(other db.DatabaseEntity) bool

func (*ClusterCleanupEntity) Marshaller 

func (cce *ClusterCleanupEntity) Marshaller() *db.EntityMarshaller

func (*ClusterCleanupEntity) New 

func (cce *ClusterCleanupEntity) New() db.DatabaseEntity

func (*ClusterCleanupEntity) String 

func (cce *ClusterCleanupEntity) String() string

func (*ClusterCleanupEntity) Table 

func (cce *ClusterCleanupEntity) Table() string

type ClusterConfigurationEntity 

type ClusterConfigurationEntity struct {
	Version        int64            `db:"readOnly"`
	RuntimeID      string           `db:"notNull"`
	ClusterVersion int64            `db:"notNull"` // Cluster entity primary key
	KymaVersion    string           `db:"notNull"`
	KymaProfile    string           `db:""`
	Components     []*keb.Component `db:"notNull,encrypt"`
	Administrators []string
	Contract       int64     `db:"notNull"`
	Deleted        bool      `db:"notNull"`
	Created        time.Time `db:"readOnly"`
}

func (*ClusterConfigurationEntity) Equal 

func (c *ClusterConfigurationEntity) Equal(other db.DatabaseEntity) bool

func (*ClusterConfigurationEntity) GetComponent 

func (c *ClusterConfigurationEntity) GetComponent(component string) *keb.Component

func (*ClusterConfigurationEntity) GetReconciliationSequence 

func (c *ClusterConfigurationEntity) GetReconciliationSequence(cfg *ReconciliationSequenceConfig) *ReconciliationSequence

func (*ClusterConfigurationEntity) Marshaller 

func (c *ClusterConfigurationEntity) Marshaller() *db.EntityMarshaller

func (*ClusterConfigurationEntity) New 

func (c *ClusterConfigurationEntity) New() db.DatabaseEntity

func (*ClusterConfigurationEntity) String 

func (c *ClusterConfigurationEntity) String() string

func (*ClusterConfigurationEntity) Table 

func (c *ClusterConfigurationEntity) Table() string

type ClusterEntity 

type ClusterEntity struct {
	Version    int64             `db:"readOnly"`
	RuntimeID  string            `db:"notNull"`
	Runtime    *keb.RuntimeInput `db:"notNull"`
	Metadata   *keb.Metadata     `db:"notNull"`
	Kubeconfig string            `db:"notNull,encrypt"`
	Contract   int64             `db:"notNull"`
	Deleted    bool              `db:"notNull"`
	Created    time.Time         `db:"readOnly"`
}

func (*ClusterEntity) Equal 

func (c *ClusterEntity) Equal(other db.DatabaseEntity) bool

func (*ClusterEntity) Marshaller 

func (c *ClusterEntity) Marshaller() *db.EntityMarshaller

func (*ClusterEntity) New 

func (c *ClusterEntity) New() db.DatabaseEntity

func (*ClusterEntity) String 

func (c *ClusterEntity) String() string

func (*ClusterEntity) Table 

func (c *ClusterEntity) Table() string

type ClusterStatus 

type ClusterStatus struct {
	ID     float64 //required for monitoring metrics, has to be unique!
	Status Status
}

func NewClusterStatus 

func NewClusterStatus(status Status) (*ClusterStatus, error)

func (*ClusterStatus) String 

func (s *ClusterStatus) String() string

type ClusterStatusEntity 

type ClusterStatusEntity struct {
	ID             int64     `db:"readOnly"`
	RuntimeID      string    `db:"notNull"`
	ClusterVersion int64     `db:"notNull"` // Cluster entity primary key
	ConfigVersion  int64     `db:"notNull"` // Cluster config entity primary key
	Status         Status    `db:"notNull"`
	Deleted        bool      `db:"notNull"`
	Created        time.Time `db:"readOnly"`
}

func (*ClusterStatusEntity) Equal 

func (c *ClusterStatusEntity) Equal(other db.DatabaseEntity) bool

func (*ClusterStatusEntity) GetClusterStatus 

func (c *ClusterStatusEntity) GetClusterStatus() (*ClusterStatus, error)

func (*ClusterStatusEntity) GetKEBClusterStatus 

func (c *ClusterStatusEntity) GetKEBClusterStatus() (keb.Status, error)

func (*ClusterStatusEntity) Marshaller 

func (c *ClusterStatusEntity) Marshaller() *db.EntityMarshaller

func (*ClusterStatusEntity) New 

func (c *ClusterStatusEntity) New() db.DatabaseEntity

func (*ClusterStatusEntity) String 

func (c *ClusterStatusEntity) String() string

func (*ClusterStatusEntity) Table 

func (c *ClusterStatusEntity) Table() string

type DataType 

type DataType string
const (
	String  DataType = "string"
	Integer DataType = "integer"
	Boolean DataType = "boolean"
)

func NewDataType 

func NewDataType(dataType string) (DataType, error)

func (DataType) Get 

func (dt DataType) Get(value string) (interface{}, error)

type InvalidValueError 

type InvalidValueError struct {
	Validator string
	Result    interface{}
	Key       string
	Value     string
}

func (InvalidValueError) Error 

func (err InvalidValueError) Error() string

type KeyEntity 

type KeyEntity struct {
	Key       string   `db:"notNull"`
	Version   int64    `db:"readOnly"`
	DataType  DataType `db:"notNull"`
	Encrypted bool
	Created   time.Time `db:"readOnly"`
	Username  string    `db:"notNull"`
	Validator string
	Trigger   string
}

func (*KeyEntity) Equal 

func (ke *KeyEntity) Equal(other db.DatabaseEntity) bool

func (*KeyEntity) Marshaller 

func (ke *KeyEntity) Marshaller() *db.EntityMarshaller

func (*KeyEntity) New 

func (ke *KeyEntity) New() db.DatabaseEntity

func (*KeyEntity) String 

func (ke *KeyEntity) String() string

func (*KeyEntity) Table 

func (ke *KeyEntity) Table() string

func (*KeyEntity) Validate 

func (ke *KeyEntity) Validate(value string) error

type OperationEntity 

type OperationEntity struct {
	Priority           int64          `db:"notNull"`
	SchedulingID       string         `db:"notNull"`
	CorrelationID      string         `db:"notNull"`
	RuntimeID          string         `db:"notNull"`
	ClusterConfig      int64          `db:"notNull"`
	Component          string         `db:"notNull"`
	Type               OperationType  `db:"notNull"`
	State              OperationState `db:"notNull"`
	Reason             string         `db:""`
	Created            time.Time      `db:"readOnly"`
	Updated            time.Time      `db:""`
	PickedUp           time.Time      `db:""`
	ProcessingDuration int64          `db:""`
	Retries            int64          `db:""`
	RetryID            string         `db:"notNull"`
	Debug              bool           `db:"notNull"`
}

func (*OperationEntity) Equal 

func (o *OperationEntity) Equal(other db.DatabaseEntity) bool

func (*OperationEntity) Marshaller 

func (o *OperationEntity) Marshaller() *db.EntityMarshaller

func (*OperationEntity) New 

func (*OperationEntity) New() db.DatabaseEntity

func (*OperationEntity) String 

func (o *OperationEntity) String() string

func (*OperationEntity) Table 

func (*OperationEntity) Table() string

type OperationState 

type OperationState string
const (
	OperationStateNew         OperationState = "new"
	OperationStateInProgress  OperationState = "in_progress"
	OperationStateDone        OperationState = "done"
	OperationStateClientError OperationState = "client_error"
	OperationStateError       OperationState = "error"
	OperationStateFailed      OperationState = "failed"
	OperationStateOrphan      OperationState = "orphan"
)

func NewOperationState 

func NewOperationState(state string) (OperationState, error)

func (OperationState) IsError 

func (o OperationState) IsError() bool

func (OperationState) IsFinal 

func (o OperationState) IsFinal() bool

func (OperationState) IsTemporary 

func (o OperationState) IsTemporary() bool

type OperationType 

type OperationType string
const (
	OperationTypeReconcile OperationType = "reconcile"
	OperationTypeDelete    OperationType = "delete"
)

func NewOperationType 

func NewOperationType(state string) (OperationType, error)

type ReconciliationEntity 

type ReconciliationEntity struct {
	Lock                string    `db:"notNull"`
	RuntimeID           string    `db:"notNull"`
	ClusterConfig       int64     `db:"notNull"`
	ClusterConfigStatus int64     `db:"notNull"`
	Finished            bool      `db:"notNull"`
	SchedulingID        string    `db:"notNull"`
	Created             time.Time `db:"readOnly"`
	Updated             time.Time `db:""`
	Status              Status    `db:"notNull"`
}

func (*ReconciliationEntity) Equal 

func (r *ReconciliationEntity) Equal(other db.DatabaseEntity) bool

func (*ReconciliationEntity) Marshaller 

func (r *ReconciliationEntity) Marshaller() *db.EntityMarshaller

func (*ReconciliationEntity) New 

func (*ReconciliationEntity) New() db.DatabaseEntity

func (*ReconciliationEntity) String 

func (r *ReconciliationEntity) String() string

func (*ReconciliationEntity) Table 

func (*ReconciliationEntity) Table() string

type ReconciliationSequence 

type ReconciliationSequence struct {
	Queue [][]*keb.Component
	// contains filtered or unexported fields
}

type ReconciliationSequenceConfig 

type ReconciliationSequenceConfig struct {
	PreComponents        [][]string
	DeleteStrategy       string
	ComponentCRDs        map[string]config.ComponentCRD
	ReconciliationStatus Status
	Kubeconfig           string
}

type Status 

type Status string
const (
	ClusterStatusDeletePending           Status = "delete_pending"
	ClusterStatusDeleting                Status = "deleting"
	ClusterStatusDeleteError             Status = "delete_error"
	ClusterStatusDeleteErrorRetryable    Status = "delete_error_retryable"
	ClusterStatusDeleted                 Status = "deleted"
	ClusterStatusReconcilePending        Status = "reconcile_pending"
	ClusterStatusReconcileDisabled       Status = "reconcile_disabled"
	ClusterStatusReconciling             Status = "reconciling"
	ClusterStatusReconcileError          Status = "error"
	ClusterStatusReconcileErrorRetryable Status = "reconcile_error_retryable"
	ClusterStatusReady                   Status = "ready"
)

func (Status) IsDeleteCandidate 

func (s Status) IsDeleteCandidate() bool

func (Status) IsDeletionInProgress 

func (s Status) IsDeletionInProgress() bool

func (Status) IsDisabled 

func (s Status) IsDisabled() bool

func (Status) IsFinal 

func (s Status) IsFinal() bool

func (Status) IsFinalStable 

func (s Status) IsFinalStable() bool

func (Status) IsInProgress 

func (s Status) IsInProgress() bool

func (Status) IsReconcileCandidate 

func (s Status) IsReconcileCandidate() bool

type StatusCleanupEntity 

type StatusCleanupEntity struct {
	StatusID  int64     `db:"notNull"`
	RuntimeID string    `db:"notNull"`
	ClusterID int64     `db:"notNull"`
	ConfigID  int64     `db:"notNull"`
	Status    string    `db:"notNull"`
	Created   time.Time `db:"readOnly"`
}

func (*StatusCleanupEntity) Equal 

func (sce *StatusCleanupEntity) Equal(other db.DatabaseEntity) bool

func (*StatusCleanupEntity) Marshaller 

func (sce *StatusCleanupEntity) Marshaller() *db.EntityMarshaller

func (*StatusCleanupEntity) New 

func (sce *StatusCleanupEntity) New() db.DatabaseEntity

func (*StatusCleanupEntity) String 

func (sce *StatusCleanupEntity) String() string

func (*StatusCleanupEntity) Table 

func (sce *StatusCleanupEntity) Table() string

type ValueEntity 

type ValueEntity struct {
	Key        string    `db:"notNull"`
	KeyVersion int64     `db:"notNull"`
	Version    int64     `db:"readOnly"`
	Bucket     string    `db:"notNull"`
	Value      string    `db:"notNull"`
	DataType   DataType  `db:"notNull"`
	Created    time.Time `db:"readOnly"`
	Username   string    `db:"notNull"`
}

func (*ValueEntity) Equal 

func (ve *ValueEntity) Equal(other db.DatabaseEntity) bool

func (*ValueEntity) Get 

func (ve *ValueEntity) Get() (interface{}, error)

func (*ValueEntity) Marshaller 

func (ve *ValueEntity) Marshaller() *db.EntityMarshaller

func (*ValueEntity) New 

func (ve *ValueEntity) New() db.DatabaseEntity

func (*ValueEntity) String 

func (ve *ValueEntity) String() string

func (*ValueEntity) Table 

func (ve *ValueEntity) Table() string

type WorkerPoolOccupancyEntity 

type WorkerPoolOccupancyEntity struct {
	WorkerPoolID       string    `db:"notNull"`
	Component          string    `db:"notNull"`
	RunningWorkers     int64     `db:""`
	WorkerPoolCapacity int64     `db:"notNull"`
	Created            time.Time `db:"readOnly"`
}

func (*WorkerPoolOccupancyEntity) Equal 

func (o *WorkerPoolOccupancyEntity) Equal(other db.DatabaseEntity) bool

func (*WorkerPoolOccupancyEntity) Marshaller 

func (o *WorkerPoolOccupancyEntity) Marshaller() *db.EntityMarshaller

func (*WorkerPoolOccupancyEntity) New 

func (o *WorkerPoolOccupancyEntity) New() db.DatabaseEntity

func (*WorkerPoolOccupancyEntity) String 

func (o *WorkerPoolOccupancyEntity) String() string

func (*WorkerPoolOccupancyEntity) Table 

func (o *WorkerPoolOccupancyEntity) Table() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.