checkv1

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Mar 27, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-deepcopy. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

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

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 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) DeepCopy

func (in *CheckRequest) DeepCopy() *CheckRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CheckRequest. Required by controller-gen.

func (*CheckRequest) DeepCopyInterface

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

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new CheckRequest. Required by controller-gen.

func (*CheckRequest) DeepCopyInto

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

DeepCopyInto supports using CheckRequest within kubernetes types, where deepcopy-gen is used.

func (*CheckRequest) Descriptor deprecated

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

Deprecated: Use CheckRequest.ProtoReflect.Descriptor instead.

func (*CheckRequest) GetControlPoint added in v0.11.0

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) ProtoMessage

func (*CheckRequest) ProtoMessage()

func (*CheckRequest) ProtoReflect

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

func (*CheckRequest) Reset

func (x *CheckRequest) Reset()

func (*CheckRequest) String

func (x *CheckRequest) String() string

func (*CheckRequest) UnmarshalJSON

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

UnmarshalJSON implements json.Unmarshaler

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"`
	// contains filtered or unexported fields
}

CheckResponse contains fields that represent decision made by Check call.

func (*CheckResponse) DeepCopy

func (in *CheckResponse) DeepCopy() *CheckResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CheckResponse. Required by controller-gen.

func (*CheckResponse) DeepCopyInterface

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

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new CheckResponse. Required by controller-gen.

func (*CheckResponse) DeepCopyInto

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

DeepCopyInto supports using CheckResponse within kubernetes types, where deepcopy-gen is used.

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 added in v0.11.0

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) MarshalJSON

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

MarshalJSON implements json.Marshaler

func (*CheckResponse) ProtoMessage

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) ProtoReflect

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

func (*CheckResponse) Reset

func (x *CheckResponse) Reset()

func (*CheckResponse) String

func (x *CheckResponse) String() string

func (*CheckResponse) UnmarshalJSON

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

UnmarshalJSON implements json.Unmarshaler

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) Enum

func (CheckResponse_DecisionType) EnumDescriptor deprecated

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

Deprecated: Use CheckResponse_DecisionType.Descriptor instead.

func (CheckResponse_DecisionType) Number

func (CheckResponse_DecisionType) String

func (CheckResponse_DecisionType) Type

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_CONCURRENCY_LIMITED CheckResponse_RejectReason = 2
)

func (CheckResponse_RejectReason) Descriptor

func (CheckResponse_RejectReason) Enum

func (CheckResponse_RejectReason) EnumDescriptor deprecated

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

Deprecated: Use CheckResponse_RejectReason.Descriptor instead.

func (CheckResponse_RejectReason) Number

func (CheckResponse_RejectReason) String

