flowcontrolv1

Sep 26, 2022

Changes in this version

+ var ClassifierInfo_Error_name = map[int32]string

+ var ClassifierInfo_Error_value = map[string]int32

+ var ControlPointInfo_Type_name = map[int32]string

+ var ControlPointInfo_Type_value = map[string]int32

type CheckResponse

+ ClassifierInfos []*ClassifierInfo

+ ControlPointInfo *ControlPointInfo

+ FluxMeterInfos []*FluxMeterInfo

+ func (x *CheckResponse) GetClassifierInfos() []*ClassifierInfo

+ func (x *CheckResponse) GetControlPointInfo() *ControlPointInfo

+ func (x *CheckResponse) GetFluxMeterInfos() []*FluxMeterInfo

+ type ClassifierInfo struct

+ ClassifierIndex int64

+ Error ClassifierInfo_Error

+ LabelKey string

+ PolicyHash string

+ PolicyName string

+ func (*ClassifierInfo) Descriptor() ([]byte, []int)

+ func (*ClassifierInfo) ProtoMessage()

+ func (in *ClassifierInfo) DeepCopy() *ClassifierInfo

+ func (in *ClassifierInfo) DeepCopyInterface() interface{}

+ func (in *ClassifierInfo) DeepCopyInto(out *ClassifierInfo)

+ func (msg *ClassifierInfo) MarshalJSON() ([]byte, error)

+ func (msg *ClassifierInfo) UnmarshalJSON(b []byte) error

+ func (x *ClassifierInfo) GetClassifierIndex() int64

+ func (x *ClassifierInfo) GetError() ClassifierInfo_Error

+ func (x *ClassifierInfo) GetLabelKey() string

+ func (x *ClassifierInfo) GetPolicyHash() string

+ func (x *ClassifierInfo) GetPolicyName() string

+ func (x *ClassifierInfo) ProtoReflect() protoreflect.Message

+ func (x *ClassifierInfo) Reset()

+ func (x *ClassifierInfo) String() string

+ type ClassifierInfo_Error int32

+ const ClassifierInfo_ERROR_AMBIGUOUS_RESULTSET

+ const ClassifierInfo_ERROR_EMPTY_RESULTSET

+ const ClassifierInfo_ERROR_EVAL_FAILED

+ const ClassifierInfo_ERROR_EXPRESSION_NOT_MAP

+ const ClassifierInfo_ERROR_MULTI_EXPRESSION

+ const ClassifierInfo_ERROR_NONE

+ func (ClassifierInfo_Error) Descriptor() protoreflect.EnumDescriptor

+ func (ClassifierInfo_Error) EnumDescriptor() ([]byte, []int)

+ func (ClassifierInfo_Error) Type() protoreflect.EnumType

+ func (x ClassifierInfo_Error) Enum() *ClassifierInfo_Error

+ func (x ClassifierInfo_Error) Number() protoreflect.EnumNumber

+ func (x ClassifierInfo_Error) String() string

+ type ControlPointInfo struct

+ Feature string

+ Type ControlPointInfo_Type

+ func (*ControlPointInfo) Descriptor() ([]byte, []int)

+ func (*ControlPointInfo) ProtoMessage()

+ func (in *ControlPointInfo) DeepCopy() *ControlPointInfo

+ func (in *ControlPointInfo) DeepCopyInterface() interface{}

+ func (in *ControlPointInfo) DeepCopyInto(out *ControlPointInfo)

+ func (msg *ControlPointInfo) MarshalJSON() ([]byte, error)

+ func (msg *ControlPointInfo) UnmarshalJSON(b []byte) error

+ func (x *ControlPointInfo) GetFeature() string

+ func (x *ControlPointInfo) GetType() ControlPointInfo_Type

+ func (x *ControlPointInfo) ProtoReflect() protoreflect.Message

+ func (x *ControlPointInfo) Reset()

+ func (x *ControlPointInfo) String() string

+ type ControlPointInfo_Type int32

+ const ControlPointInfo_TYPE_EGRESS

+ const ControlPointInfo_TYPE_FEATURE

+ const ControlPointInfo_TYPE_INGRESS

+ const ControlPointInfo_TYPE_UNKNOWN

+ func (ControlPointInfo_Type) Descriptor() protoreflect.EnumDescriptor

+ func (ControlPointInfo_Type) EnumDescriptor() ([]byte, []int)

