checkv1

package
v2.12.1-rc.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 18, 2023 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FlowControlService_Check_FullMethodName = "/aperture.flowcontrol.check.v1.FlowControlService/Check"
)

Variables

View Source 
var (
	CheckResponse_RejectReason_name = map[int32]string{
		0: "REJECT_REASON_NONE",
		1: "REJECT_REASON_RATE_LIMITED",
		2: "REJECT_REASON_NO_TOKENS",
		3: "REJECT_REASON_REGULATED",
	}
	CheckResponse_RejectReason_value = map[string]int32{
		"REJECT_REASON_NONE":         0,
		"REJECT_REASON_RATE_LIMITED": 1,
		"REJECT_REASON_NO_TOKENS":    2,
		"REJECT_REASON_REGULATED":    3,
	}
)

Enum value maps for CheckResponse_RejectReason.

View Source 
var (
	CheckResponse_DecisionType_name = map[int32]string{
		0: "DECISION_TYPE_ACCEPTED",
		1: "DECISION_TYPE_REJECTED",
	}
	CheckResponse_DecisionType_value = map[string]int32{
		"DECISION_TYPE_ACCEPTED": 0,
		"DECISION_TYPE_REJECTED": 1,
	}
)

Enum value maps for CheckResponse_DecisionType.

View Source 
var (
	ClassifierInfo_Error_name = map[int32]string{
		0: "ERROR_NONE",
		1: "ERROR_EVAL_FAILED",
		2: "ERROR_EMPTY_RESULTSET",
		3: "ERROR_AMBIGUOUS_RESULTSET",
		4: "ERROR_MULTI_EXPRESSION",
		5: "ERROR_EXPRESSION_NOT_MAP",
	}
	ClassifierInfo_Error_value = map[string]int32{
		"ERROR_NONE":                0,
		"ERROR_EVAL_FAILED":         1,
		"ERROR_EMPTY_RESULTSET":     2,
		"ERROR_AMBIGUOUS_RESULTSET": 3,
		"ERROR_MULTI_EXPRESSION":    4,
		"ERROR_EXPRESSION_NOT_MAP":  5,
	}
)

Enum value maps for ClassifierInfo_Error.

View Source 
var (
	LimiterDecision_LimiterReason_name = map[int32]string{
		0: "LIMITER_REASON_UNSPECIFIED",
		1: "LIMITER_REASON_KEY_NOT_FOUND",
	}
	LimiterDecision_LimiterReason_value = map[string]int32{
		"LIMITER_REASON_UNSPECIFIED":   0,
		"LIMITER_REASON_KEY_NOT_FOUND": 1,
	}
)

Enum value maps for LimiterDecision_LimiterReason.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_aperture_flowcontrol_check_v1_check_proto protoreflect.FileDescriptor
View Source 
var FlowControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aperture.flowcontrol.check.v1.FlowControlService",
	HandlerType: (*FlowControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Check",
			Handler:    _FlowControlService_Check_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aperture/flowcontrol/check/v1/check.proto",
}

FlowControlService_ServiceDesc is the grpc.ServiceDesc for FlowControlService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFlowControlServiceServer 

func RegisterFlowControlServiceServer(s grpc.ServiceRegistrar, srv FlowControlServiceServer)

Types

type CheckRequest 

type CheckRequest struct {
	ControlPoint string            `protobuf:"bytes,1,opt,name=control_point,json=controlPoint,proto3" json:"control_point,omitempty"`
	Labels       map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

CheckRequest contains fields required to perform Check call.

func (*CheckRequest) Descriptor deprecated 

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

Deprecated: Use CheckRequest.ProtoReflect.Descriptor instead.

func (*CheckRequest) GetControlPoint 

func (x *CheckRequest) GetControlPoint() string

func (*CheckRequest) GetLabels 

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

func (*CheckRequest) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CheckRequest) MarshalToSizedBufferVT added in v2.7.0 

func (m *CheckRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckRequest) MarshalToVT added in v2.7.0 

func (m *CheckRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CheckRequest) MarshalVT added in v2.7.0 

func (m *CheckRequest) MarshalVT() (dAtA []byte, err error)

func (*CheckRequest) ProtoMessage 

func (*CheckRequest) ProtoMessage()

func (*CheckRequest) ProtoReflect 

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

func (*CheckRequest) Reset 

func (x *CheckRequest) Reset()

func (*CheckRequest) SizeVT added in v2.7.0 

func (m *CheckRequest) SizeVT() (n int)

func (*CheckRequest) String 

func (x *CheckRequest) String() string

func (*CheckRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CheckRequest) UnmarshalVT added in v2.7.0 

func (m *CheckRequest) UnmarshalVT(dAtA []byte) error

func (*CheckRequest) Validate 

func (m *CheckRequest) Validate() error

Validate checks the field values on CheckRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CheckRequest) ValidateAll 

func (m *CheckRequest) ValidateAll() error

ValidateAll checks the field values on CheckRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CheckRequestMultiError, or nil if none found.

type CheckRequestMultiError 

type CheckRequestMultiError []error

CheckRequestMultiError is an error wrapping multiple validation errors returned by CheckRequest.ValidateAll() if the designated constraints aren't met.

func (CheckRequestMultiError) AllErrors 

func (m CheckRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CheckRequestMultiError) Error 

