internalstorage

Jan 8, 2024

Changes in this version

+ const AllowParameterizedSQLQuery

type ResourceStorage

+ func (c *ResourceStorage) ConvertDeletedObject(obj interface{}) (runtime.Object, error)

Dec 21, 2023

Changes in this version

+ const URLQueryFieldWhereSQLJSONParams

+ const URLQueryFieldWhereSQLParam

+ const URLQueryFieldWhereSQLStatement

+ type URLQueryWhereSQLParams struct

+ WhereSQL string

+ WhereSQLJSONParams []any

+ WhereSQLParams []string

+ WhereSQLStatement string

+ func NewURLQueryWhereSQLParamsFromURLValues(urlQuery url.Values) (URLQueryWhereSQLParams, error)

Jul 4, 2023

Changes in this version

type Bytes

+ func (bytes *Bytes) Scan(data any) error

+ func (bytes Bytes) Value() (driver.Value, error)

type Config

+ DSN string

Jan 3, 2023

Changes in this version

type MySQLConfig

+ RecoverableErrNumbers []int

type PostgresConfig

+ RecoverableErrCodes []string

Dec 14, 2022

Changes in this version

type ResourceStorage

+ func (s *ResourceStorage) Watch(_ context.Context, _ *internal.ListOptions) (watch.Interface, error)

type StorageFactory

+ func (s *StorageFactory) GetSupportedRequestVerbs() []string

+ func (s *StorageFactory) PrepareCluster(cluster string) error

Jul 20, 2022

Changes in this version

+ const CollectionResourceAny

+ const URLQueryGroups

+ const URLQueryResources

+ func InterpretDBError(key string, err error) error

+ func InterpretMysqlError(key string, err error) error

+ func InterpretPostgresError(key string, err error) error

+ func InterpretResourceDBError(cluster, name string, err error) error

+ type Bytes []byte

+ func (bytes Bytes) ConvertTo(codec runtime.Codec, object runtime.Object) (runtime.Object, error)

+ func (bytes Bytes) ConvertToUnstructured() (*unstructured.Unstructured, error)

+ func (bytes Bytes) GetResourceType() ResourceType

+ type BytesList []Bytes

+ func (list *BytesList) From(db *gorm.DB) error

+ func (list BytesList) Items() []Object

+ func (list BytesList) Select(query *gorm.DB) *gorm.DB

type Object

+ ConvertTo func(codec runtime.Codec, object runtime.Object) (runtime.Object, error)

type ObjectList

+ Select func(db *gorm.DB) *gorm.DB

type Resource

+ func (res Resource) ConvertTo(codec runtime.Codec, object runtime.Object) (runtime.Object, error)

type ResourceList

+ func (list ResourceList) Select(query *gorm.DB) *gorm.DB

type ResourceMetadata

+ func (data ResourceMetadata) ConvertTo(codec runtime.Codec, object runtime.Object) (runtime.Object, error)

type ResourceMetadataList

+ func (list ResourceMetadataList) Select(query *gorm.DB) *gorm.DB

type ResourceType

+ func (rt ResourceType) Empty() bool

Jun 1, 2022

Changes in this version

+ const AllowRawSQLQuery

+ const CollectionResourceKubeResources

+ const CollectionResourceWorkloads

+ const URLQueryWhereSQL

+ func NewCollectionResourceStorage(db *gorm.DB, cr *internal.CollectionResource) storage.CollectionResourceStorage

type Config

+ ConnPool ConnPoolConfig

+ type ConnPoolConfig struct

+ ConnMaxLifetime time.Duration

+ MaxIdleConns int

+ MaxOpenConns int

type LogConfig

+ Logger *lumberjack.Logger

+ type Object interface

+ ConvertToUnstructured func() (*unstructured.Unstructured, error)

+ GetResourceType func() ResourceType

+ type ObjectList interface

+ From func(db *gorm.DB) error

+ Items func() []Object

type Resource

+ func (res Resource) ConvertToUnstructured() (*unstructured.Unstructured, error)

+ func (res Resource) GetResourceType() ResourceType

+ type ResourceList []Resource

+ func (list *ResourceList) From(db *gorm.DB) error

+ func (list ResourceList) Items() []Object

+ type ResourceMetadata struct

+ Metadata datatypes.JSONMap

+ func (data ResourceMetadata) ConvertToUnstructured() (*unstructured.Unstructured, error)

+ func (data ResourceMetadata) GetResourceType() ResourceType

+ type ResourceMetadataList []ResourceMetadata

+ func (list *ResourceMetadataList) From(db *gorm.DB) error

+ func (list ResourceMetadataList) Items() []Object

+ type ResourceType struct

+ Group string

+ Kind string

+ Resource string

+ Version string

+ func (res ResourceType) GroupVersionResource() schema.GroupVersionResource