+ func (ControlPointInfo_Type) Type() protoreflect.EnumType

+ func (x ControlPointInfo_Type) Enum() *ControlPointInfo_Type

+ func (x ControlPointInfo_Type) Number() protoreflect.EnumNumber

+ func (x ControlPointInfo_Type) String() string

+ type FluxMeterInfo struct

+ FluxMeterName string

+ func (*FluxMeterInfo) Descriptor() ([]byte, []int)

+ func (*FluxMeterInfo) ProtoMessage()

+ func (in *FluxMeterInfo) DeepCopy() *FluxMeterInfo

+ func (in *FluxMeterInfo) DeepCopyInterface() interface{}

+ func (in *FluxMeterInfo) DeepCopyInto(out *FluxMeterInfo)

+ func (msg *FluxMeterInfo) MarshalJSON() ([]byte, error)

+ func (msg *FluxMeterInfo) UnmarshalJSON(b []byte) error

+ func (x *FluxMeterInfo) GetFluxMeterName() string

+ func (x *FluxMeterInfo) ProtoReflect() protoreflect.Message

+ func (x *FluxMeterInfo) Reset()

+ func (x *FluxMeterInfo) String() string

type LimiterDecision

+ func (x *LimiterDecision) GetConcurrencyLimiterInfo() *LimiterDecision_ConcurrencyLimiterInfo

+ func (x *LimiterDecision) GetRateLimiterInfo() *LimiterDecision_RateLimiterInfo

+ type LimiterDecision_ConcurrencyLimiterInfo struct

+ WorkloadIndex string

+ func (*LimiterDecision_ConcurrencyLimiterInfo) Descriptor() ([]byte, []int)

+ func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoMessage()

+ func (in *LimiterDecision_ConcurrencyLimiterInfo) DeepCopy() *LimiterDecision_ConcurrencyLimiterInfo

+ func (in *LimiterDecision_ConcurrencyLimiterInfo) DeepCopyInterface() interface{}

+ func (in *LimiterDecision_ConcurrencyLimiterInfo) DeepCopyInto(out *LimiterDecision_ConcurrencyLimiterInfo)

+ func (msg *LimiterDecision_ConcurrencyLimiterInfo) MarshalJSON() ([]byte, error)

+ func (msg *LimiterDecision_ConcurrencyLimiterInfo) UnmarshalJSON(b []byte) error

+ func (x *LimiterDecision_ConcurrencyLimiterInfo) GetWorkloadIndex() string

+ func (x *LimiterDecision_ConcurrencyLimiterInfo) ProtoReflect() protoreflect.Message

+ func (x *LimiterDecision_ConcurrencyLimiterInfo) Reset()

+ func (x *LimiterDecision_ConcurrencyLimiterInfo) String() string

+ type LimiterDecision_ConcurrencyLimiterInfo_ struct

+ ConcurrencyLimiterInfo *LimiterDecision_ConcurrencyLimiterInfo

+ type LimiterDecision_RateLimiterInfo struct

+ Current int64

+ Label string

+ Remaining int64

+ func (*LimiterDecision_RateLimiterInfo) Descriptor() ([]byte, []int)

+ func (*LimiterDecision_RateLimiterInfo) ProtoMessage()

+ func (in *LimiterDecision_RateLimiterInfo) DeepCopy() *LimiterDecision_RateLimiterInfo

+ func (in *LimiterDecision_RateLimiterInfo) DeepCopyInterface() interface{}

+ func (in *LimiterDecision_RateLimiterInfo) DeepCopyInto(out *LimiterDecision_RateLimiterInfo)

+ func (msg *LimiterDecision_RateLimiterInfo) MarshalJSON() ([]byte, error)

+ func (msg *LimiterDecision_RateLimiterInfo) UnmarshalJSON(b []byte) error

+ func (x *LimiterDecision_RateLimiterInfo) GetCurrent() int64

+ func (x *LimiterDecision_RateLimiterInfo) GetLabel() string

+ func (x *LimiterDecision_RateLimiterInfo) GetRemaining() int64

+ func (x *LimiterDecision_RateLimiterInfo) ProtoReflect() protoreflect.Message

+ func (x *LimiterDecision_RateLimiterInfo) Reset()

+ func (x *LimiterDecision_RateLimiterInfo) String() string

+ type LimiterDecision_RateLimiterInfo_ struct

+ RateLimiterInfo *LimiterDecision_RateLimiterInfo

Sep 19, 2022

Changes in this version

+ var CheckResponse_DecisionType_name = map[int32]string

+ var CheckResponse_DecisionType_value = map[string]int32

+ var CheckResponse_Error_name = map[int32]string

+ var CheckResponse_Error_value = map[string]int32

+ var CheckResponse_RejectReason_name = map[int32]string

+ var CheckResponse_RejectReason_value = map[string]int32

+ var Classifier_Error_name = map[int32]string

+ var Classifier_Error_value = map[string]int32

+ var ControlPoint_Type_name = map[int32]string

+ var ControlPoint_Type_value = map[string]int32

type CheckResponse

+ ControlPoint *ControlPoint

+ End *timestamppb.Timestamp

+ Error CheckResponse_Error

+ RejectReason CheckResponse_RejectReason

+ Services []string

+ Start *timestamppb.Timestamp

+ TelemetryFlowLabels map[string]string

+ func (x *CheckResponse) GetControlPoint() *ControlPoint

+ func (x *CheckResponse) GetEnd() *timestamppb.Timestamp

+ func (x *CheckResponse) GetError() CheckResponse_Error

+ func (x *CheckResponse) GetRejectReason() CheckResponse_RejectReason

+ func (x *CheckResponse) GetServices() []string

+ func (x *CheckResponse) GetStart() *timestamppb.Timestamp

+ func (x *CheckResponse) GetTelemetryFlowLabels() map[string]string

+ type CheckResponse_DecisionType int32

+ const CheckResponse_DECISION_TYPE_ACCEPTED

+ const CheckResponse_DECISION_TYPE_REJECTED

+ func (CheckResponse_DecisionType) Descriptor() protoreflect.EnumDescriptor

+ func (CheckResponse_DecisionType) EnumDescriptor() ([]byte, []int)

+ func (CheckResponse_DecisionType) Type() protoreflect.EnumType

+ func (x CheckResponse_DecisionType) Enum() *CheckResponse_DecisionType

+ func (x CheckResponse_DecisionType) Number() protoreflect.EnumNumber

+ func (x CheckResponse_DecisionType) String() string

+ type CheckResponse_Error int32

+ const CheckResponse_ERROR_CLASSIFY

+ const CheckResponse_ERROR_CONVERT_TO_MAP_STRUCT

+ const CheckResponse_ERROR_CONVERT_TO_REGO_AST

+ const CheckResponse_ERROR_INVALID_TRAFFIC_DIRECTION

+ const CheckResponse_ERROR_MISSING_TRAFFIC_DIRECTION

+ const CheckResponse_ERROR_NONE

+ func (CheckResponse_Error) Descriptor() protoreflect.EnumDescriptor

+ func (CheckResponse_Error) EnumDescriptor() ([]byte, []int)

+ func (CheckResponse_Error) Type() protoreflect.EnumType

+ func (x CheckResponse_Error) Enum() *CheckResponse_Error

+ func (x CheckResponse_Error) Number() protoreflect.EnumNumber

+ func (x CheckResponse_Error) String() string

+ type CheckResponse_RejectReason int32

+ const CheckResponse_REJECT_REASON_CONCURRENCY_LIMITED

+ const CheckResponse_REJECT_REASON_NONE

+ const CheckResponse_REJECT_REASON_RATE_LIMITED

+ func (CheckResponse_RejectReason) Descriptor() protoreflect.EnumDescriptor

+ func (CheckResponse_RejectReason) EnumDescriptor() ([]byte, []int)

+ func (CheckResponse_RejectReason) Type() protoreflect.EnumType

+ func (x CheckResponse_RejectReason) Enum() *CheckResponse_RejectReason

+ func (x CheckResponse_RejectReason) Number() protoreflect.EnumNumber

+ func (x CheckResponse_RejectReason) String() string

type Classifier

+ Error Classifier_Error

+ LabelKey string

+ func (x *Classifier) GetError() Classifier_Error

+ func (x *Classifier) GetLabelKey() string

+ type Classifier_Error int32

+ const Classifier_ERROR_AMBIGUOUS_RESULTSET

+ const Classifier_ERROR_EMPTY_RESULTSET

+ const Classifier_ERROR_EVAL_FAILED

+ const Classifier_ERROR_EXPRESSION_NOT_MAP

+ const Classifier_ERROR_MULTI_EXPRESSION