func (m CheckRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CheckRequestValidationError 

type CheckRequestValidationError struct {
	// contains filtered or unexported fields
}

CheckRequestValidationError is the validation error returned by CheckRequest.Validate if the designated constraints aren't met.

func (CheckRequestValidationError) Cause 

func (e CheckRequestValidationError) Cause() error

Cause function returns cause value.

func (CheckRequestValidationError) Error 

func (e CheckRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CheckRequestValidationError) ErrorName 

func (e CheckRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CheckRequestValidationError) Field 

func (e CheckRequestValidationError) Field() string

Field function returns field value.

func (CheckRequestValidationError) Key 

func (e CheckRequestValidationError) Key() bool

Key function returns key value.

func (CheckRequestValidationError) Reason 

func (e CheckRequestValidationError) Reason() string

Reason function returns reason value.

type CheckResponse 

type CheckResponse struct {

	// start timestamp
	Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	// end timestamp
	End *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	// services that matched
	Services []string `protobuf:"bytes,4,rep,name=services,proto3" json:"services,omitempty"`
	// control_point of request
	ControlPoint string `protobuf:"bytes,5,opt,name=control_point,json=controlPoint,proto3" json:"control_point,omitempty"`
	// flow label keys that were matched for this request.
	FlowLabelKeys []string `protobuf:"bytes,6,rep,name=flow_label_keys,json=flowLabelKeys,proto3" json:"flow_label_keys,omitempty"`
	// telemetry_flow_labels are labels for telemetry purpose. The keys in telemetry_flow_labels is subset of flow_label_keys.
	TelemetryFlowLabels map[string]string `` /* 208-byte string literal not displayed */
	// decision_type contains what the decision was.
	DecisionType CheckResponse_DecisionType `` /* 160-byte string literal not displayed */
	// reject_reason contains the reason for the rejection.
	RejectReason CheckResponse_RejectReason `` /* 160-byte string literal not displayed */
	// classifiers that were matched for this request.
	ClassifierInfos []*ClassifierInfo `protobuf:"bytes,10,rep,name=classifier_infos,json=classifierInfos,proto3" json:"classifier_infos,omitempty"`
	// flux meters that were matched for this request.
	FluxMeterInfos []*FluxMeterInfo `protobuf:"bytes,11,rep,name=flux_meter_infos,json=fluxMeterInfos,proto3" json:"flux_meter_infos,omitempty"`
	// limiter_decisions contains information about decision made by each limiter.
	LimiterDecisions []*LimiterDecision `protobuf:"bytes,12,rep,name=limiter_decisions,json=limiterDecisions,proto3" json:"limiter_decisions,omitempty"`
	// Recommended minimal amount of time to wait when retrying the request, if
	// decision_type is REJECTED. Optional.
	WaitTime *durationpb.Duration `protobuf:"bytes,13,opt,name=wait_time,json=waitTime,proto3" json:"wait_time,omitempty"`
	// contains filtered or unexported fields
}

CheckResponse contains fields that represent decision made by Check call.

func CheckResponseFromVTPool added in v2.7.0 

func CheckResponseFromVTPool() *CheckResponse

func (*CheckResponse) Descriptor deprecated 

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

Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead.

func (*CheckResponse) GetClassifierInfos 

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

func (*CheckResponse) GetControlPoint 

func (x *CheckResponse) GetControlPoint() string

func (*CheckResponse) GetDecisionType 

func (x *CheckResponse) GetDecisionType() CheckResponse_DecisionType

func (*CheckResponse) GetEnd 

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

func (*CheckResponse) GetFlowLabelKeys 

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

func (*CheckResponse) GetFluxMeterInfos 

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

func (*CheckResponse) GetLimiterDecisions 

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

func (*CheckResponse) GetRejectReason 

func (x *CheckResponse) GetRejectReason() CheckResponse_RejectReason

func (*CheckResponse) GetServices 

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

func (*CheckResponse) GetStart 

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

func (*CheckResponse) GetTelemetryFlowLabels 

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

func (*CheckResponse) GetWaitTime added in v2.5.0 

func (x *CheckResponse) GetWaitTime() *durationpb.Duration

func (*CheckResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CheckResponse) MarshalToSizedBufferVT added in v2.7.0 

func (m *CheckResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CheckResponse) MarshalToVT added in v2.7.0 

func (m *CheckResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CheckResponse) MarshalVT added in v2.7.0 

func (m *CheckResponse) MarshalVT() (dAtA []byte, err error)

func (*CheckResponse) ProtoMessage 

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) ProtoReflect 

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

func (*CheckResponse) Reset 

func (x *CheckResponse) Reset()

func (*CheckResponse) ResetVT added in v2.7.0 

func (m *CheckResponse) ResetVT()

func (*CheckResponse) ReturnToVTPool added in v2.7.0 

func (m *CheckResponse) ReturnToVTPool()

func (*CheckResponse) SizeVT added in v2.7.0 

func (m *CheckResponse) SizeVT() (n int)

func (*CheckResponse) String 

func (x *CheckResponse) String() string

func (*CheckResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CheckResponse) UnmarshalVT added in v2.7.0 

func (m *CheckResponse) UnmarshalVT(dAtA []byte) error

func (*CheckResponse) Validate 

func (m *CheckResponse) Validate() error

Validate checks the field values on CheckResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CheckResponse) ValidateAll 

func (m *CheckResponse) ValidateAll() error

ValidateAll checks the field values on CheckResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CheckResponseMultiError, or nil if none found.

type CheckResponseMultiError 

type CheckResponseMultiError []error

CheckResponseMultiError is an error wrapping multiple validation errors returned by CheckResponse.ValidateAll() if the designated constraints aren't met.

func (CheckResponseMultiError) AllErrors 

func (m CheckResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CheckResponseMultiError) Error 

