Versions in this module Expand all Collapse all v0 v0.0.1 Feb 15, 2023 Changes in this version + const Group + const KindCache + const KindEagerCacheRule + const KindLazyCacheRule + const LabelCache + const LabelCacheNamespace + var AddToScheme = SchemeBuilder.AddToScheme + var CacheDeploymentType_name = map[int32]string + var CacheDeploymentType_value = map[string]int32 + var DBType_name = map[int32]string + var DBType_value = map[string]int32 + var File_config_cache_v1alpha1_cache_proto protoreflect.FileDescriptor + var File_config_cache_v1alpha1_rules_proto protoreflect.FileDescriptor + var GroupVersion = schema.GroupVersion + var KeyFormat_name = map[int32]string + var KeyFormat_value = map[string]int32 + var SchemeBuilder = &scheme.Builder + var SchemeGroupVersion = GroupVersion + func EnsureRuleImmutability(allErrs *field.ErrorList, ruleKind string, a, b CacheRule) error + func FieldMustBeDefined(field string) string + func RegisterEagerRuleValidatingWebhook(mgr ctrl.Manager) + func RegisterLazyRuleValidatingWebhook(mgr ctrl.Manager) + func RequireField(allErrs *field.ErrorList, name, value string, p *field.Path) + func RequireNonEmptyArray(allErrs *field.ErrorList, name string, value []string, p *field.Path) + func StatusError(allErrs field.ErrorList, name, kind string) error + type Cache struct + Spec CacheSpec + Status CacheStatus + func (c *Cache) CacheManagerImage() string + func (c *Cache) CacheService() CacheService + func (c *Cache) Cluster() bool + func (c *Cache) Condition(condition CacheConditionType) CacheCondition + func (c *Cache) DBSyncerLimits() v1.ResourceList + func (c *Cache) DBSyncerName() string + func (c *Cache) DBSyncerRequests() v1.ResourceList + func (c *Cache) Default() + func (c *Cache) DeploymentLimits() v1.ResourceList + func (c *Cache) DeploymentRequests() v1.ResourceList + func (c *Cache) Local() bool + func (c *Cache) SetCondition(condition CacheCondition) (updated bool) + func (c *Cache) SetupWebhookWithManager(mgr ctrl.Manager) error + func (c *Cache) ValidateCreate() error + func (c *Cache) ValidateDelete() error + func (c *Cache) ValidateUpdate(_ runtime.Object) error + func (in *Cache) DeepCopy() *Cache + func (in *Cache) DeepCopyInto(out *Cache) + func (in *Cache) DeepCopyObject() runtime.Object + type CacheCondition struct + Message string + Status metav1.ConditionStatus + Type CacheConditionType + type CacheConditionType string + const CacheConditionReady + type CacheConf struct + CacheSpec *CacheSpec + EagerCacheRuleSpecs map[string]*EagerCacheRuleSpec + LazyCacheRuleSpecs map[string]*LazyCacheRuleSpec + func (*CacheConf) Descriptor() ([]byte, []int) + func (*CacheConf) ProtoMessage() + func (in *CacheConf) DeepCopy() *CacheConf + func (in *CacheConf) DeepCopyInterface() interface{} + func (in *CacheConf) DeepCopyInto(out *CacheConf) + func (x *CacheConf) GetCacheSpec() *CacheSpec + func (x *CacheConf) GetEagerCacheRuleSpecs() map[string]*EagerCacheRuleSpec + func (x *CacheConf) GetLazyCacheRuleSpecs() map[string]*LazyCacheRuleSpec + func (x *CacheConf) ProtoReflect() protoreflect.Message + func (x *CacheConf) Reset() + func (x *CacheConf) String() string + type CacheDeploymentSpec struct + Replicas int32 + Resources *Resources + Type CacheDeploymentType + func (*CacheDeploymentSpec) Descriptor() ([]byte, []int) + func (*CacheDeploymentSpec) ProtoMessage() + func (in *CacheDeploymentSpec) DeepCopy() *CacheDeploymentSpec + func (in *CacheDeploymentSpec) DeepCopyInterface() interface{} + func (in *CacheDeploymentSpec) DeepCopyInto(out *CacheDeploymentSpec) + func (x *CacheDeploymentSpec) GetReplicas() int32 + func (x *CacheDeploymentSpec) GetResources() *Resources + func (x *CacheDeploymentSpec) GetType() CacheDeploymentType + func (x *CacheDeploymentSpec) ProtoReflect() protoreflect.Message + func (x *CacheDeploymentSpec) Reset() + func (x *CacheDeploymentSpec) String() string + type CacheDeploymentType int32 + const CacheDeploymentType_CLUSTER + const CacheDeploymentType_LOCAL + func (CacheDeploymentType) Descriptor() protoreflect.EnumDescriptor + func (CacheDeploymentType) EnumDescriptor() ([]byte, []int) + func (CacheDeploymentType) Type() protoreflect.EnumType + func (x *CacheDeploymentType) UnmarshalJSON(b []byte) error + func (x CacheDeploymentType) Enum() *CacheDeploymentType + func (x CacheDeploymentType) MarshalJSON() ([]byte, error) + func (x CacheDeploymentType) Number() protoreflect.EnumNumber + func (x CacheDeploymentType) String() string + type CacheList struct + Items []Cache + func (in *CacheList) DeepCopy() *CacheList + func (in *CacheList) DeepCopyInto(out *CacheList) + func (in *CacheList) DeepCopyObject() runtime.Object + type CacheRule interface + MarshallSpec func() ([]byte, error) + type CacheService struct + Name string + Namespace string + func (in *CacheService) DeepCopy() *CacheService + func (in *CacheService) DeepCopyInto(out *CacheService) + func (s CacheService) ApplyLabels(meta *metav1.ObjectMeta) + func (s CacheService) ApplyLabelsToMap(m map[string]string) + func (s CacheService) DBSyncerCacheServiceBinding() string + func (s CacheService) DBSyncerCacheServiceBindingSecret() string + func (s CacheService) DBSyncerDataServiceBinding() string + func (s CacheService) DBSyncerName() string + func (s CacheService) DataSourceServiceBinding() string + func (s CacheService) EagerCacheConfigMap() string + func (s CacheService) LabelSelector() map[string]string + func (s CacheService) LazyCacheConfigMap() string + func (s CacheService) String() string + func (s CacheService) SvcName() string + func (s CacheService) UserServiceBindingSecret() string + type CacheSpec struct + DataSource *DataSourceSpec + DbSyncer *DBSyncerDeploymentSpec + Deployment *CacheDeploymentSpec + func (*CacheSpec) Descriptor() ([]byte, []int) + func (*CacheSpec) ProtoMessage() + func (in *CacheSpec) DeepCopy() *CacheSpec + func (in *CacheSpec) DeepCopyInterface() interface{} + func (in *CacheSpec) DeepCopyInto(out *CacheSpec) + func (x *CacheSpec) GetDataSource() *DataSourceSpec + func (x *CacheSpec) GetDbSyncer() *DBSyncerDeploymentSpec + func (x *CacheSpec) GetDeployment() *CacheDeploymentSpec + func (x *CacheSpec) ProtoReflect() protoreflect.Message + func (x *CacheSpec) Reset() + func (x *CacheSpec) String() string + type CacheStatus struct + Conditions []CacheCondition + ServiceBinding *ServiceBinding + func (in *CacheStatus) DeepCopy() *CacheStatus + func (in *CacheStatus) DeepCopyInto(out *CacheStatus) + type DBSyncerDeploymentSpec struct + Resources *Resources + func (*DBSyncerDeploymentSpec) Descriptor() ([]byte, []int) + func (*DBSyncerDeploymentSpec) ProtoMessage() + func (in *DBSyncerDeploymentSpec) DeepCopy() *DBSyncerDeploymentSpec + func (in *DBSyncerDeploymentSpec) DeepCopyInterface() interface{} + func (in *DBSyncerDeploymentSpec) DeepCopyInto(out *DBSyncerDeploymentSpec) + func (x *DBSyncerDeploymentSpec) GetResources() *Resources + func (x *DBSyncerDeploymentSpec) ProtoReflect() protoreflect.Message + func (x *DBSyncerDeploymentSpec) Reset() + func (x *DBSyncerDeploymentSpec) String() string + type DBType int32 + const DBType_MYSQL_8 + const DBType_POSTGRES_14 + const DBType_SQL_SERVER_2019 + func (DBType) Descriptor() protoreflect.EnumDescriptor + func (DBType) EnumDescriptor() ([]byte, []int) + func (DBType) Type() protoreflect.EnumType + func (dbType *DBType) ServiceBinding() string + func (x *DBType) UnmarshalJSON(b []byte) error + func (x DBType) Enum() *DBType + func (x DBType) MarshalJSON() ([]byte, error) + func (x DBType) Number() protoreflect.EnumNumber + func (x DBType) String() string + type DataSourceSpec struct + ConnectionProperties map[string]string + DbType *DBType + SecretRef *LocalObjectReference + ServiceProviderRef *ServiceRef + func (*DataSourceSpec) Descriptor() ([]byte, []int) + func (*DataSourceSpec) ProtoMessage() + func (in *DataSourceSpec) DeepCopy() *DataSourceSpec + func (in *DataSourceSpec) DeepCopyInterface() interface{} + func (in *DataSourceSpec) DeepCopyInto(out *DataSourceSpec) + func (x *DataSourceSpec) GetConnectionProperties() map[string]string + func (x *DataSourceSpec) GetDbType() DBType + func (x *DataSourceSpec) GetSecretRef() *LocalObjectReference + func (x *DataSourceSpec) GetServiceProviderRef() *ServiceRef + func (x *DataSourceSpec) ProtoReflect() protoreflect.Message + func (x *DataSourceSpec) Reset() + func (x *DataSourceSpec) String() string + type EagerCacheKey struct + Format KeyFormat + KeyColumns []string + KeySeparator string + func (*EagerCacheKey) Descriptor() ([]byte, []int) + func (*EagerCacheKey) ProtoMessage() + func (in *EagerCacheKey) DeepCopy() *EagerCacheKey + func (in *EagerCacheKey) DeepCopyInterface() interface{} + func (in *EagerCacheKey) DeepCopyInto(out *EagerCacheKey) + func (x *EagerCacheKey) GetFormat() KeyFormat + func (x *EagerCacheKey) GetKeyColumns() []string + func (x *EagerCacheKey) GetKeySeparator() string + func (x *EagerCacheKey) ProtoReflect() protoreflect.Message + func (x *EagerCacheKey) Reset() + func (x *EagerCacheKey) String() string + type EagerCacheRule struct + Spec EagerCacheRuleSpec + Status EagerCacheRuleStatus + func (in *EagerCacheRule) DeepCopy() *EagerCacheRule + func (in *EagerCacheRule) DeepCopyInto(out *EagerCacheRule) + func (in *EagerCacheRule) DeepCopyObject() runtime.Object + func (r *EagerCacheRule) CacheService() CacheService + func (r *EagerCacheRule) Condition(condition EagerCacheRuleConditionType) EagerCacheRuleCondition + func (r *EagerCacheRule) ConfigMap() string + func (r *EagerCacheRule) Default() + func (r *EagerCacheRule) Finalizer() string + func (r *EagerCacheRule) MarshallSpec() ([]byte, error) + func (r *EagerCacheRule) NamespacedName() types.NamespacedName + func (r *EagerCacheRule) SetCondition(condition EagerCacheRuleCondition) (updated bool) + func (r *EagerCacheRule) SetupWebhookWithManager(mgr ctrl.Manager) error + type EagerCacheRuleCondition struct + Message string + Status metav1.ConditionStatus + Type EagerCacheRuleConditionType + type EagerCacheRuleConditionType string + const EagerCacheRuleConditionReady + type EagerCacheRuleList struct + Items []EagerCacheRule + func (in *EagerCacheRuleList) DeepCopy() *EagerCacheRuleList + func (in *EagerCacheRuleList) DeepCopyInto(out *EagerCacheRuleList) + func (in *EagerCacheRuleList) DeepCopyObject() runtime.Object + type EagerCacheRuleSpec struct + CacheRef *NamespacedObjectReference + Key *EagerCacheKey + TableName string + Value *Value + func (*EagerCacheRuleSpec) Descriptor() ([]byte, []int) + func (*EagerCacheRuleSpec) ProtoMessage() + func (in *EagerCacheRuleSpec) DeepCopy() *EagerCacheRuleSpec + func (in *EagerCacheRuleSpec) DeepCopyInterface() interface{} + func (in *EagerCacheRuleSpec) DeepCopyInto(out *EagerCacheRuleSpec) + func (x *EagerCacheRuleSpec) GetCacheRef() *NamespacedObjectReference + func (x *EagerCacheRuleSpec) GetKey() *EagerCacheKey + func (x *EagerCacheRuleSpec) GetTableName() string + func (x *EagerCacheRuleSpec) GetValue() *Value + func (x *EagerCacheRuleSpec) ProtoReflect() protoreflect.Message + func (x *EagerCacheRuleSpec) Reset() + func (x *EagerCacheRuleSpec) String() string + type EagerCacheRuleStatus struct + Conditions []EagerCacheRuleCondition + func (in *EagerCacheRuleStatus) DeepCopy() *EagerCacheRuleStatus + func (in *EagerCacheRuleStatus) DeepCopyInto(out *EagerCacheRuleStatus) + type KeyFormat int32 + const KeyFormat_JSON + const KeyFormat_TEXT + func (KeyFormat) Descriptor() protoreflect.EnumDescriptor + func (KeyFormat) EnumDescriptor() ([]byte, []int) + func (KeyFormat) Type() protoreflect.EnumType + func (x *KeyFormat) UnmarshalJSON(b []byte) error + func (x KeyFormat) Enum() *KeyFormat + func (x KeyFormat) MarshalJSON() ([]byte, error) + func (x KeyFormat) Number() protoreflect.EnumNumber + func (x KeyFormat) String() string + type LazyCacheKey struct + Format KeyFormat + KeySeparator string + func (*LazyCacheKey) Descriptor() ([]byte, []int) + func (*LazyCacheKey) ProtoMessage() + func (in *LazyCacheKey) DeepCopy() *LazyCacheKey + func (in *LazyCacheKey) DeepCopyInterface() interface{} + func (in *LazyCacheKey) DeepCopyInto(out *LazyCacheKey) + func (x *LazyCacheKey) GetFormat() KeyFormat + func (x *LazyCacheKey) GetKeySeparator() string + func (x *LazyCacheKey) ProtoReflect() protoreflect.Message + func (x *LazyCacheKey) Reset() + func (x *LazyCacheKey) String() string + type LazyCacheRule struct + Spec LazyCacheRuleSpec + Status LazyCacheRuleStatus + func (in *LazyCacheRule) DeepCopy() *LazyCacheRule + func (in *LazyCacheRule) DeepCopyInto(out *LazyCacheRule) + func (in *LazyCacheRule) DeepCopyObject() runtime.Object + func (r *LazyCacheRule) CacheService() CacheService + func (r *LazyCacheRule) Condition(condition LazyCacheRuleConditionType) LazyCacheRuleCondition + func (r *LazyCacheRule) ConfigMap() string + func (r *LazyCacheRule) Default() + func (r *LazyCacheRule) Finalizer() string + func (r *LazyCacheRule) MarshallSpec() ([]byte, error) + func (r *LazyCacheRule) NamespacedName() types.NamespacedName + func (r *LazyCacheRule) SetCondition(condition LazyCacheRuleCondition) (updated bool) + func (r *LazyCacheRule) SetupWebhookWithManager(mgr ctrl.Manager) error + type LazyCacheRuleCondition struct + Message string + Status metav1.ConditionStatus + Type LazyCacheRuleConditionType + type LazyCacheRuleConditionType string + const LazyCacheRuleConditionReady + type LazyCacheRuleList struct + Items []LazyCacheRule + func (in *LazyCacheRuleList) DeepCopy() *LazyCacheRuleList + func (in *LazyCacheRuleList) DeepCopyInto(out *LazyCacheRuleList) + func (in *LazyCacheRuleList) DeepCopyObject() runtime.Object + type LazyCacheRuleSpec struct + CacheRef *NamespacedObjectReference + Key *LazyCacheKey + Query string + func (*LazyCacheRuleSpec) Descriptor() ([]byte, []int) + func (*LazyCacheRuleSpec) ProtoMessage() + func (in *LazyCacheRuleSpec) DeepCopy() *LazyCacheRuleSpec + func (in *LazyCacheRuleSpec) DeepCopyInterface() interface{} + func (in *LazyCacheRuleSpec) DeepCopyInto(out *LazyCacheRuleSpec) + func (x *LazyCacheRuleSpec) GetCacheRef() *NamespacedObjectReference + func (x *LazyCacheRuleSpec) GetKey() *LazyCacheKey + func (x *LazyCacheRuleSpec) GetQuery() string + func (x *LazyCacheRuleSpec) ProtoReflect() protoreflect.Message + func (x *LazyCacheRuleSpec) Reset() + func (x *LazyCacheRuleSpec) String() string + type LazyCacheRuleStatus struct + Conditions []LazyCacheRuleCondition + func (in *LazyCacheRuleStatus) DeepCopy() *LazyCacheRuleStatus + func (in *LazyCacheRuleStatus) DeepCopyInto(out *LazyCacheRuleStatus) + type LocalObjectReference struct + Name string + func (*LocalObjectReference) Descriptor() ([]byte, []int) + func (*LocalObjectReference) ProtoMessage() + func (in *LocalObjectReference) DeepCopy() *LocalObjectReference + func (in *LocalObjectReference) DeepCopyInterface() interface{} + func (in *LocalObjectReference) DeepCopyInto(out *LocalObjectReference) + func (x *LocalObjectReference) GetName() string + func (x *LocalObjectReference) ProtoReflect() protoreflect.Message + func (x *LocalObjectReference) Reset() + func (x *LocalObjectReference) String() string + type NamespacedObjectReference struct + Name string + Namespace string + func (*NamespacedObjectReference) Descriptor() ([]byte, []int) + func (*NamespacedObjectReference) ProtoMessage() + func (in *NamespacedObjectReference) DeepCopy() *NamespacedObjectReference + func (in *NamespacedObjectReference) DeepCopyInterface() interface{} + func (in *NamespacedObjectReference) DeepCopyInto(out *NamespacedObjectReference) + func (x *NamespacedObjectReference) GetName() string + func (x *NamespacedObjectReference) GetNamespace() string + func (x *NamespacedObjectReference) ProtoReflect() protoreflect.Message + func (x *NamespacedObjectReference) Reset() + func (x *NamespacedObjectReference) String() string + type ResourceQuantity struct + Cpu string + Memory string + func (*ResourceQuantity) Descriptor() ([]byte, []int) + func (*ResourceQuantity) ProtoMessage() + func (in *ResourceQuantity) DeepCopy() *ResourceQuantity + func (in *ResourceQuantity) DeepCopyInterface() interface{} + func (in *ResourceQuantity) DeepCopyInto(out *ResourceQuantity) + func (x *ResourceQuantity) GetCpu() string + func (x *ResourceQuantity) GetMemory() string + func (x *ResourceQuantity) ProtoReflect() protoreflect.Message + func (x *ResourceQuantity) Reset() + func (x *ResourceQuantity) String() string + type Resources struct + Limits *ResourceQuantity + Requests *ResourceQuantity + func (*Resources) Descriptor() ([]byte, []int) + func (*Resources) ProtoMessage() + func (in *Resources) DeepCopy() *Resources + func (in *Resources) DeepCopyInterface() interface{} + func (in *Resources) DeepCopyInto(out *Resources) + func (x *Resources) GetLimits() *ResourceQuantity + func (x *Resources) GetRequests() *ResourceQuantity + func (x *Resources) ProtoReflect() protoreflect.Message + func (x *Resources) Reset() + func (x *Resources) String() string + type ServiceBinding struct + Name string + func (in *ServiceBinding) DeepCopy() *ServiceBinding + func (in *ServiceBinding) DeepCopyInto(out *ServiceBinding) + type ServiceRef struct + ApiVersion string + Kind string + Name string + func (*ServiceRef) Descriptor() ([]byte, []int) + func (*ServiceRef) ProtoMessage() + func (in *ServiceRef) DeepCopy() *ServiceRef + func (in *ServiceRef) DeepCopyInterface() interface{} + func (in *ServiceRef) DeepCopyInto(out *ServiceRef) + func (x *ServiceRef) GetApiVersion() string + func (x *ServiceRef) GetKind() string + func (x *ServiceRef) GetName() string + func (x *ServiceRef) ProtoReflect() protoreflect.Message + func (x *ServiceRef) Reset() + func (x *ServiceRef) String() string + type Value struct + ValueColumns []string + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (in *Value) DeepCopy() *Value + func (in *Value) DeepCopyInterface() interface{} + func (in *Value) DeepCopyInto(out *Value) + func (x *Value) GetValueColumns() []string + func (x *Value) ProtoReflect() protoreflect.Message + func (x *Value) Reset() + func (x *Value) String() string