+ const Classifier_ERROR_NONE

+ func (Classifier_Error) Descriptor() protoreflect.EnumDescriptor

+ func (Classifier_Error) EnumDescriptor() ([]byte, []int)

+ func (Classifier_Error) Type() protoreflect.EnumType

+ func (x Classifier_Error) Enum() *Classifier_Error

+ func (x Classifier_Error) Number() protoreflect.EnumNumber

+ func (x Classifier_Error) String() string

+ type ControlPoint struct

+ Feature string

+ Type ControlPoint_Type

+ func (*ControlPoint) Descriptor() ([]byte, []int)

+ func (*ControlPoint) ProtoMessage()

+ func (in *ControlPoint) DeepCopy() *ControlPoint

+ func (in *ControlPoint) DeepCopyInterface() interface{}

+ func (in *ControlPoint) DeepCopyInto(out *ControlPoint)

+ func (msg *ControlPoint) MarshalJSON() ([]byte, error)

+ func (msg *ControlPoint) UnmarshalJSON(b []byte) error

+ func (x *ControlPoint) GetFeature() string

+ func (x *ControlPoint) GetType() ControlPoint_Type

+ func (x *ControlPoint) ProtoReflect() protoreflect.Message

+ func (x *ControlPoint) Reset()

+ func (x *ControlPoint) String() string

+ type ControlPoint_Type int32

+ const ControlPoint_TYPE_EGRESS

+ const ControlPoint_TYPE_FEATURE

+ const ControlPoint_TYPE_INGRESS

+ const ControlPoint_TYPE_UNKNOWN

+ func (ControlPoint_Type) Descriptor() protoreflect.EnumDescriptor

+ func (ControlPoint_Type) EnumDescriptor() ([]byte, []int)

+ func (ControlPoint_Type) Type() protoreflect.EnumType

+ func (x ControlPoint_Type) Enum() *ControlPoint_Type

+ func (x ControlPoint_Type) Number() protoreflect.EnumNumber

+ func (x ControlPoint_Type) String() string

Sep 8, 2022

Changes in this version

type AuthzResponse

+ func (in *AuthzResponse) DeepCopy() *AuthzResponse

+ func (in *AuthzResponse) DeepCopyInterface() interface{}

+ func (in *AuthzResponse) DeepCopyInto(out *AuthzResponse)

type CheckRequest

+ func (in *CheckRequest) DeepCopy() *CheckRequest

+ func (in *CheckRequest) DeepCopyInterface() interface{}

+ func (in *CheckRequest) DeepCopyInto(out *CheckRequest)

type CheckResponse

+ Classifiers []*Classifier

+ func (in *CheckResponse) DeepCopy() *CheckResponse

+ func (in *CheckResponse) DeepCopyInterface() interface{}

+ func (in *CheckResponse) DeepCopyInto(out *CheckResponse)

+ func (x *CheckResponse) GetClassifiers() []*Classifier

+ type Classifier struct

+ ClassifierIndex int64

+ PolicyHash string

+ PolicyName string

+ func (*Classifier) Descriptor() ([]byte, []int)

+ func (*Classifier) ProtoMessage()

+ func (in *Classifier) DeepCopy() *Classifier

+ func (in *Classifier) DeepCopyInterface() interface{}

+ func (in *Classifier) DeepCopyInto(out *Classifier)

+ func (msg *Classifier) MarshalJSON() ([]byte, error)

+ func (msg *Classifier) UnmarshalJSON(b []byte) error

+ func (x *Classifier) GetClassifierIndex() int64

+ func (x *Classifier) GetPolicyHash() string

+ func (x *Classifier) GetPolicyName() string

+ func (x *Classifier) ProtoReflect() protoreflect.Message

+ func (x *Classifier) Reset()

+ func (x *Classifier) String() string

type DecisionReason

+ func (in *DecisionReason) DeepCopy() *DecisionReason

+ func (in *DecisionReason) DeepCopyInterface() interface{}

+ func (in *DecisionReason) DeepCopyInto(out *DecisionReason)

type FluxMeter

+ func (in *FluxMeter) DeepCopy() *FluxMeter

+ func (in *FluxMeter) DeepCopyInterface() interface{}

+ func (in *FluxMeter) DeepCopyInto(out *FluxMeter)

type LimiterDecision

+ func (in *LimiterDecision) DeepCopy() *LimiterDecision