func (m CheckResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CheckResponseValidationError 

type CheckResponseValidationError struct {
	// contains filtered or unexported fields
}

CheckResponseValidationError is the validation error returned by CheckResponse.Validate if the designated constraints aren't met.

func (CheckResponseValidationError) Cause 

func (e CheckResponseValidationError) Cause() error

Cause function returns cause value.

func (CheckResponseValidationError) Error 

func (e CheckResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CheckResponseValidationError) ErrorName 

func (e CheckResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CheckResponseValidationError) Field 

func (e CheckResponseValidationError) Field() string

Field function returns field value.

func (CheckResponseValidationError) Key 

func (e CheckResponseValidationError) Key() bool

Key function returns key value.

func (CheckResponseValidationError) Reason 

func (e CheckResponseValidationError) Reason() string

Reason function returns reason value.

type CheckResponse_DecisionType 

type CheckResponse_DecisionType int32

DecisionType contains fields that represent decision made by Check call. 

const (
	CheckResponse_DECISION_TYPE_ACCEPTED CheckResponse_DecisionType = 0
	CheckResponse_DECISION_TYPE_REJECTED CheckResponse_DecisionType = 1
)

func (CheckResponse_DecisionType) Descriptor 

func (CheckResponse_DecisionType) Descriptor() protoreflect.EnumDescriptor

func (CheckResponse_DecisionType) Enum 

func (x CheckResponse_DecisionType) Enum() *CheckResponse_DecisionType

func (CheckResponse_DecisionType) EnumDescriptor deprecated 

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

Deprecated: Use CheckResponse_DecisionType.Descriptor instead.

func (CheckResponse_DecisionType) Number 

func (x CheckResponse_DecisionType) Number() protoreflect.EnumNumber

func (CheckResponse_DecisionType) String 

func (x CheckResponse_DecisionType) String() string

func (CheckResponse_DecisionType) Type 

func (CheckResponse_DecisionType) Type() protoreflect.EnumType

type CheckResponse_RejectReason 

type CheckResponse_RejectReason int32

RejectReason contains fields that give further information about rejection. 

const (
	CheckResponse_REJECT_REASON_NONE         CheckResponse_RejectReason = 0
	CheckResponse_REJECT_REASON_RATE_LIMITED CheckResponse_RejectReason = 1
	CheckResponse_REJECT_REASON_NO_TOKENS    CheckResponse_RejectReason = 2
	CheckResponse_REJECT_REASON_REGULATED    CheckResponse_RejectReason = 3
)

func (CheckResponse_RejectReason) Descriptor 

func (CheckResponse_RejectReason) Descriptor() protoreflect.EnumDescriptor

func (CheckResponse_RejectReason) Enum 

func (x CheckResponse_RejectReason) Enum() *CheckResponse_RejectReason

func (CheckResponse_RejectReason) EnumDescriptor deprecated 

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

Deprecated: Use CheckResponse_RejectReason.Descriptor instead.

func (CheckResponse_RejectReason) Number 

func (x CheckResponse_RejectReason) Number() protoreflect.EnumNumber

func (CheckResponse_RejectReason) String 

func (x CheckResponse_RejectReason) String() string

func (CheckResponse_RejectReason) Type 

func (CheckResponse_RejectReason) Type() protoreflect.EnumType

type ClassifierInfo 

type ClassifierInfo struct {
	PolicyName      string               `protobuf:"bytes,1,opt,name=policy_name,json=policyName,proto3" json:"policy_name,omitempty"`
	PolicyHash      string               `protobuf:"bytes,2,opt,name=policy_hash,json=policyHash,proto3" json:"policy_hash,omitempty"`
	ClassifierIndex int64                `protobuf:"varint,3,opt,name=classifier_index,json=classifierIndex,proto3" json:"classifier_index,omitempty"`
	Error           ClassifierInfo_Error `protobuf:"varint,5,opt,name=error,proto3,enum=aperture.flowcontrol.check.v1.ClassifierInfo_Error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ClassifierInfo describes details for each ClassifierInfo.

func (*ClassifierInfo) Descriptor deprecated 

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

Deprecated: Use ClassifierInfo.ProtoReflect.Descriptor instead.

func (*ClassifierInfo) GetClassifierIndex 

func (x *ClassifierInfo) GetClassifierIndex() int64

func (*ClassifierInfo) GetError 

func (x *ClassifierInfo) GetError() ClassifierInfo_Error

func (*ClassifierInfo) GetPolicyHash 

func (x *ClassifierInfo) GetPolicyHash() string

func (*ClassifierInfo) GetPolicyName 

func (x *ClassifierInfo) GetPolicyName() string

func (*ClassifierInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*ClassifierInfo) MarshalToSizedBufferVT added in v2.7.0 

func (m *ClassifierInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ClassifierInfo) MarshalToVT added in v2.7.0 

func (m *ClassifierInfo) MarshalToVT(dAtA []byte) (int, error)

func (*ClassifierInfo) MarshalVT added in v2.7.0 

func (m *ClassifierInfo) MarshalVT() (dAtA []byte, err error)

func (*ClassifierInfo) ProtoMessage 

func (*ClassifierInfo) ProtoMessage()

func (*ClassifierInfo) ProtoReflect 

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

func (*ClassifierInfo) Reset 

func (x *ClassifierInfo) Reset()

func (*ClassifierInfo) SizeVT added in v2.7.0 

func (m *ClassifierInfo) SizeVT() (n int)

func (*ClassifierInfo) String 

func (x *ClassifierInfo) String() string

func (*ClassifierInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*ClassifierInfo) UnmarshalVT added in v2.7.0 

func (m *ClassifierInfo) UnmarshalVT(dAtA []byte) error

func (*ClassifierInfo) Validate 

func (m *ClassifierInfo) Validate() error

Validate checks the field values on ClassifierInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ClassifierInfo) ValidateAll 

func (m *ClassifierInfo) ValidateAll() error

ValidateAll checks the field values on ClassifierInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClassifierInfoMultiError, or nil if none found.

type ClassifierInfoMultiError 

type ClassifierInfoMultiError []error

ClassifierInfoMultiError is an error wrapping multiple validation errors returned by ClassifierInfo.ValidateAll() if the designated constraints aren't met.

func (ClassifierInfoMultiError) AllErrors 

func (m ClassifierInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ClassifierInfoMultiError) Error 

func (m ClassifierInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ClassifierInfoValidationError 

type ClassifierInfoValidationError struct {
	// contains filtered or unexported fields
}

ClassifierInfoValidationError is the validation error returned by ClassifierInfo.Validate if the designated constraints aren't met.

func (ClassifierInfoValidationError) Cause 

func (e ClassifierInfoValidationError) Cause() error

Cause function returns cause value.

func (ClassifierInfoValidationError) Error 

func (e ClassifierInfoValidationError) Error() string

Error satisfies the builtin error interface

func (ClassifierInfoValidationError) ErrorName 

func (e ClassifierInfoValidationError) ErrorName() string

ErrorName returns error name.

func (ClassifierInfoValidationError) Field 

func (e ClassifierInfoValidationError) Field() string

Field function returns field value.

func (ClassifierInfoValidationError) Key 

func (e ClassifierInfoValidationError) Key() bool

Key function returns key value.

func (ClassifierInfoValidationError) Reason 

func (e ClassifierInfoValidationError) Reason() string

Reason function returns reason value.

type ClassifierInfo_Error 

type ClassifierInfo_Error int32

Error information. 

const (
	ClassifierInfo_ERROR_NONE                ClassifierInfo_Error = 0
	ClassifierInfo_ERROR_EVAL_FAILED         ClassifierInfo_Error = 1
	ClassifierInfo_ERROR_EMPTY_RESULTSET     ClassifierInfo_Error = 2
	ClassifierInfo_ERROR_AMBIGUOUS_RESULTSET ClassifierInfo_Error = 3
	ClassifierInfo_ERROR_MULTI_EXPRESSION    ClassifierInfo_Error = 4
	ClassifierInfo_ERROR_EXPRESSION_NOT_MAP  ClassifierInfo_Error = 5
)

func (ClassifierInfo_Error) Descriptor 

func (ClassifierInfo_Error) Descriptor() protoreflect.EnumDescriptor

func (ClassifierInfo_Error) Enum 

func (x ClassifierInfo_Error) Enum() *ClassifierInfo_Error

func (ClassifierInfo_Error) EnumDescriptor deprecated 

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

Deprecated: Use ClassifierInfo_Error.Descriptor instead.

func (ClassifierInfo_Error) Number 

func (x ClassifierInfo_Error) Number() protoreflect.EnumNumber

func (ClassifierInfo_Error) String 

func (x ClassifierInfo_Error) String() string

func (ClassifierInfo_Error) Type 

func (ClassifierInfo_Error) Type() protoreflect.EnumType

type FlowControlServiceClient 

type FlowControlServiceClient interface {
	// Check wraps the given arbitrary resource and matches the given labels against Flow Control Limiters to makes a decision whether to allow/deny.
	Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
}

FlowControlServiceClient is the client API for FlowControlService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFlowControlServiceClient 

func NewFlowControlServiceClient(cc grpc.ClientConnInterface) FlowControlServiceClient

type FlowControlServiceServer 

type FlowControlServiceServer interface {
	// Check wraps the given arbitrary resource and matches the given labels against Flow Control Limiters to makes a decision whether to allow/deny.
	Check(context.Context, *CheckRequest) (*CheckResponse, error)
}

FlowControlServiceServer is the server API for FlowControlService service. All implementations should embed UnimplementedFlowControlServiceServer for forward compatibility

type FluxMeterInfo 

type FluxMeterInfo struct {
	FluxMeterName string `protobuf:"bytes,1,opt,name=flux_meter_name,json=fluxMeterName,proto3" json:"flux_meter_name,omitempty"`
	// contains filtered or unexported fields
}

FluxMeterInfo describes detail for each FluxMeterInfo.

func (*FluxMeterInfo) Descriptor deprecated 

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

Deprecated: Use FluxMeterInfo.ProtoReflect.Descriptor instead.

func (*FluxMeterInfo) GetFluxMeterName 

func (x *FluxMeterInfo) GetFluxMeterName() string

func (*FluxMeterInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*FluxMeterInfo) MarshalToSizedBufferVT added in v2.7.0 

func (m *FluxMeterInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FluxMeterInfo) MarshalToVT added in v2.7.0 

func (m *FluxMeterInfo) MarshalToVT(dAtA []byte) (int, error)

func (*FluxMeterInfo) MarshalVT added in v2.7.0 

func (m *FluxMeterInfo) MarshalVT() (dAtA []byte, err error)

func (*FluxMeterInfo) ProtoMessage 

func (*FluxMeterInfo) ProtoMessage()

func (*FluxMeterInfo) ProtoReflect 

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

func (*FluxMeterInfo) Reset 

func (x *FluxMeterInfo) Reset()

func (*FluxMeterInfo) SizeVT added in v2.7.0 

func (m *FluxMeterInfo) SizeVT() (n int)

func (*FluxMeterInfo) String 

func (x *FluxMeterInfo) String() string

func (*FluxMeterInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*FluxMeterInfo) UnmarshalVT added in v2.7.0 

func (m *FluxMeterInfo) UnmarshalVT(dAtA []byte) error

func (*FluxMeterInfo) Validate 

func (m *FluxMeterInfo) Validate() error

Validate checks the field values on FluxMeterInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*FluxMeterInfo) ValidateAll 

func (m *FluxMeterInfo) ValidateAll() error

ValidateAll checks the field values on FluxMeterInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FluxMeterInfoMultiError, or nil if none found.

type FluxMeterInfoMultiError 

type FluxMeterInfoMultiError []error

FluxMeterInfoMultiError is an error wrapping multiple validation errors returned by FluxMeterInfo.ValidateAll() if the designated constraints aren't met.

func (FluxMeterInfoMultiError) AllErrors 

func (m FluxMeterInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FluxMeterInfoMultiError) Error 

func (m FluxMeterInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type FluxMeterInfoValidationError 

type FluxMeterInfoValidationError struct {
	// contains filtered or unexported fields
}

FluxMeterInfoValidationError is the validation error returned by FluxMeterInfo.Validate if the designated constraints aren't met.

func (FluxMeterInfoValidationError) Cause 

func (e FluxMeterInfoValidationError) Cause() error

Cause function returns cause value.

func (FluxMeterInfoValidationError) Error 

func (e FluxMeterInfoValidationError) Error() string

Error satisfies the builtin error interface

func (FluxMeterInfoValidationError) ErrorName 

func (e FluxMeterInfoValidationError) ErrorName() string

ErrorName returns error name.

func (FluxMeterInfoValidationError) Field 

func (e FluxMeterInfoValidationError) Field() string

Field function returns field value.

func (FluxMeterInfoValidationError) Key 

func (e FluxMeterInfoValidationError) Key() bool

Key function returns key value.

func (FluxMeterInfoValidationError) Reason 

func (e FluxMeterInfoValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision 

type LimiterDecision struct {
	PolicyName  string                        `protobuf:"bytes,1,opt,name=policy_name,json=policyName,proto3" json:"policy_name,omitempty"`
	PolicyHash  string                        `protobuf:"bytes,2,opt,name=policy_hash,json=policyHash,proto3" json:"policy_hash,omitempty"`
	ComponentId string                        `protobuf:"bytes,3,opt,name=component_id,json=componentId,proto3" json:"component_id,omitempty"`
	Dropped     bool                          `protobuf:"varint,4,opt,name=dropped,proto3" json:"dropped,omitempty"`
	Reason      LimiterDecision_LimiterReason `` /* 131-byte string literal not displayed */
	// Types that are assignable to Details:
	//
	//	*LimiterDecision_RateLimiterInfo_
	//	*LimiterDecision_LoadSchedulerInfo
	//	*LimiterDecision_SamplerInfo_
	//	*LimiterDecision_QuotaSchedulerInfo_
	Details isLimiterDecision_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

LimiterDecision describes details for each limiter.

func (*LimiterDecision) Descriptor deprecated 

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

Deprecated: Use LimiterDecision.ProtoReflect.Descriptor instead.

func (*LimiterDecision) GetComponentId 

func (x *LimiterDecision) GetComponentId() string

func (*LimiterDecision) GetDetails 

func (m *LimiterDecision) GetDetails() isLimiterDecision_Details

func (*LimiterDecision) GetDropped 

func (x *LimiterDecision) GetDropped() bool

func (*LimiterDecision) GetLoadSchedulerInfo 

func (x *LimiterDecision) GetLoadSchedulerInfo() *LimiterDecision_SchedulerInfo

func (*LimiterDecision) GetPolicyHash 

func (x *LimiterDecision) GetPolicyHash() string

func (*LimiterDecision) GetPolicyName 

func (x *LimiterDecision) GetPolicyName() string

func (*LimiterDecision) GetQuotaSchedulerInfo added in v2.2.0 

func (x *LimiterDecision) GetQuotaSchedulerInfo() *LimiterDecision_QuotaSchedulerInfo

func (*LimiterDecision) GetRateLimiterInfo 

func (x *LimiterDecision) GetRateLimiterInfo() *LimiterDecision_RateLimiterInfo

func (*LimiterDecision) GetReason 

func (x *LimiterDecision) GetReason() LimiterDecision_LimiterReason

func (*LimiterDecision) GetSamplerInfo added in v2.5.0 

func (x *LimiterDecision) GetSamplerInfo() *LimiterDecision_SamplerInfo

func (*LimiterDecision) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision) MarshalToSizedBufferVT added in v2.7.0 

func (m *LimiterDecision) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LimiterDecision) MarshalToVT added in v2.7.0 

func (m *LimiterDecision) MarshalToVT(dAtA []byte) (int, error)

func (*LimiterDecision) MarshalVT added in v2.7.0 

func (m *LimiterDecision) MarshalVT() (dAtA []byte, err error)

func (*LimiterDecision) ProtoMessage 

func (*LimiterDecision) ProtoMessage()

func (*LimiterDecision) ProtoReflect 

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

func (*LimiterDecision) Reset 

func (x *LimiterDecision) Reset()

func (*LimiterDecision) SizeVT added in v2.7.0 

func (m *LimiterDecision) SizeVT() (n int)

func (*LimiterDecision) String 

func (x *LimiterDecision) String() string

func (*LimiterDecision) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision) UnmarshalVT added in v2.7.0 

func (m *LimiterDecision) UnmarshalVT(dAtA []byte) error

func (*LimiterDecision) Validate 

func (m *LimiterDecision) Validate() error

Validate checks the field values on LimiterDecision with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LimiterDecision) ValidateAll 

func (m *LimiterDecision) ValidateAll() error

ValidateAll checks the field values on LimiterDecision with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LimiterDecisionMultiError, or nil if none found.

type LimiterDecisionMultiError 

type LimiterDecisionMultiError []error

LimiterDecisionMultiError is an error wrapping multiple validation errors returned by LimiterDecision.ValidateAll() if the designated constraints aren't met.

func (LimiterDecisionMultiError) AllErrors 

func (m LimiterDecisionMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecisionMultiError) Error 

func (m LimiterDecisionMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LimiterDecisionValidationError 

type LimiterDecisionValidationError struct {
	// contains filtered or unexported fields
}

LimiterDecisionValidationError is the validation error returned by LimiterDecision.Validate if the designated constraints aren't met.

func (LimiterDecisionValidationError) Cause 

func (e LimiterDecisionValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecisionValidationError) Error 

func (e LimiterDecisionValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecisionValidationError) ErrorName 

func (e LimiterDecisionValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecisionValidationError) Field 

func (e LimiterDecisionValidationError) Field() string

Field function returns field value.

func (LimiterDecisionValidationError) Key 

func (e LimiterDecisionValidationError) Key() bool

Key function returns key value.

func (LimiterDecisionValidationError) Reason 

func (e LimiterDecisionValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision_LimiterReason 

type LimiterDecision_LimiterReason int32
const (
	LimiterDecision_LIMITER_REASON_UNSPECIFIED   LimiterDecision_LimiterReason = 0
	LimiterDecision_LIMITER_REASON_KEY_NOT_FOUND LimiterDecision_LimiterReason = 1
)

func (LimiterDecision_LimiterReason) Descriptor 

func (LimiterDecision_LimiterReason) Descriptor() protoreflect.EnumDescriptor

func (LimiterDecision_LimiterReason) Enum 

func (x LimiterDecision_LimiterReason) Enum() *LimiterDecision_LimiterReason

func (LimiterDecision_LimiterReason) EnumDescriptor deprecated 

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

Deprecated: Use LimiterDecision_LimiterReason.Descriptor instead.

func (LimiterDecision_LimiterReason) Number 

func (x LimiterDecision_LimiterReason) Number() protoreflect.EnumNumber

func (LimiterDecision_LimiterReason) String 

func (x LimiterDecision_LimiterReason) String() string

func (LimiterDecision_LimiterReason) Type 

func (LimiterDecision_LimiterReason) Type() protoreflect.EnumType

type LimiterDecision_LoadSchedulerInfo 

type LimiterDecision_LoadSchedulerInfo struct {
	LoadSchedulerInfo *LimiterDecision_SchedulerInfo `protobuf:"bytes,7,opt,name=load_scheduler_info,json=loadSchedulerInfo,proto3,oneof"`
}

func (*LimiterDecision_LoadSchedulerInfo) MarshalToSizedBufferVT added in v2.7.0 

func (m *LimiterDecision_LoadSchedulerInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LimiterDecision_LoadSchedulerInfo) MarshalToVT added in v2.7.0 

func (m *LimiterDecision_LoadSchedulerInfo) MarshalToVT(dAtA []byte) (int, error)

func (*LimiterDecision_LoadSchedulerInfo) SizeVT added in v2.7.0 

func (m *LimiterDecision_LoadSchedulerInfo) SizeVT() (n int)

type LimiterDecision_QuotaSchedulerInfo added in v2.2.0 

type LimiterDecision_QuotaSchedulerInfo struct {
	Label         string                         `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	SchedulerInfo *LimiterDecision_SchedulerInfo `protobuf:"bytes,2,opt,name=scheduler_info,json=schedulerInfo,proto3" json:"scheduler_info,omitempty"`
	// contains filtered or unexported fields
}

func (*LimiterDecision_QuotaSchedulerInfo) Descriptor deprecated added in v2.2.0 

func (*LimiterDecision_QuotaSchedulerInfo) Descriptor() ([]byte, []int)

Deprecated: Use LimiterDecision_QuotaSchedulerInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_QuotaSchedulerInfo) GetLabel added in v2.2.0 