Apr 8, 2022

Changes in this version

+ const SearchLabelFuzzyName

Feb 15, 2022

Changes in this version

+ const SearchLabelOwnerKey

+ const SearchLabelOwnerSeniority

+ const SearchLabelOwnerUID

+ const StorageName

type JSONQueryExpression

+ func (jsonQuery *JSONQueryExpression) Exist() *JSONQueryExpression

+ func (jsonQuery *JSONQueryExpression) NotExist() *JSONQueryExpression

type Resource

+ OwnerUID types.UID

Dec 1, 2021

Changes in this version

+ func InterpreError(key string, err error) error

+ func InterpreMysqlError(key string, err error) error

+ func InterprePostgresError(key string, err error) error

+ func InterpreResourceError(cluster, name string, err error) error

+ func NewStorageFactory(configPath string) (storage.StorageFactory, error)

+ type CollectionResourceStorage struct

+ func (s *CollectionResourceStorage) Get(ctx context.Context, opts *pediainternal.ListOptions) (*pediainternal.CollectionResource, error)

+ type Config struct

+ CertFile string

+ Database string

+ Host string

+ KeyFile string

+ Log *LogConfig

+ MySQL *MySQLConfig

+ Network string

+ Params map[string]string

+ Password string

+ Port string

+ Postgres *PostgresConfig

+ RootCertFile string

+ SSLMode string

+ Type string

+ User string

+ func (cfg *Config) LoggerConfig() (logger.Config, error)

+ type JSONQueryExpression struct

+ func JSONQuery(column string, keys ...string) *JSONQueryExpression

+ func (jsonQuery *JSONQueryExpression) Build(builder clause.Builder)

+ func (jsonQuery *JSONQueryExpression) Equal(value interface{}) *JSONQueryExpression

+ func (jsonQuery *JSONQueryExpression) In(values ...interface{}) *JSONQueryExpression

+ func (jsonQuery *JSONQueryExpression) NotEqual(value interface{}) *JSONQueryExpression

+ func (jsonQuery *JSONQueryExpression) NotIn(values ...interface{}) *JSONQueryExpression

+ type LogConfig struct

+ Colorful bool

+ IgnoreRecordNotFoundError bool

+ Level string

+ SlowThreshold time.Duration

+ Stdout bool

+ type MySQLConfig struct

+ AllowAllFiles *bool

+ AllowCleartextPasswords *bool

+ AllowNativePasswords *bool

+ AllowOldPasswords *bool

+ CheckConnLiveness *bool

+ ClientFoundRows *bool

+ ColumnsWithAlias *bool

+ DialTimeout *time.Duration

+ InterpolateParams *bool

+ Loc *string

+ MaxAllowedPacket *int

+ MultiStatements *bool

+ ParseTime *bool

+ ReadTimeout *time.Duration

+ RejectReadOnly *bool

+ ServerPubKey *string

+ WriteTimeout *time.Duration

+ type PostgresConfig struct

+ type Resource struct

+ Cluster string

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ Group string

+ ID uint

+ Kind string

+ Name string

+ Namespace string

+ Object datatypes.JSON

+ Resource string

+ ResourceVersion string

+ SyncedAt time.Time

+ UID types.UID

+ Version string

+ func (res Resource) GroupVersionResource() schema.GroupVersionResource

+ type ResourceStorage struct

+ func (s *ResourceStorage) Create(ctx context.Context, cluster string, obj runtime.Object) error

+ func (s *ResourceStorage) Delete(ctx context.Context, cluster string, obj runtime.Object) error

+ func (s *ResourceStorage) Get(ctx context.Context, cluster, namespace, name string, into runtime.Object) error

+ func (s *ResourceStorage) GetStorageConfig() *storage.ResourceStorageConfig

+ func (s *ResourceStorage) List(ctx context.Context, listObject runtime.Object, ...) error

+ func (s *ResourceStorage) Update(ctx context.Context, cluster string, obj runtime.Object) error

+ type SelectedResource struct

+ type StorageFactory struct

+ func (f *StorageFactory) CleanCluster(ctx context.Context, cluster string) error

+ func (f *StorageFactory) GetResourceVersions(ctx context.Context, cluster string) (map[schema.GroupVersionResource]map[string]interface{}, error)

+ func (s *StorageFactory) CleanClusterResource(ctx context.Context, cluster string, gvr schema.GroupVersionResource) error

+ func (s *StorageFactory) GetCollectionResources(ctx context.Context) ([]*pediainternal.CollectionResource, error)

+ func (s *StorageFactory) NewCollectionResourceStorage(cr *pediainternal.CollectionResource) (storage.CollectionResourceStorage, error)

+ func (s *StorageFactory) NewResourceStorage(config *storage.ResourceStorageConfig) (storage.ResourceStorage, error)