+ func (in *LimiterDecision) DeepCopyInterface() interface{}

+ func (in *LimiterDecision) DeepCopyInto(out *LimiterDecision)

type LimiterDecision_ConcurrencyLimiter

+ func (in *LimiterDecision_ConcurrencyLimiter) DeepCopy() *LimiterDecision_ConcurrencyLimiter

+ func (in *LimiterDecision_ConcurrencyLimiter) DeepCopyInterface() interface{}

+ func (in *LimiterDecision_ConcurrencyLimiter) DeepCopyInto(out *LimiterDecision_ConcurrencyLimiter)

type LimiterDecision_RateLimiter

+ func (in *LimiterDecision_RateLimiter) DeepCopy() *LimiterDecision_RateLimiter

+ func (in *LimiterDecision_RateLimiter) DeepCopyInterface() interface{}

+ func (in *LimiterDecision_RateLimiter) DeepCopyInto(out *LimiterDecision_RateLimiter)

Aug 31, 2022

Changes in this version

+ var AuthzResponse_Status_name = map[int32]string

+ var AuthzResponse_Status_value = map[string]int32

+ var DecisionReason_ErrorReason_name = map[int32]string

+ var DecisionReason_ErrorReason_value = map[string]int32

+ var DecisionReason_RejectReason_name = map[int32]string

+ var DecisionReason_RejectReason_value = map[string]int32

+ var DecisionType_name = map[int32]string

+ var DecisionType_value = map[string]int32

+ var File_aperture_flowcontrol_v1_envoy_proto protoreflect.FileDescriptor

+ var File_aperture_flowcontrol_v1_flowcontrol_proto protoreflect.FileDescriptor

+ var FlowControlService_ServiceDesc = grpc.ServiceDesc

+ var LimiterDecision_LimiterReason_name = map[int32]string

+ var LimiterDecision_LimiterReason_value = map[string]int32

+ func RegisterFlowControlServiceServer(s grpc.ServiceRegistrar, srv FlowControlServiceServer)

+ type AuthzResponse struct

+ Status AuthzResponse_Status

+ func (*AuthzResponse) Descriptor() ([]byte, []int)

+ func (*AuthzResponse) ProtoMessage()

+ func (msg *AuthzResponse) MarshalJSON() ([]byte, error)

+ func (msg *AuthzResponse) UnmarshalJSON(b []byte) error

+ func (x *AuthzResponse) GetStatus() AuthzResponse_Status

+ func (x *AuthzResponse) ProtoReflect() protoreflect.Message

+ func (x *AuthzResponse) Reset()

+ func (x *AuthzResponse) String() string

+ type AuthzResponse_Status int32

+ const AuthzResponse_STATUS_CLASSIFY_FLOW_LABELS

+ const AuthzResponse_STATUS_CONVERT_TO_MAP_STRUCT

+ const AuthzResponse_STATUS_CONVERT_TO_REGO_AST

+ const AuthzResponse_STATUS_INVALID_TRAFFIC_DIRECTION

+ const AuthzResponse_STATUS_NO_ERROR

+ func (AuthzResponse_Status) Descriptor() protoreflect.EnumDescriptor

+ func (AuthzResponse_Status) EnumDescriptor() ([]byte, []int)

+ func (AuthzResponse_Status) Type() protoreflect.EnumType

+ func (x AuthzResponse_Status) Enum() *AuthzResponse_Status

+ func (x AuthzResponse_Status) Number() protoreflect.EnumNumber

+ func (x AuthzResponse_Status) String() string

+ type CheckRequest struct

+ Feature string

+ Labels map[string]string

+ func (*CheckRequest) Descriptor() ([]byte, []int)

+ func (*CheckRequest) ProtoMessage()

+ func (msg *CheckRequest) MarshalJSON() ([]byte, error)

+ func (msg *CheckRequest) UnmarshalJSON(b []byte) error

+ func (x *CheckRequest) GetFeature() string

+ func (x *CheckRequest) GetLabels() map[string]string

+ func (x *CheckRequest) ProtoReflect() protoreflect.Message

+ func (x *CheckRequest) Reset()

+ func (x *CheckRequest) String() string

+ type CheckResponse struct

+ DecisionReason *DecisionReason

+ DecisionType DecisionType

+ FlowLabelKeys []string

+ FluxMeters []*FluxMeter

+ LimiterDecisions []*LimiterDecision