func (x *LimiterDecision_QuotaSchedulerInfo) GetLabel() string

func (*LimiterDecision_QuotaSchedulerInfo) GetSchedulerInfo added in v2.2.0 

func (x *LimiterDecision_QuotaSchedulerInfo) GetSchedulerInfo() *LimiterDecision_SchedulerInfo

func (*LimiterDecision_QuotaSchedulerInfo) MarshalJSON added in v2.2.0 

func (msg *LimiterDecision_QuotaSchedulerInfo) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*LimiterDecision_QuotaSchedulerInfo) MarshalToSizedBufferVT added in v2.7.0 

func (m *LimiterDecision_QuotaSchedulerInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LimiterDecision_QuotaSchedulerInfo) MarshalToVT added in v2.7.0 

func (m *LimiterDecision_QuotaSchedulerInfo) MarshalToVT(dAtA []byte) (int, error)

func (*LimiterDecision_QuotaSchedulerInfo) MarshalVT added in v2.7.0 

func (m *LimiterDecision_QuotaSchedulerInfo) MarshalVT() (dAtA []byte, err error)

func (*LimiterDecision_QuotaSchedulerInfo) ProtoMessage added in v2.2.0 

func (*LimiterDecision_QuotaSchedulerInfo) ProtoMessage()

