Documentation
¶
Index ¶
- func NamespacedName(obj client.Object) types.NamespacedName
- type RatelimitDataStore
- func (ods *RatelimitDataStore) AddorUpdateAIRatelimitToStore(rateLimit types.NamespacedName, ...)
- func (ods *RatelimitDataStore) AddorUpdateCustomRatelimitToStore(rateLimit types.NamespacedName, ...)
- func (ods *RatelimitDataStore) AddorUpdateResolveRatelimitToStore(rateLimit types.NamespacedName, ...)
- func (ods *RatelimitDataStore) AddorUpdateResolveSubscriptionRatelimitToStore(rateLimit types.NamespacedName, ...)
- func (ods *RatelimitDataStore) AddorUpdateSubscriptionBasedAIRatelimitToStore(rateLimit types.NamespacedName, ...)
- func (ods *RatelimitDataStore) DeleteAIRatelimitPolicySpec(rateLimit types.NamespacedName)
- func (ods *RatelimitDataStore) DeleteCachedCustomRatelimitPolicy(rateLimit types.NamespacedName)
- func (ods *RatelimitDataStore) DeleteResolveRatelimitPolicy(rateLimit types.NamespacedName)
- func (ods *RatelimitDataStore) DeleteSubscriptionBasedAIRatelimitPolicySpec(subscription types.NamespacedName)
- func (ods *RatelimitDataStore) DeleteSubscriptionRatelimitPolicy(rateLimit types.NamespacedName)
- func (ods *RatelimitDataStore) GetAIRatelimitPolicySpecs() map[types.NamespacedName]*dpv1alpha3.AIRateLimitPolicySpec
- func (ods *RatelimitDataStore) GetCachedCustomRatelimitPolicy(rateLimit types.NamespacedName) (dpv1alpha1.CustomRateLimitPolicyDef, bool)
- func (ods *RatelimitDataStore) GetResolveRatelimitPolicy(rateLimit types.NamespacedName) ([]dpv1alpha1.ResolveRateLimitAPIPolicy, bool)
- func (ods *RatelimitDataStore) GetResolveSubscriptionRatelimitPolicy(rateLimit types.NamespacedName) (dpv1alpha3.ResolveSubscriptionRatelimitPolicy, bool)
- func (ods *RatelimitDataStore) GetSubscriptionBasedAIRatelimitPolicySpecs() map[types.NamespacedName]*dpv1alpha3.AIRateLimitPolicySpec
- type RouteMetadataDataStore
- func (rmds *RouteMetadataDataStore) AddOrUpdateRouteMetadata(routeMetadata dpv2alpha1.RouteMetadata)
- func (rmds *RouteMetadataDataStore) DeleteRouteMetadata(namespace, name string)
- func (rmds *RouteMetadataDataStore) GetRouteMetadata(namespace, name string) (dpv2alpha1.RouteMetadata, bool)
- func (rmds *RouteMetadataDataStore) GetRouteMetadatas() map[string]dpv2alpha1.RouteMetadata
- type RoutePolicyDataStore
- func (rds *RoutePolicyDataStore) AddOrUpdateRoutePolicy(routePolicy dpv2alpha1.RoutePolicy)
- func (rds *RoutePolicyDataStore) DeleteRoutePolicy(namespace, name string)
- func (rds *RoutePolicyDataStore) GetRoutePolicies() map[string]dpv2alpha1.RoutePolicy
- func (rds *RoutePolicyDataStore) GetRoutePolicy(namespace, name string) (dpv2alpha1.RoutePolicy, bool)
- type SubscriptionDataStore
- func (ods *SubscriptionDataStore) AddorUpdateApplicationMappingToStore(name types.NamespacedName, ...)
- func (ods *SubscriptionDataStore) AddorUpdateApplicationToStore(name types.NamespacedName, application cpv1alpha2.ApplicationSpec)
- func (ods *SubscriptionDataStore) AddorUpdateSubscriptionToStore(name types.NamespacedName, subscription cpv1alpha3.SubscriptionSpec)
- func (ods *SubscriptionDataStore) DeleteApplicationFromStore(name types.NamespacedName)
- func (ods *SubscriptionDataStore) DeleteApplicationMappingFromStore(name types.NamespacedName)
- func (ods *SubscriptionDataStore) DeleteSubscriptionFromStore(name types.NamespacedName)
- func (ods *SubscriptionDataStore) GetApplicationFromStore(name types.NamespacedName) (cpv1alpha2.ApplicationSpec, bool)
- func (ods *SubscriptionDataStore) GetApplicationMappingFromStore(name types.NamespacedName) (cpv1alpha2.ApplicationMappingSpec, bool)
- func (ods *SubscriptionDataStore) GetSubscriptionFromStore(name types.NamespacedName) (cpv1alpha3.SubscriptionSpec, bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NamespacedName ¶
func NamespacedName(obj client.Object) types.NamespacedName
NamespacedName generates namespaced name for Kubernetes objects
Types ¶
type RatelimitDataStore ¶
type RatelimitDataStore struct {
// contains filtered or unexported fields
}
RatelimitDataStore is a cache for rate limit policies.
func CreateNewOperatorDataStore ¶
func CreateNewOperatorDataStore() *RatelimitDataStore
CreateNewOperatorDataStore creates a new RatelimitDataStore.
func (*RatelimitDataStore) AddorUpdateAIRatelimitToStore ¶
func (ods *RatelimitDataStore) AddorUpdateAIRatelimitToStore(rateLimit types.NamespacedName, aiRatelimitSpec dpv1alpha3.AIRateLimitPolicySpec)
AddorUpdateAIRatelimitToStore adds a new ratelimit to the RatelimitDataStore.
func (*RatelimitDataStore) AddorUpdateCustomRatelimitToStore ¶
func (ods *RatelimitDataStore) AddorUpdateCustomRatelimitToStore(rateLimit types.NamespacedName, customRateLimitPolicy dpv1alpha1.CustomRateLimitPolicyDef)
AddorUpdateCustomRatelimitToStore adds a new ratelimit to the RatelimitDataStore.
func (*RatelimitDataStore) AddorUpdateResolveRatelimitToStore ¶
func (ods *RatelimitDataStore) AddorUpdateResolveRatelimitToStore(rateLimit types.NamespacedName, resolveRatelimitPolicyList []dpv1alpha1.ResolveRateLimitAPIPolicy)
AddorUpdateResolveRatelimitToStore adds a new ratelimit to the RatelimitDataStore.
func (*RatelimitDataStore) AddorUpdateResolveSubscriptionRatelimitToStore ¶
func (ods *RatelimitDataStore) AddorUpdateResolveSubscriptionRatelimitToStore(rateLimit types.NamespacedName, resolveSubscriptionRatelimit dpv1alpha3.ResolveSubscriptionRatelimitPolicy)
AddorUpdateResolveSubscriptionRatelimitToStore adds a new ratelimit to the RatelimitDataStore.
func (*RatelimitDataStore) AddorUpdateSubscriptionBasedAIRatelimitToStore ¶
func (ods *RatelimitDataStore) AddorUpdateSubscriptionBasedAIRatelimitToStore(rateLimit types.NamespacedName, aiRatelimitSpec dpv1alpha3.AIRateLimitPolicySpec)
AddorUpdateSubscriptionBasedAIRatelimitToStore adds a new ratelimit to the RatelimitDataStore.
func (*RatelimitDataStore) DeleteAIRatelimitPolicySpec ¶
func (ods *RatelimitDataStore) DeleteAIRatelimitPolicySpec(rateLimit types.NamespacedName)
DeleteAIRatelimitPolicySpec delete from ratelimit cache
func (*RatelimitDataStore) DeleteCachedCustomRatelimitPolicy ¶
func (ods *RatelimitDataStore) DeleteCachedCustomRatelimitPolicy(rateLimit types.NamespacedName)
DeleteCachedCustomRatelimitPolicy delete from ratelimit cache
func (*RatelimitDataStore) DeleteResolveRatelimitPolicy ¶
func (ods *RatelimitDataStore) DeleteResolveRatelimitPolicy(rateLimit types.NamespacedName)
DeleteResolveRatelimitPolicy delete from ratelimit cache
func (*RatelimitDataStore) DeleteSubscriptionBasedAIRatelimitPolicySpec ¶
func (ods *RatelimitDataStore) DeleteSubscriptionBasedAIRatelimitPolicySpec(subscription types.NamespacedName)
DeleteSubscriptionBasedAIRatelimitPolicySpec delete from ratelimit cache
func (*RatelimitDataStore) DeleteSubscriptionRatelimitPolicy ¶
func (ods *RatelimitDataStore) DeleteSubscriptionRatelimitPolicy(rateLimit types.NamespacedName)
DeleteSubscriptionRatelimitPolicy delete from ratelimit cache
func (*RatelimitDataStore) GetAIRatelimitPolicySpecs ¶
func (ods *RatelimitDataStore) GetAIRatelimitPolicySpecs() map[types.NamespacedName]*dpv1alpha3.AIRateLimitPolicySpec
GetAIRatelimitPolicySpecs gets all the AIRatelimitPolicy stored in ods
func (*RatelimitDataStore) GetCachedCustomRatelimitPolicy ¶
func (ods *RatelimitDataStore) GetCachedCustomRatelimitPolicy(rateLimit types.NamespacedName) (dpv1alpha1.CustomRateLimitPolicyDef, bool)
GetCachedCustomRatelimitPolicy get cached ratelimit
func (*RatelimitDataStore) GetResolveRatelimitPolicy ¶
func (ods *RatelimitDataStore) GetResolveRatelimitPolicy(rateLimit types.NamespacedName) ([]dpv1alpha1.ResolveRateLimitAPIPolicy, bool)
GetResolveRatelimitPolicy get cached ratelimit
func (*RatelimitDataStore) GetResolveSubscriptionRatelimitPolicy ¶
func (ods *RatelimitDataStore) GetResolveSubscriptionRatelimitPolicy(rateLimit types.NamespacedName) (dpv1alpha3.ResolveSubscriptionRatelimitPolicy, bool)
GetResolveSubscriptionRatelimitPolicy get cached ratelimit
func (*RatelimitDataStore) GetSubscriptionBasedAIRatelimitPolicySpecs ¶
func (ods *RatelimitDataStore) GetSubscriptionBasedAIRatelimitPolicySpecs() map[types.NamespacedName]*dpv1alpha3.AIRateLimitPolicySpec
GetSubscriptionBasedAIRatelimitPolicySpecs gets all the AIRatelimitPolicy stored in ods
type RouteMetadataDataStore ¶
type RouteMetadataDataStore struct {
// contains filtered or unexported fields
}
RouteMetadataDataStore holds RouteMetadata objects,
func GetRouteMetadataDataStore ¶
func GetRouteMetadataDataStore() *RouteMetadataDataStore
GetRouteMetadataDataStore returns the singleton instance of RouteMetadataDataStore.
func (*RouteMetadataDataStore) AddOrUpdateRouteMetadata ¶
func (rmds *RouteMetadataDataStore) AddOrUpdateRouteMetadata(routeMetadata dpv2alpha1.RouteMetadata)
AddOrUpdateRouteMetadata adds or updates a route metadata entry in the store.
func (*RouteMetadataDataStore) DeleteRouteMetadata ¶
func (rmds *RouteMetadataDataStore) DeleteRouteMetadata(namespace, name string)
DeleteRouteMetadata deletes a route metadata entry from the store.
func (*RouteMetadataDataStore) GetRouteMetadata ¶
func (rmds *RouteMetadataDataStore) GetRouteMetadata(namespace, name string) (dpv2alpha1.RouteMetadata, bool)
GetRouteMetadata retrieves a route metadata entry from the store.
func (*RouteMetadataDataStore) GetRouteMetadatas ¶
func (rmds *RouteMetadataDataStore) GetRouteMetadatas() map[string]dpv2alpha1.RouteMetadata
GetRouteMetadatas retrieves all route metadata entries from the store.
type RoutePolicyDataStore ¶
type RoutePolicyDataStore struct {
// contains filtered or unexported fields
}
RoutePolicyDataStore holds RoutePolicy objects,
func GetRoutePolicyDataStore ¶
func GetRoutePolicyDataStore() *RoutePolicyDataStore
GetRoutePolicyDataStore returns the singleton instance of RoutePolicyDataStore.
func (*RoutePolicyDataStore) AddOrUpdateRoutePolicy ¶
func (rds *RoutePolicyDataStore) AddOrUpdateRoutePolicy(routePolicy dpv2alpha1.RoutePolicy)
AddOrUpdateRoutePolicy adds or updates a route policy in the RoutePolicyDataStore.
func (*RoutePolicyDataStore) DeleteRoutePolicy ¶
func (rds *RoutePolicyDataStore) DeleteRoutePolicy(namespace, name string)
DeleteRoutePolicy deletes a route policy from the RoutePolicyDataStore.
func (*RoutePolicyDataStore) GetRoutePolicies ¶
func (rds *RoutePolicyDataStore) GetRoutePolicies() map[string]dpv2alpha1.RoutePolicy
GetRoutePolicies retrieves all route policies from the RoutePolicyDataStore.
func (*RoutePolicyDataStore) GetRoutePolicy ¶
func (rds *RoutePolicyDataStore) GetRoutePolicy(namespace, name string) (dpv2alpha1.RoutePolicy, bool)
GetRoutePolicy retrieves a route policy from the RoutePolicyDataStore.
type SubscriptionDataStore ¶
type SubscriptionDataStore struct {
// contains filtered or unexported fields
}
SubscriptionDataStore is a cache subscription data.
func CreateNewSubscriptionDataStore ¶
func CreateNewSubscriptionDataStore() *SubscriptionDataStore
CreateNewSubscriptionDataStore creates a new SubscriptionDataStore.
func (*SubscriptionDataStore) AddorUpdateApplicationMappingToStore ¶
func (ods *SubscriptionDataStore) AddorUpdateApplicationMappingToStore(name types.NamespacedName, applicationMapping cpv1alpha2.ApplicationMappingSpec)
AddorUpdateApplicationMappingToStore adds a new application mapping to the DataStore.
func (*SubscriptionDataStore) AddorUpdateApplicationToStore ¶
func (ods *SubscriptionDataStore) AddorUpdateApplicationToStore(name types.NamespacedName, application cpv1alpha2.ApplicationSpec)
AddorUpdateApplicationToStore adds a new application to the DataStore.
func (*SubscriptionDataStore) AddorUpdateSubscriptionToStore ¶
func (ods *SubscriptionDataStore) AddorUpdateSubscriptionToStore(name types.NamespacedName, subscription cpv1alpha3.SubscriptionSpec)
AddorUpdateSubscriptionToStore adds a new subscription to the DataStore.
func (*SubscriptionDataStore) DeleteApplicationFromStore ¶
func (ods *SubscriptionDataStore) DeleteApplicationFromStore(name types.NamespacedName)
DeleteApplicationFromStore delete from application cache
func (*SubscriptionDataStore) DeleteApplicationMappingFromStore ¶
func (ods *SubscriptionDataStore) DeleteApplicationMappingFromStore(name types.NamespacedName)
DeleteApplicationMappingFromStore delete from application mapping cache
func (*SubscriptionDataStore) DeleteSubscriptionFromStore ¶
func (ods *SubscriptionDataStore) DeleteSubscriptionFromStore(name types.NamespacedName)
DeleteSubscriptionFromStore delete from subscription cache
func (*SubscriptionDataStore) GetApplicationFromStore ¶
func (ods *SubscriptionDataStore) GetApplicationFromStore(name types.NamespacedName) (cpv1alpha2.ApplicationSpec, bool)
GetApplicationFromStore get cached application
func (*SubscriptionDataStore) GetApplicationMappingFromStore ¶
func (ods *SubscriptionDataStore) GetApplicationMappingFromStore(name types.NamespacedName) (cpv1alpha2.ApplicationMappingSpec, bool)
GetApplicationMappingFromStore get cached application mapping
func (*SubscriptionDataStore) GetSubscriptionFromStore ¶
func (ods *SubscriptionDataStore) GetSubscriptionFromStore(name types.NamespacedName) (cpv1alpha3.SubscriptionSpec, bool)
GetSubscriptionFromStore get cached subscription
Source Files