+ func (*CheckResponse) Descriptor() ([]byte, []int)

+ func (*CheckResponse) ProtoMessage()

+ func (msg *CheckResponse) MarshalJSON() ([]byte, error)

+ func (msg *CheckResponse) UnmarshalJSON(b []byte) error

+ func (x *CheckResponse) GetDecisionReason() *DecisionReason

+ func (x *CheckResponse) GetDecisionType() DecisionType

+ func (x *CheckResponse) GetFlowLabelKeys() []string

+ func (x *CheckResponse) GetFluxMeters() []*FluxMeter

+ func (x *CheckResponse) GetLimiterDecisions() []*LimiterDecision

+ func (x *CheckResponse) ProtoReflect() protoreflect.Message

+ func (x *CheckResponse) Reset()

+ func (x *CheckResponse) String() string

+ type DecisionReason struct

+ ErrorReason DecisionReason_ErrorReason

+ RejectReason DecisionReason_RejectReason

+ func (*DecisionReason) Descriptor() ([]byte, []int)

+ func (*DecisionReason) ProtoMessage()

+ func (msg *DecisionReason) MarshalJSON() ([]byte, error)

+ func (msg *DecisionReason) UnmarshalJSON(b []byte) error

+ func (x *DecisionReason) GetErrorReason() DecisionReason_ErrorReason

+ func (x *DecisionReason) GetRejectReason() DecisionReason_RejectReason

+ func (x *DecisionReason) ProtoReflect() protoreflect.Message

+ func (x *DecisionReason) Reset()

+ func (x *DecisionReason) String() string

+ type DecisionReason_ErrorReason int32

+ const DecisionReason_ERROR_REASON_UNSPECIFIED

+ func (DecisionReason_ErrorReason) Descriptor() protoreflect.EnumDescriptor

+ func (DecisionReason_ErrorReason) EnumDescriptor() ([]byte, []int)

+ func (DecisionReason_ErrorReason) Type() protoreflect.EnumType

+ func (x DecisionReason_ErrorReason) Enum() *DecisionReason_ErrorReason

+ func (x DecisionReason_ErrorReason) Number() protoreflect.EnumNumber

+ func (x DecisionReason_ErrorReason) String() string

+ type DecisionReason_RejectReason int32

+ const DecisionReason_REJECT_REASON_CONCURRENCY_LIMITED

+ const DecisionReason_REJECT_REASON_RATE_LIMITED

+ const DecisionReason_REJECT_REASON_UNSPECIFIED

+ func (DecisionReason_RejectReason) Descriptor() protoreflect.EnumDescriptor

+ func (DecisionReason_RejectReason) EnumDescriptor() ([]byte, []int)

+ func (DecisionReason_RejectReason) Type() protoreflect.EnumType

+ func (x DecisionReason_RejectReason) Enum() *DecisionReason_RejectReason

+ func (x DecisionReason_RejectReason) Number() protoreflect.EnumNumber

+ func (x DecisionReason_RejectReason) String() string

+ type DecisionType int32

+ const DecisionType_DECISION_TYPE_ACCEPTED

+ const DecisionType_DECISION_TYPE_REJECTED

+ const DecisionType_DECISION_TYPE_UNSPECIFIED

+ func (DecisionType) Descriptor() protoreflect.EnumDescriptor

+ func (DecisionType) EnumDescriptor() ([]byte, []int)

+ func (DecisionType) Type() protoreflect.EnumType

+ func (x DecisionType) Enum() *DecisionType

+ func (x DecisionType) Number() protoreflect.EnumNumber

+ func (x DecisionType) String() string

+ type FlowControlServiceClient interface

+ Check func(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)

+ func NewFlowControlServiceClient(cc grpc.ClientConnInterface) FlowControlServiceClient

+ type FlowControlServiceServer interface

+ Check func(context.Context, *CheckRequest) (*CheckResponse, error)

+ type FluxMeter struct

+ FluxMeterName string

+ func (*FluxMeter) Descriptor() ([]byte, []int)

+ func (*FluxMeter) ProtoMessage()

+ func (msg *FluxMeter) MarshalJSON() ([]byte, error)

+ func (msg *FluxMeter) UnmarshalJSON(b []byte) error

+ func (x *FluxMeter) GetFluxMeterName() string

+ func (x *FluxMeter) ProtoReflect() protoreflect.Message

+ func (x *FluxMeter) Reset()

+ func (x *FluxMeter) String() string

+ type LimiterDecision struct

+ ComponentIndex int64

+ Details isLimiterDecision_Details

+ Dropped bool

+ PolicyHash string

+ PolicyName string

+ Reason LimiterDecision_LimiterReason

+ func (*LimiterDecision) Descriptor() ([]byte, []int)

+ func (*LimiterDecision) ProtoMessage()

+ func (m *LimiterDecision) GetDetails() isLimiterDecision_Details

+ func (msg *LimiterDecision) MarshalJSON() ([]byte, error)

+ func (msg *LimiterDecision) UnmarshalJSON(b []byte) error

+ func (x *LimiterDecision) GetComponentIndex() int64

+ func (x *LimiterDecision) GetConcurrencyLimiter() *LimiterDecision_ConcurrencyLimiter

+ func (x *LimiterDecision) GetDropped() bool

+ func (x *LimiterDecision) GetPolicyHash() string

+ func (x *LimiterDecision) GetPolicyName() string

+ func (x *LimiterDecision) GetRateLimiter() *LimiterDecision_RateLimiter

+ func (x *LimiterDecision) GetReason() LimiterDecision_LimiterReason

+ func (x *LimiterDecision) ProtoReflect() protoreflect.Message

+ func (x *LimiterDecision) Reset()

+ func (x *LimiterDecision) String() string

+ type LimiterDecision_ConcurrencyLimiter struct

+ WorkloadIndex string

+ func (*LimiterDecision_ConcurrencyLimiter) Descriptor() ([]byte, []int)

+ func (*LimiterDecision_ConcurrencyLimiter) ProtoMessage()

+ func (msg *LimiterDecision_ConcurrencyLimiter) MarshalJSON() ([]byte, error)

+ func (msg *LimiterDecision_ConcurrencyLimiter) UnmarshalJSON(b []byte) error

+ func (x *LimiterDecision_ConcurrencyLimiter) GetWorkloadIndex() string

+ func (x *LimiterDecision_ConcurrencyLimiter) ProtoReflect() protoreflect.Message

+ func (x *LimiterDecision_ConcurrencyLimiter) Reset()

+ func (x *LimiterDecision_ConcurrencyLimiter) String() string

+ type LimiterDecision_ConcurrencyLimiter_ struct

+ ConcurrencyLimiter *LimiterDecision_ConcurrencyLimiter

+ type LimiterDecision_LimiterReason int32

+ const LimiterDecision_LIMITER_REASON_KEY_NOT_FOUND

+ const LimiterDecision_LIMITER_REASON_UNSPECIFIED

+ func (LimiterDecision_LimiterReason) Descriptor() protoreflect.EnumDescriptor

+ func (LimiterDecision_LimiterReason) EnumDescriptor() ([]byte, []int)

+ func (LimiterDecision_LimiterReason) Type() protoreflect.EnumType

+ func (x LimiterDecision_LimiterReason) Enum() *LimiterDecision_LimiterReason

+ func (x LimiterDecision_LimiterReason) Number() protoreflect.EnumNumber

+ func (x LimiterDecision_LimiterReason) String() string

+ type LimiterDecision_RateLimiter struct

+ Current int64

+ Label string

+ Remaining int64

+ func (*LimiterDecision_RateLimiter) Descriptor() ([]byte, []int)

+ func (*LimiterDecision_RateLimiter) ProtoMessage()

+ func (msg *LimiterDecision_RateLimiter) MarshalJSON() ([]byte, error)

+ func (msg *LimiterDecision_RateLimiter) UnmarshalJSON(b []byte) error

+ func (x *LimiterDecision_RateLimiter) GetCurrent() int64

+ func (x *LimiterDecision_RateLimiter) GetLabel() string

+ func (x *LimiterDecision_RateLimiter) GetRemaining() int64

+ func (x *LimiterDecision_RateLimiter) ProtoReflect() protoreflect.Message

+ func (x *LimiterDecision_RateLimiter) Reset()

+ func (x *LimiterDecision_RateLimiter) String() string

+ type LimiterDecision_RateLimiter_ struct

+ RateLimiter *LimiterDecision_RateLimiter

+ type UnimplementedFlowControlServiceServer struct

+ func (UnimplementedFlowControlServiceServer) Check(context.Context, *CheckRequest) (*CheckResponse, error)

+ type UnsafeFlowControlServiceServer interface