func (*LimiterDecision_QuotaSchedulerInfo) ProtoReflect added in v2.2.0 

func (x *LimiterDecision_QuotaSchedulerInfo) ProtoReflect() protoreflect.Message

func (*LimiterDecision_QuotaSchedulerInfo) Reset added in v2.2.0 

func (x *LimiterDecision_QuotaSchedulerInfo) Reset()

func (*LimiterDecision_QuotaSchedulerInfo) SizeVT added in v2.7.0 

func (m *LimiterDecision_QuotaSchedulerInfo) SizeVT() (n int)

func (*LimiterDecision_QuotaSchedulerInfo) String added in v2.2.0 

func (x *LimiterDecision_QuotaSchedulerInfo) String() string

func (*LimiterDecision_QuotaSchedulerInfo) UnmarshalJSON added in v2.2.0 

func (msg *LimiterDecision_QuotaSchedulerInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_QuotaSchedulerInfo) UnmarshalVT added in v2.7.0 

func (m *LimiterDecision_QuotaSchedulerInfo) UnmarshalVT(dAtA []byte) error

func (*LimiterDecision_QuotaSchedulerInfo) Validate added in v2.2.0 

func (m *LimiterDecision_QuotaSchedulerInfo) Validate() error

Validate checks the field values on LimiterDecision_QuotaSchedulerInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LimiterDecision_QuotaSchedulerInfo) ValidateAll added in v2.2.0 

func (m *LimiterDecision_QuotaSchedulerInfo) ValidateAll() error

ValidateAll checks the field values on LimiterDecision_QuotaSchedulerInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LimiterDecision_QuotaSchedulerInfoMultiError, or nil if none found.

type LimiterDecision_QuotaSchedulerInfoMultiError added in v2.2.0 

type LimiterDecision_QuotaSchedulerInfoMultiError []error

LimiterDecision_QuotaSchedulerInfoMultiError is an error wrapping multiple validation errors returned by LimiterDecision_QuotaSchedulerInfo.ValidateAll() if the designated constraints aren't met.

func (LimiterDecision_QuotaSchedulerInfoMultiError) AllErrors added in v2.2.0 

func (m LimiterDecision_QuotaSchedulerInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_QuotaSchedulerInfoMultiError) Error added in v2.2.0 

func (m LimiterDecision_QuotaSchedulerInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LimiterDecision_QuotaSchedulerInfoValidationError added in v2.2.0 

type LimiterDecision_QuotaSchedulerInfoValidationError struct {
	// contains filtered or unexported fields
}

LimiterDecision_QuotaSchedulerInfoValidationError is the validation error returned by LimiterDecision_QuotaSchedulerInfo.Validate if the designated constraints aren't met.

func (LimiterDecision_QuotaSchedulerInfoValidationError) Cause added in v2.2.0 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_QuotaSchedulerInfoValidationError) Error added in v2.2.0 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_QuotaSchedulerInfoValidationError) ErrorName added in v2.2.0 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_QuotaSchedulerInfoValidationError) Field added in v2.2.0 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_QuotaSchedulerInfoValidationError) Key added in v2.2.0 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_QuotaSchedulerInfoValidationError) Reason added in v2.2.0 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision_QuotaSchedulerInfo_ added in v2.2.0 

type LimiterDecision_QuotaSchedulerInfo_ struct {
	QuotaSchedulerInfo *LimiterDecision_QuotaSchedulerInfo `protobuf:"bytes,9,opt,name=quota_scheduler_info,json=quotaSchedulerInfo,proto3,oneof"`
}

func (*LimiterDecision_QuotaSchedulerInfo_) MarshalToSizedBufferVT added in v2.7.0 

func (m *LimiterDecision_QuotaSchedulerInfo_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LimiterDecision_QuotaSchedulerInfo_) MarshalToVT added in v2.7.0 

func (m *LimiterDecision_QuotaSchedulerInfo_) MarshalToVT(dAtA []byte) (int, error)

func (*LimiterDecision_QuotaSchedulerInfo_) SizeVT added in v2.7.0 

func (m *LimiterDecision_QuotaSchedulerInfo_) SizeVT() (n int)

type LimiterDecision_RateLimiterInfo 

type LimiterDecision_RateLimiterInfo struct {
	Remaining      float64 `protobuf:"fixed64,1,opt,name=remaining,proto3" json:"remaining,omitempty"`
	Current        float64 `protobuf:"fixed64,2,opt,name=current,proto3" json:"current,omitempty"`
	Label          string  `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	TokensConsumed float64 `protobuf:"fixed64,4,opt,name=tokens_consumed,json=tokensConsumed,proto3" json:"tokens_consumed,omitempty"`
	// contains filtered or unexported fields
}

func (*LimiterDecision_RateLimiterInfo) Descriptor deprecated 

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

Deprecated: Use LimiterDecision_RateLimiterInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_RateLimiterInfo) GetCurrent 

func (x *LimiterDecision_RateLimiterInfo) GetCurrent() float64

func (*LimiterDecision_RateLimiterInfo) GetLabel 

func (x *LimiterDecision_RateLimiterInfo) GetLabel() string

func (*LimiterDecision_RateLimiterInfo) GetRemaining 

func (x *LimiterDecision_RateLimiterInfo) GetRemaining() float64

func (*LimiterDecision_RateLimiterInfo) GetTokensConsumed 

func (x *LimiterDecision_RateLimiterInfo) GetTokensConsumed() float64

func (*LimiterDecision_RateLimiterInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_RateLimiterInfo) MarshalToSizedBufferVT added in v2.7.0 

func (m *LimiterDecision_RateLimiterInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LimiterDecision_RateLimiterInfo) MarshalToVT added in v2.7.0 

func (m *LimiterDecision_RateLimiterInfo) MarshalToVT(dAtA []byte) (int, error)

func (*LimiterDecision_RateLimiterInfo) MarshalVT added in v2.7.0 

func (m *LimiterDecision_RateLimiterInfo) MarshalVT() (dAtA []byte, err error)

func (*LimiterDecision_RateLimiterInfo) ProtoMessage 

func (*LimiterDecision_RateLimiterInfo) ProtoMessage()

func (*LimiterDecision_RateLimiterInfo) ProtoReflect 

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

func (*LimiterDecision_RateLimiterInfo) Reset 

func (x *LimiterDecision_RateLimiterInfo) Reset()

func (*LimiterDecision_RateLimiterInfo) SizeVT added in v2.7.0 

func (m *LimiterDecision_RateLimiterInfo) SizeVT() (n int)

func (*LimiterDecision_RateLimiterInfo) String 

func (x *LimiterDecision_RateLimiterInfo) String() string

func (*LimiterDecision_RateLimiterInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_RateLimiterInfo) UnmarshalVT added in v2.7.0 

func (m *LimiterDecision_RateLimiterInfo) UnmarshalVT(dAtA []byte) error

func (*LimiterDecision_RateLimiterInfo) Validate 

func (m *LimiterDecision_RateLimiterInfo) Validate() error

Validate checks the field values on LimiterDecision_RateLimiterInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LimiterDecision_RateLimiterInfo) ValidateAll 

func (m *LimiterDecision_RateLimiterInfo) ValidateAll() error

ValidateAll checks the field values on LimiterDecision_RateLimiterInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LimiterDecision_RateLimiterInfoMultiError, or nil if none found.

type LimiterDecision_RateLimiterInfoMultiError 

type LimiterDecision_RateLimiterInfoMultiError []error

LimiterDecision_RateLimiterInfoMultiError is an error wrapping multiple validation errors returned by LimiterDecision_RateLimiterInfo.ValidateAll() if the designated constraints aren't met.

func (LimiterDecision_RateLimiterInfoMultiError) AllErrors 

func (m LimiterDecision_RateLimiterInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_RateLimiterInfoMultiError) Error 

func (m LimiterDecision_RateLimiterInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LimiterDecision_RateLimiterInfoValidationError 

type LimiterDecision_RateLimiterInfoValidationError struct {
	// contains filtered or unexported fields
}

LimiterDecision_RateLimiterInfoValidationError is the validation error returned by LimiterDecision_RateLimiterInfo.Validate if the designated constraints aren't met.

func (LimiterDecision_RateLimiterInfoValidationError) Cause 

func (e LimiterDecision_RateLimiterInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_RateLimiterInfoValidationError) Error 

func (e LimiterDecision_RateLimiterInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_RateLimiterInfoValidationError) ErrorName 

func (e LimiterDecision_RateLimiterInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_RateLimiterInfoValidationError) Field 

func (e LimiterDecision_RateLimiterInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_RateLimiterInfoValidationError) Key 

func (e LimiterDecision_RateLimiterInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_RateLimiterInfoValidationError) Reason 

func (e LimiterDecision_RateLimiterInfoValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision_RateLimiterInfo_ 

type LimiterDecision_RateLimiterInfo_ struct {
	RateLimiterInfo *LimiterDecision_RateLimiterInfo `protobuf:"bytes,6,opt,name=rate_limiter_info,json=rateLimiterInfo,proto3,oneof"`
}

func (*LimiterDecision_RateLimiterInfo_) MarshalToSizedBufferVT added in v2.7.0 

func (m *LimiterDecision_RateLimiterInfo_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LimiterDecision_RateLimiterInfo_) MarshalToVT added in v2.7.0 

func (m *LimiterDecision_RateLimiterInfo_) MarshalToVT(dAtA []byte) (int, error)

func (*LimiterDecision_RateLimiterInfo_) SizeVT added in v2.7.0 

func (m *LimiterDecision_RateLimiterInfo_) SizeVT() (n int)

type LimiterDecision_SamplerInfo added in v2.5.0 

type LimiterDecision_SamplerInfo struct {
	Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	// contains filtered or unexported fields
}

func (*LimiterDecision_SamplerInfo) Descriptor deprecated added in v2.5.0 

func (*LimiterDecision_SamplerInfo) Descriptor() ([]byte, []int)

Deprecated: Use LimiterDecision_SamplerInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_SamplerInfo) GetLabel added in v2.5.0 

func (x *LimiterDecision_SamplerInfo) GetLabel() string

func (*LimiterDecision_SamplerInfo) MarshalJSON added in v2.5.0 

func (msg *LimiterDecision_SamplerInfo) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*LimiterDecision_SamplerInfo) MarshalToSizedBufferVT added in v2.7.0 

func (m *LimiterDecision_SamplerInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LimiterDecision_SamplerInfo) MarshalToVT added in v2.7.0 

func (m *LimiterDecision_SamplerInfo) MarshalToVT(dAtA []byte) (int, error)

func (*LimiterDecision_SamplerInfo) MarshalVT added in v2.7.0 

func (m *LimiterDecision_SamplerInfo) MarshalVT() (dAtA []byte, err error)

func (*LimiterDecision_SamplerInfo) ProtoMessage added in v2.5.0 

func (*LimiterDecision_SamplerInfo) ProtoMessage()

func (*LimiterDecision_SamplerInfo) ProtoReflect added in v2.5.0 

func (x *LimiterDecision_SamplerInfo) ProtoReflect() protoreflect.Message

func (*LimiterDecision_SamplerInfo) Reset added in v2.5.0 

func (x *LimiterDecision_SamplerInfo) Reset()

func (*LimiterDecision_SamplerInfo) SizeVT added in v2.7.0 

func (m *LimiterDecision_SamplerInfo) SizeVT() (n int)

func (*LimiterDecision_SamplerInfo) String added in v2.5.0 

func (x *LimiterDecision_SamplerInfo) String() string

func (*LimiterDecision_SamplerInfo) UnmarshalJSON added in v2.5.0 

func (msg *LimiterDecision_SamplerInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_SamplerInfo) UnmarshalVT added in v2.7.0 

func (m *LimiterDecision_SamplerInfo) UnmarshalVT(dAtA []byte) error

func (*LimiterDecision_SamplerInfo) Validate added in v2.5.0 

func (m *LimiterDecision_SamplerInfo) Validate() error

Validate checks the field values on LimiterDecision_SamplerInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LimiterDecision_SamplerInfo) ValidateAll added in v2.5.0 

func (m *LimiterDecision_SamplerInfo) ValidateAll() error

ValidateAll checks the field values on LimiterDecision_SamplerInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LimiterDecision_SamplerInfoMultiError, or nil if none found.

type LimiterDecision_SamplerInfoMultiError added in v2.5.0 

type LimiterDecision_SamplerInfoMultiError []error

LimiterDecision_SamplerInfoMultiError is an error wrapping multiple validation errors returned by LimiterDecision_SamplerInfo.ValidateAll() if the designated constraints aren't met.

func (LimiterDecision_SamplerInfoMultiError) AllErrors added in v2.5.0 

func (m LimiterDecision_SamplerInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_SamplerInfoMultiError) Error added in v2.5.0 

func (m LimiterDecision_SamplerInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LimiterDecision_SamplerInfoValidationError added in v2.5.0 

type LimiterDecision_SamplerInfoValidationError struct {
	// contains filtered or unexported fields
}

LimiterDecision_SamplerInfoValidationError is the validation error returned by LimiterDecision_SamplerInfo.Validate if the designated constraints aren't met.

func (LimiterDecision_SamplerInfoValidationError) Cause added in v2.5.0 

func (e LimiterDecision_SamplerInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_SamplerInfoValidationError) Error added in v2.5.0 

func (e LimiterDecision_SamplerInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_SamplerInfoValidationError) ErrorName added in v2.5.0 

func (e LimiterDecision_SamplerInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_SamplerInfoValidationError) Field added in v2.5.0 

func (e LimiterDecision_SamplerInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_SamplerInfoValidationError) Key added in v2.5.0 

func (e LimiterDecision_SamplerInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_SamplerInfoValidationError) Reason added in v2.5.0 

func (e LimiterDecision_SamplerInfoValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision_SamplerInfo_ added in v2.5.0 

type LimiterDecision_SamplerInfo_ struct {
	SamplerInfo *LimiterDecision_SamplerInfo `protobuf:"bytes,8,opt,name=sampler_info,json=samplerInfo,proto3,oneof"`
}

func (*LimiterDecision_SamplerInfo_) MarshalToSizedBufferVT added in v2.7.0 

func (m *LimiterDecision_SamplerInfo_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LimiterDecision_SamplerInfo_) MarshalToVT added in v2.7.0 

func (m *LimiterDecision_SamplerInfo_) MarshalToVT(dAtA []byte) (int, error)

func (*LimiterDecision_SamplerInfo_) SizeVT added in v2.7.0 

func (m *LimiterDecision_SamplerInfo_) SizeVT() (n int)

type LimiterDecision_SchedulerInfo added in v2.2.0 

type LimiterDecision_SchedulerInfo struct {
	WorkloadIndex  string `protobuf:"bytes,1,opt,name=workload_index,json=workloadIndex,proto3" json:"workload_index,omitempty"`
	TokensConsumed uint64 `protobuf:"varint,2,opt,name=tokens_consumed,json=tokensConsumed,proto3" json:"tokens_consumed,omitempty"`
	// contains filtered or unexported fields
}

func LimiterDecision_SchedulerInfoFromVTPool added in v2.7.0 

func LimiterDecision_SchedulerInfoFromVTPool() *LimiterDecision_SchedulerInfo

func (*LimiterDecision_SchedulerInfo) Descriptor deprecated added in v2.2.0 

func (*LimiterDecision_SchedulerInfo) Descriptor() ([]byte, []int)

Deprecated: Use LimiterDecision_SchedulerInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_SchedulerInfo) GetTokensConsumed added in v2.2.0 

func (x *LimiterDecision_SchedulerInfo) GetTokensConsumed() uint64

func (*LimiterDecision_SchedulerInfo) GetWorkloadIndex added in v2.2.0 

func (x *LimiterDecision_SchedulerInfo) GetWorkloadIndex() string

func (*LimiterDecision_SchedulerInfo) MarshalJSON added in v2.2.0 

func (msg *LimiterDecision_SchedulerInfo) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*LimiterDecision_SchedulerInfo) MarshalToSizedBufferVT added in v2.7.0 

func (m *LimiterDecision_SchedulerInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LimiterDecision_SchedulerInfo) MarshalToVT added in v2.7.0 

func (m *LimiterDecision_SchedulerInfo) MarshalToVT(dAtA []byte) (int, error)

func (*LimiterDecision_SchedulerInfo) MarshalVT added in v2.7.0 

func (m *LimiterDecision_SchedulerInfo) MarshalVT() (dAtA []byte, err error)

func (*LimiterDecision_SchedulerInfo) ProtoMessage added in v2.2.0 

func (*LimiterDecision_SchedulerInfo) ProtoMessage()

func (*LimiterDecision_SchedulerInfo) ProtoReflect added in v2.2.0 

func (x *LimiterDecision_SchedulerInfo) ProtoReflect() protoreflect.Message

func (*LimiterDecision_SchedulerInfo) Reset added in v2.2.0 

func (x *LimiterDecision_SchedulerInfo) Reset()

func (*LimiterDecision_SchedulerInfo) ResetVT added in v2.7.0 

func (m *LimiterDecision_SchedulerInfo) ResetVT()

func (*LimiterDecision_SchedulerInfo) ReturnToVTPool added in v2.7.0 

func (m *LimiterDecision_SchedulerInfo) ReturnToVTPool()

func (*LimiterDecision_SchedulerInfo) SizeVT added in v2.7.0 

func (m *LimiterDecision_SchedulerInfo) SizeVT() (n int)

func (*LimiterDecision_SchedulerInfo) String added in v2.2.0 

func (x *LimiterDecision_SchedulerInfo) String() string

func (*LimiterDecision_SchedulerInfo) UnmarshalJSON added in v2.2.0 

func (msg *LimiterDecision_SchedulerInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_SchedulerInfo) UnmarshalVT added in v2.7.0 

func (m *LimiterDecision_SchedulerInfo) UnmarshalVT(dAtA []byte) error

func (*LimiterDecision_SchedulerInfo) Validate added in v2.2.0 

func (m *LimiterDecision_SchedulerInfo) Validate() error

Validate checks the field values on LimiterDecision_SchedulerInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LimiterDecision_SchedulerInfo) ValidateAll added in v2.2.0 

func (m *LimiterDecision_SchedulerInfo) ValidateAll() error

ValidateAll checks the field values on LimiterDecision_SchedulerInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LimiterDecision_SchedulerInfoMultiError, or nil if none found.

type LimiterDecision_SchedulerInfoMultiError added in v2.2.0 

type LimiterDecision_SchedulerInfoMultiError []error

LimiterDecision_SchedulerInfoMultiError is an error wrapping multiple validation errors returned by LimiterDecision_SchedulerInfo.ValidateAll() if the designated constraints aren't met.

func (LimiterDecision_SchedulerInfoMultiError) AllErrors added in v2.2.0 

func (m LimiterDecision_SchedulerInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_SchedulerInfoMultiError) Error added in v2.2.0 

func (m LimiterDecision_SchedulerInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LimiterDecision_SchedulerInfoValidationError added in v2.2.0 

type LimiterDecision_SchedulerInfoValidationError struct {
	// contains filtered or unexported fields
}

LimiterDecision_SchedulerInfoValidationError is the validation error returned by LimiterDecision_SchedulerInfo.Validate if the designated constraints aren't met.

func (LimiterDecision_SchedulerInfoValidationError) Cause added in v2.2.0 

func (e LimiterDecision_SchedulerInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_SchedulerInfoValidationError) Error added in v2.2.0 

func (e LimiterDecision_SchedulerInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_SchedulerInfoValidationError) ErrorName added in v2.2.0 

func (e LimiterDecision_SchedulerInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_SchedulerInfoValidationError) Field added in v2.2.0 

func (e LimiterDecision_SchedulerInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_SchedulerInfoValidationError) Key added in v2.2.0 

func (e LimiterDecision_SchedulerInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_SchedulerInfoValidationError) Reason added in v2.2.0 

func (e LimiterDecision_SchedulerInfoValidationError) Reason() string

Reason function returns reason value.

type UnimplementedFlowControlServiceServer 

type UnimplementedFlowControlServiceServer struct {
}

UnimplementedFlowControlServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedFlowControlServiceServer) Check 

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

type UnsafeFlowControlServiceServer 

type UnsafeFlowControlServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeFlowControlServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FlowControlServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.