Versions in this module Expand all Collapse all v0 v0.1.3-alpha.0 Jan 11, 2024 v0.1.2 Dec 29, 2023 Changes in this version + const AllSubsetPublic + const ResourceAll + var BreakerState_name = map[int32]string + var BreakerState_value = map[string]int32 + var CircuitBreaker_Option_name = map[int32]string + var CircuitBreaker_Option_value = map[string]int32 + var DefaultHttpClient = &http.Client + var File_pkg_apis_ctrlmesh_proto_ctrlmesh_proto protoreflect.FileDescriptor + var File_pkg_apis_ctrlmesh_proto_throttling_proto protoreflect.FileDescriptor + var RateLimiting_RecoverType_name = map[int32]string + var RateLimiting_RecoverType_value = map[string]int32 + var RateLimiting_TriggerPolicy_name = map[int32]string + var RateLimiting_TriggerPolicy_value = map[string]int32 + var TrafficInterceptRule_ContentType_name = map[int32]string + var TrafficInterceptRule_ContentType_value = map[string]int32 + var TrafficInterceptRule_InterceptType_name = map[int32]string + var TrafficInterceptRule_InterceptType_value = map[string]int32 + type APIGroupResource struct + ApiGroups []string + Resources []string + func (*APIGroupResource) Descriptor() ([]byte, []int) + func (*APIGroupResource) ProtoMessage() + func (in *APIGroupResource) DeepCopy() *APIGroupResource + func (in *APIGroupResource) DeepCopyInterface() interface{} + func (in *APIGroupResource) DeepCopyInto(out *APIGroupResource) + func (x *APIGroupResource) GetApiGroups() []string + func (x *APIGroupResource) GetResources() []string + func (x *APIGroupResource) ProtoReflect() protoreflect.Message + func (x *APIGroupResource) Reset() + func (x *APIGroupResource) String() string + type BreakerState int32 + const BreakerState_CLOSED + const BreakerState_OPENED + func (BreakerState) Descriptor() protoreflect.EnumDescriptor + func (BreakerState) EnumDescriptor() ([]byte, []int) + func (BreakerState) Type() protoreflect.EnumType + func (x BreakerState) Enum() *BreakerState + func (x BreakerState) Number() protoreflect.EnumNumber + func (x BreakerState) String() string + type Bucket struct + Burst uint32 + Interval string + Limit uint32 + func (*Bucket) Descriptor() ([]byte, []int) + func (*Bucket) ProtoMessage() + func (in *Bucket) DeepCopy() *Bucket + func (in *Bucket) DeepCopyInterface() interface{} + func (in *Bucket) DeepCopyInto(out *Bucket) + func (x *Bucket) GetBurst() uint32 + func (x *Bucket) GetInterval() string + func (x *Bucket) GetLimit() uint32 + func (x *Bucket) ProtoReflect() protoreflect.Message + func (x *Bucket) Reset() + func (x *Bucket) String() string + type CircuitBreaker struct + ConfigHash string + Name string + Option CircuitBreaker_Option + RateLimitings []*RateLimiting + TrafficInterceptRules []*TrafficInterceptRule + func (*CircuitBreaker) Descriptor() ([]byte, []int) + func (*CircuitBreaker) ProtoMessage() + func (in *CircuitBreaker) DeepCopy() *CircuitBreaker + func (in *CircuitBreaker) DeepCopyInterface() interface{} + func (in *CircuitBreaker) DeepCopyInto(out *CircuitBreaker) + func (x *CircuitBreaker) GetConfigHash() string + func (x *CircuitBreaker) GetName() string + func (x *CircuitBreaker) GetOption() CircuitBreaker_Option + func (x *CircuitBreaker) GetRateLimitings() []*RateLimiting + func (x *CircuitBreaker) GetTrafficInterceptRules() []*TrafficInterceptRule + func (x *CircuitBreaker) ProtoReflect() protoreflect.Message + func (x *CircuitBreaker) Reset() + func (x *CircuitBreaker) String() string + type CircuitBreaker_Option int32 + const CircuitBreaker_CHECK + const CircuitBreaker_CREATE + const CircuitBreaker_DELETE + const CircuitBreaker_RECOVER + const CircuitBreaker_UPDATE + func (CircuitBreaker_Option) Descriptor() protoreflect.EnumDescriptor + func (CircuitBreaker_Option) EnumDescriptor() ([]byte, []int) + func (CircuitBreaker_Option) Type() protoreflect.EnumType + func (x CircuitBreaker_Option) Enum() *CircuitBreaker_Option + func (x CircuitBreaker_Option) Number() protoreflect.EnumNumber + func (x CircuitBreaker_Option) String() string + type ConfigResp struct + LimitingSnapshot []*LimitingSnapshot + Message string + Success bool + func (*ConfigResp) Descriptor() ([]byte, []int) + func (*ConfigResp) ProtoMessage() + func (in *ConfigResp) DeepCopy() *ConfigResp + func (in *ConfigResp) DeepCopyInterface() interface{} + func (in *ConfigResp) DeepCopyInto(out *ConfigResp) + func (x *ConfigResp) GetLimitingSnapshot() []*LimitingSnapshot + func (x *ConfigResp) GetMessage() string + func (x *ConfigResp) GetSuccess() bool + func (x *ConfigResp) ProtoReflect() protoreflect.Message + func (x *ConfigResp) Reset() + func (x *ConfigResp) String() string + type Endpoint struct + Ip string + Limits []*Limit + Name string + ShardName string + func (*Endpoint) Descriptor() ([]byte, []int) + func (*Endpoint) ProtoMessage() + func (in *Endpoint) DeepCopy() *Endpoint + func (in *Endpoint) DeepCopyInterface() interface{} + func (in *Endpoint) DeepCopyInto(out *Endpoint) + func (x *Endpoint) GetIp() string + func (x *Endpoint) GetLimits() []*Limit + func (x *Endpoint) GetName() string + func (x *Endpoint) GetShardName() string + func (x *Endpoint) ProtoReflect() protoreflect.Message + func (x *Endpoint) Reset() + func (x *Endpoint) String() string + type InternalSpec struct + func ConvertProtoSpecToInternal(protoSpec *ProxySpec) *InternalSpec + func (is *InternalSpec) GetMatchedSubsetEndpoint(ns string, gr schema.GroupResource) (ignore bool, self bool, hosts []string) + func (is *InternalSpec) GetObjectSelector(gr schema.GroupResource) (sel *metav1.LabelSelector) + type LeaderElectionState struct + Identity string + IsLeader bool + func (*LeaderElectionState) Descriptor() ([]byte, []int) + func (*LeaderElectionState) ProtoMessage() + func (in *LeaderElectionState) DeepCopy() *LeaderElectionState + func (in *LeaderElectionState) DeepCopyInterface() interface{} + func (in *LeaderElectionState) DeepCopyInto(out *LeaderElectionState) + func (x *LeaderElectionState) GetIdentity() string + func (x *LeaderElectionState) GetIsLeader() bool + func (x *LeaderElectionState) ProtoReflect() protoreflect.Message + func (x *LeaderElectionState) Reset() + func (x *LeaderElectionState) String() string + type Limit struct + ObjectSelector string + Resources []*APIGroupResource + func (*Limit) Descriptor() ([]byte, []int) + func (*Limit) ProtoMessage() + func (in *Limit) DeepCopy() *Limit + func (in *Limit) DeepCopyInterface() interface{} + func (in *Limit) DeepCopyInto(out *Limit) + func (x *Limit) GetObjectSelector() string + func (x *Limit) GetResources() []*APIGroupResource + func (x *Limit) ProtoReflect() protoreflect.Message + func (x *Limit) Reset() + func (x *Limit) String() string + type LimitingSnapshot struct + LastTransitionTime *v1.Time + LimitingName string + RecoverTime *v1.Time + State BreakerState + func (*LimitingSnapshot) Descriptor() ([]byte, []int) + func (*LimitingSnapshot) ProtoMessage() + func (in *LimitingSnapshot) DeepCopy() *LimitingSnapshot + func (in *LimitingSnapshot) DeepCopyInterface() interface{} + func (in *LimitingSnapshot) DeepCopyInto(out *LimitingSnapshot) + func (x *LimitingSnapshot) GetLastTransitionTime() *v1.Time + func (x *LimitingSnapshot) GetLimitingName() string + func (x *LimitingSnapshot) GetRecoverTime() *v1.Time + func (x *LimitingSnapshot) GetState() BreakerState + func (x *LimitingSnapshot) ProtoReflect() protoreflect.Message + func (x *LimitingSnapshot) Reset() + func (x *LimitingSnapshot) String() string + type MetaState struct + CurrentHash string + ExpectedHash string + HashUnloadReason string + func (*MetaState) Descriptor() ([]byte, []int) + func (*MetaState) ProtoMessage() + func (in *MetaState) DeepCopy() *MetaState + func (in *MetaState) DeepCopyInterface() interface{} + func (in *MetaState) DeepCopyInto(out *MetaState) + func (x *MetaState) GetCurrentHash() string + func (x *MetaState) GetExpectedHash() string + func (x *MetaState) GetHashUnloadReason() string + func (x *MetaState) ProtoReflect() protoreflect.Message + func (x *MetaState) Reset() + func (x *MetaState) String() string + type ProxySpec struct + Endpoints []*Endpoint + Limits []*Limit + Meta *SpecMeta + func (*ProxySpec) Descriptor() ([]byte, []int) + func (*ProxySpec) ProtoMessage() + func (in *ProxySpec) DeepCopy() *ProxySpec + func (in *ProxySpec) DeepCopyInterface() interface{} + func (in *ProxySpec) DeepCopyInto(out *ProxySpec) + func (x *ProxySpec) GetEndpoints() []*Endpoint + func (x *ProxySpec) GetLimits() []*Limit + func (x *ProxySpec) GetMeta() *SpecMeta + func (x *ProxySpec) ProtoReflect() protoreflect.Message + func (x *ProxySpec) Reset() + func (x *ProxySpec) String() string + type ProxyStatus struct + LeaderElectionState *LeaderElectionState + MetaState *MetaState + SelfInfo *SelfInfo + func (*ProxyStatus) Descriptor() ([]byte, []int) + func (*ProxyStatus) ProtoMessage() + func (in *ProxyStatus) DeepCopy() *ProxyStatus + func (in *ProxyStatus) DeepCopyInterface() interface{} + func (in *ProxyStatus) DeepCopyInto(out *ProxyStatus) + func (x *ProxyStatus) GetLeaderElectionState() *LeaderElectionState + func (x *ProxyStatus) GetMetaState() *MetaState + func (x *ProxyStatus) GetSelfInfo() *SelfInfo + func (x *ProxyStatus) ProtoReflect() protoreflect.Message + func (x *ProxyStatus) Reset() + func (x *ProxyStatus) String() string + type RateLimiting struct + Bucket *Bucket + Name string + Properties map[string]string + RecoverPolicy *RateLimiting_RecoverPolicy + ResourceRules []*ResourceRule + RestRules []*RestRules + TriggerPolicy RateLimiting_TriggerPolicy + ValidatePolicy string + func (*RateLimiting) Descriptor() ([]byte, []int) + func (*RateLimiting) ProtoMessage() + func (in *RateLimiting) DeepCopy() *RateLimiting + func (in *RateLimiting) DeepCopyInterface() interface{} + func (in *RateLimiting) DeepCopyInto(out *RateLimiting) + func (x *RateLimiting) GetBucket() *Bucket + func (x *RateLimiting) GetName() string + func (x *RateLimiting) GetProperties() map[string]string + func (x *RateLimiting) GetRecoverPolicy() *RateLimiting_RecoverPolicy + func (x *RateLimiting) GetResourceRules() []*ResourceRule + func (x *RateLimiting) GetRestRules() []*RestRules + func (x *RateLimiting) GetTriggerPolicy() RateLimiting_TriggerPolicy + func (x *RateLimiting) GetValidatePolicy() string + func (x *RateLimiting) ProtoReflect() protoreflect.Message + func (x *RateLimiting) Reset() + func (x *RateLimiting) String() string + type RateLimiting_RecoverPolicy struct + SleepingWindowSize string + Type RateLimiting_RecoverType + func (*RateLimiting_RecoverPolicy) Descriptor() ([]byte, []int) + func (*RateLimiting_RecoverPolicy) ProtoMessage() + func (in *RateLimiting_RecoverPolicy) DeepCopy() *RateLimiting_RecoverPolicy + func (in *RateLimiting_RecoverPolicy) DeepCopyInterface() interface{} + func (in *RateLimiting_RecoverPolicy) DeepCopyInto(out *RateLimiting_RecoverPolicy) + func (x *RateLimiting_RecoverPolicy) GetSleepingWindowSize() string + func (x *RateLimiting_RecoverPolicy) GetType() RateLimiting_RecoverType + func (x *RateLimiting_RecoverPolicy) ProtoReflect() protoreflect.Message + func (x *RateLimiting_RecoverPolicy) Reset() + func (x *RateLimiting_RecoverPolicy) String() string + type RateLimiting_RecoverType int32 + const RateLimiting_RECOVER_POLICY_MANUAL + const RateLimiting_RECOVER_POLICY_SLEEPING_WINDOW + func (RateLimiting_RecoverType) Descriptor() protoreflect.EnumDescriptor + func (RateLimiting_RecoverType) EnumDescriptor() ([]byte, []int) + func (RateLimiting_RecoverType) Type() protoreflect.EnumType + func (x RateLimiting_RecoverType) Enum() *RateLimiting_RecoverType + func (x RateLimiting_RecoverType) Number() protoreflect.EnumNumber + func (x RateLimiting_RecoverType) String() string + type RateLimiting_TriggerPolicy int32 + const RateLimiting_TRIGGER_POLICY_FORCE_CLOSED + const RateLimiting_TRIGGER_POLICY_FORCE_OPENED + const RateLimiting_TRIGGER_POLICY_LIMITER_ONLY + const RateLimiting_TRIGGER_POLICY_NORMAL + func (RateLimiting_TriggerPolicy) Descriptor() protoreflect.EnumDescriptor + func (RateLimiting_TriggerPolicy) EnumDescriptor() ([]byte, []int) + func (RateLimiting_TriggerPolicy) Type() protoreflect.EnumType + func (x RateLimiting_TriggerPolicy) Enum() *RateLimiting_TriggerPolicy + func (x RateLimiting_TriggerPolicy) Number() protoreflect.EnumNumber + func (x RateLimiting_TriggerPolicy) String() string + type ResourceRequest struct + GR schema.GroupResource + ObjectSelector *metav1.LabelSelector + type ResourceRule struct + ApiGroups []string + Namespaces []string + Resources []string + Verbs []string + func (*ResourceRule) Descriptor() ([]byte, []int) + func (*ResourceRule) ProtoMessage() + func (in *ResourceRule) DeepCopy() *ResourceRule + func (in *ResourceRule) DeepCopyInterface() interface{} + func (in *ResourceRule) DeepCopyInto(out *ResourceRule) + func (x *ResourceRule) GetApiGroups() []string + func (x *ResourceRule) GetNamespaces() []string + func (x *ResourceRule) GetResources() []string + func (x *ResourceRule) GetVerbs() []string + func (x *ResourceRule) ProtoReflect() protoreflect.Message + func (x *ResourceRule) Reset() + func (x *ResourceRule) String() string + type RestRules struct + Method string + Url string + func (*RestRules) Descriptor() ([]byte, []int) + func (*RestRules) ProtoMessage() + func (in *RestRules) DeepCopy() *RestRules + func (in *RestRules) DeepCopyInterface() interface{} + func (in *RestRules) DeepCopyInto(out *RestRules) + func (x *RestRules) GetMethod() string + func (x *RestRules) GetUrl() string + func (x *RestRules) ProtoReflect() protoreflect.Message + func (x *RestRules) Reset() + func (x *RestRules) String() string + type SelfInfo struct + Name string + Namespace string + func (*SelfInfo) Descriptor() ([]byte, []int) + func (*SelfInfo) ProtoMessage() + func (in *SelfInfo) DeepCopy() *SelfInfo + func (in *SelfInfo) DeepCopyInterface() interface{} + func (in *SelfInfo) DeepCopyInto(out *SelfInfo) + func (x *SelfInfo) GetName() string + func (x *SelfInfo) GetNamespace() string + func (x *SelfInfo) ProtoReflect() protoreflect.Message + func (x *SelfInfo) Reset() + func (x *SelfInfo) String() string + type SpecMeta struct + Hash string + ShardName string + func (*SpecMeta) Descriptor() ([]byte, []int) + func (*SpecMeta) ProtoMessage() + func (in *SpecMeta) DeepCopy() *SpecMeta + func (in *SpecMeta) DeepCopyInterface() interface{} + func (in *SpecMeta) DeepCopyInto(out *SpecMeta) + func (x *SpecMeta) GetHash() string + func (x *SpecMeta) GetShardName() string + func (x *SpecMeta) ProtoReflect() protoreflect.Message + func (x *SpecMeta) Reset() + func (x *SpecMeta) String() string + type TrafficInterceptRule struct + ContentType TrafficInterceptRule_ContentType + Contents []string + InterceptType TrafficInterceptRule_InterceptType + Methods []string + Name string + func (*TrafficInterceptRule) Descriptor() ([]byte, []int) + func (*TrafficInterceptRule) ProtoMessage() + func (in *TrafficInterceptRule) DeepCopy() *TrafficInterceptRule + func (in *TrafficInterceptRule) DeepCopyInterface() interface{} + func (in *TrafficInterceptRule) DeepCopyInto(out *TrafficInterceptRule) + func (x *TrafficInterceptRule) GetContentType() TrafficInterceptRule_ContentType + func (x *TrafficInterceptRule) GetContents() []string + func (x *TrafficInterceptRule) GetInterceptType() TrafficInterceptRule_InterceptType + func (x *TrafficInterceptRule) GetMethods() []string + func (x *TrafficInterceptRule) GetName() string + func (x *TrafficInterceptRule) ProtoReflect() protoreflect.Message + func (x *TrafficInterceptRule) Reset() + func (x *TrafficInterceptRule) String() string + type TrafficInterceptRule_ContentType int32 + const TrafficInterceptRule_NORMAL + const TrafficInterceptRule_REGEXP + func (TrafficInterceptRule_ContentType) Descriptor() protoreflect.EnumDescriptor + func (TrafficInterceptRule_ContentType) EnumDescriptor() ([]byte, []int) + func (TrafficInterceptRule_ContentType) Type() protoreflect.EnumType + func (x TrafficInterceptRule_ContentType) Enum() *TrafficInterceptRule_ContentType + func (x TrafficInterceptRule_ContentType) Number() protoreflect.EnumNumber + func (x TrafficInterceptRule_ContentType) String() string + type TrafficInterceptRule_InterceptType int32 + const TrafficInterceptRule_INTERCEPT_BLACKLIST + const TrafficInterceptRule_INTERCEPT_WHITELIST + func (TrafficInterceptRule_InterceptType) Descriptor() protoreflect.EnumDescriptor + func (TrafficInterceptRule_InterceptType) EnumDescriptor() ([]byte, []int) + func (TrafficInterceptRule_InterceptType) Type() protoreflect.EnumType + func (x TrafficInterceptRule_InterceptType) Enum() *TrafficInterceptRule_InterceptType + func (x TrafficInterceptRule_InterceptType) Number() protoreflect.EnumNumber + func (x TrafficInterceptRule_InterceptType) String() string