func (CheckResponse_RejectReason) Type

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"`
	LabelKey        string               `protobuf:"bytes,4,opt,name=label_key,json=labelKey,proto3" json:"label_key,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) DeepCopy

func (in *ClassifierInfo) DeepCopy() *ClassifierInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClassifierInfo. Required by controller-gen.

func (*ClassifierInfo) DeepCopyInterface

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

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ClassifierInfo. Required by controller-gen.

func (*ClassifierInfo) DeepCopyInto

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

DeepCopyInto supports using ClassifierInfo within kubernetes types, where deepcopy-gen is used.

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) GetLabelKey

func (x *ClassifierInfo) GetLabelKey() string

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) ProtoMessage

func (*ClassifierInfo) ProtoMessage()

func (*ClassifierInfo) ProtoReflect

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

func (*ClassifierInfo) Reset

func (x *ClassifierInfo) Reset()

func (*ClassifierInfo) String

func (x *ClassifierInfo) String() string

func (*ClassifierInfo) UnmarshalJSON

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

UnmarshalJSON implements json.Unmarshaler

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) Enum

func (ClassifierInfo_Error) EnumDescriptor deprecated

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

Deprecated: Use ClassifierInfo_Error.Descriptor instead.

func (ClassifierInfo_Error) Number

func (ClassifierInfo_Error) String

func (x ClassifierInfo_Error) String() string

func (ClassifierInfo_Error) Type

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.

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) DeepCopy

func (in *FluxMeterInfo) DeepCopy() *FluxMeterInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FluxMeterInfo. Required by controller-gen.

func (*FluxMeterInfo) DeepCopyInterface

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

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new FluxMeterInfo. Required by controller-gen.

func (*FluxMeterInfo) DeepCopyInto

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

DeepCopyInto supports using FluxMeterInfo within kubernetes types, where deepcopy-gen is used.

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) ProtoMessage

func (*FluxMeterInfo) ProtoMessage()

func (*FluxMeterInfo) ProtoReflect

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

func (*FluxMeterInfo) Reset

func (x *FluxMeterInfo) Reset()

func (*FluxMeterInfo) String

func (x *FluxMeterInfo) String() string

func (*FluxMeterInfo) UnmarshalJSON

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

UnmarshalJSON implements json.Unmarshaler

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_ConcurrencyLimiterInfo_
	Details isLimiterDecision_Details `protobuf_oneof:"details"`
	// contains filtered or unexported fields
}

LimiterDecision describes details for each limiter.

func (*LimiterDecision) DeepCopy

func (in *LimiterDecision) DeepCopy() *LimiterDecision

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LimiterDecision. Required by controller-gen.

func (*LimiterDecision) DeepCopyInterface

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

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new LimiterDecision. Required by controller-gen.

func (*LimiterDecision) DeepCopyInto

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

DeepCopyInto supports using LimiterDecision within kubernetes types, where deepcopy-gen is used.

func (*LimiterDecision) Descriptor deprecated

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

Deprecated: Use LimiterDecision.ProtoReflect.Descriptor instead.

func (*LimiterDecision) GetComponentId added in v0.21.0

func (x *LimiterDecision) GetComponentId() string

func (*LimiterDecision) GetConcurrencyLimiterInfo

func (x *LimiterDecision) GetConcurrencyLimiterInfo() *LimiterDecision_ConcurrencyLimiterInfo

func (*LimiterDecision) GetDetails

func (m *LimiterDecision) GetDetails() isLimiterDecision_Details

func (*LimiterDecision) GetDropped

func (x *LimiterDecision) GetDropped() bool

func (*LimiterDecision) GetPolicyHash

func (x *LimiterDecision) GetPolicyHash() string

func (*LimiterDecision) GetPolicyName

func (x *LimiterDecision) GetPolicyName() string

func (*LimiterDecision) GetRateLimiterInfo

func (x *LimiterDecision) GetRateLimiterInfo() *LimiterDecision_RateLimiterInfo

func (*LimiterDecision) GetReason

func (*LimiterDecision) MarshalJSON

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision) ProtoMessage

func (*LimiterDecision) ProtoMessage()

func (*LimiterDecision) ProtoReflect

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

func (*LimiterDecision) Reset

func (x *LimiterDecision) Reset()

func (*LimiterDecision) String

func (x *LimiterDecision) String() string

func (*LimiterDecision) UnmarshalJSON

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

UnmarshalJSON implements json.Unmarshaler

type LimiterDecision_ConcurrencyLimiterInfo

type LimiterDecision_ConcurrencyLimiterInfo struct {
	WorkloadIndex string `protobuf:"bytes,1,opt,name=workload_index,json=workloadIndex,proto3" json:"workload_index,omitempty"`
	// contains filtered or unexported fields
}

func (*LimiterDecision_ConcurrencyLimiterInfo) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LimiterDecision_ConcurrencyLimiterInfo. Required by controller-gen.

func (*LimiterDecision_ConcurrencyLimiterInfo) DeepCopyInterface

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

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new LimiterDecision_ConcurrencyLimiterInfo. Required by controller-gen.

func (*LimiterDecision_ConcurrencyLimiterInfo) DeepCopyInto

DeepCopyInto supports using LimiterDecision_ConcurrencyLimiterInfo within kubernetes types, where deepcopy-gen is used.

func (*LimiterDecision_ConcurrencyLimiterInfo) Descriptor deprecated

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

Deprecated: Use LimiterDecision_ConcurrencyLimiterInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_ConcurrencyLimiterInfo) GetWorkloadIndex

func (x *LimiterDecision_ConcurrencyLimiterInfo) GetWorkloadIndex() string

func (*LimiterDecision_ConcurrencyLimiterInfo) MarshalJSON

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoMessage

func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoReflect

func (*LimiterDecision_ConcurrencyLimiterInfo) Reset

func (*LimiterDecision_ConcurrencyLimiterInfo) String

func (*LimiterDecision_ConcurrencyLimiterInfo) UnmarshalJSON

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

UnmarshalJSON implements json.Unmarshaler

type LimiterDecision_ConcurrencyLimiterInfo_

type LimiterDecision_ConcurrencyLimiterInfo_ struct {
	ConcurrencyLimiterInfo *LimiterDecision_ConcurrencyLimiterInfo `protobuf:"bytes,7,opt,name=concurrency_limiter_info,json=concurrencyLimiterInfo,proto3,oneof"`
}

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) Enum

func (LimiterDecision_LimiterReason) EnumDescriptor deprecated

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

Deprecated: Use LimiterDecision_LimiterReason.Descriptor instead.

func (LimiterDecision_LimiterReason) Number

func (LimiterDecision_LimiterReason) String

func (LimiterDecision_LimiterReason) Type

type LimiterDecision_RateLimiterInfo

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

func (*LimiterDecision_RateLimiterInfo) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LimiterDecision_RateLimiterInfo. Required by controller-gen.

func (*LimiterDecision_RateLimiterInfo) DeepCopyInterface

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

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new LimiterDecision_RateLimiterInfo. Required by controller-gen.

func (*LimiterDecision_RateLimiterInfo) DeepCopyInto

DeepCopyInto supports using LimiterDecision_RateLimiterInfo within kubernetes types, where deepcopy-gen is used.

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() int64

func (*LimiterDecision_RateLimiterInfo) GetLabel

func (*LimiterDecision_RateLimiterInfo) GetRemaining

func (x *LimiterDecision_RateLimiterInfo) GetRemaining() int64

func (*LimiterDecision_RateLimiterInfo) MarshalJSON

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_RateLimiterInfo) ProtoMessage

func (*LimiterDecision_RateLimiterInfo) ProtoMessage()

func (*LimiterDecision_RateLimiterInfo) ProtoReflect

func (*LimiterDecision_RateLimiterInfo) Reset

func (*LimiterDecision_RateLimiterInfo) String

func (*LimiterDecision_RateLimiterInfo) UnmarshalJSON

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

UnmarshalJSON implements json.Unmarshaler

type LimiterDecision_RateLimiterInfo_

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

type UnimplementedFlowControlServiceServer

type UnimplementedFlowControlServiceServer struct {
}

UnimplementedFlowControlServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedFlowControlServiceServer) Check

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL