flowcontrolv1

package
v0.3.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2022 License: AGPL-3.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_Error_name = map[int32]string{
		0: "ERROR_NONE",
		1: "ERROR_MISSING_TRAFFIC_DIRECTION",
		2: "ERROR_INVALID_TRAFFIC_DIRECTION",
		3: "ERROR_CONVERT_TO_MAP_STRUCT",
		4: "ERROR_CONVERT_TO_REGO_AST",
		5: "ERROR_CLASSIFY",
	}
	CheckResponse_Error_value = map[string]int32{
		"ERROR_NONE":                      0,
		"ERROR_MISSING_TRAFFIC_DIRECTION": 1,
		"ERROR_INVALID_TRAFFIC_DIRECTION": 2,
		"ERROR_CONVERT_TO_MAP_STRUCT":     3,
		"ERROR_CONVERT_TO_REGO_AST":       4,
		"ERROR_CLASSIFY":                  5,
	}
)

Enum value maps for CheckResponse_Error.

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 (
	ControlPointInfo_Type_name = map[int32]string{
		0: "TYPE_UNKNOWN",
		1: "TYPE_FEATURE",
		2: "TYPE_INGRESS",
		3: "TYPE_EGRESS",
	}
	ControlPointInfo_Type_value = map[string]int32{
		"TYPE_UNKNOWN": 0,
		"TYPE_FEATURE": 1,
		"TYPE_INGRESS": 2,
		"TYPE_EGRESS":  3,
	}
)

Enum value maps for ControlPointInfo_Type.

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_v1_flowcontrol_proto protoreflect.FileDescriptor
View Source 
var FlowControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "aperture.flowcontrol.v1.FlowControlService",
	HandlerType: (*FlowControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Check",
			Handler:    _FlowControlService_Check_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "aperture/flowcontrol/v1/flowcontrol.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 {
	Feature string            `protobuf:"bytes,1,opt,name=feature,proto3" json:"feature,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 added in v0.1.2 

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

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

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

func (x *CheckRequest) GetFeature() 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"`
	// error information.
	Error CheckResponse_Error `protobuf:"varint,3,opt,name=error,proto3,enum=aperture.flowcontrol.v1.CheckResponse_Error" json:"error,omitempty"`
	// services that matched
	Services []string `protobuf:"bytes,4,rep,name=services,proto3" json:"services,omitempty"`
	// control_point of request
	ControlPointInfo *ControlPointInfo `protobuf:"bytes,5,opt,name=control_point_info,json=controlPointInfo,proto3" json:"control_point_info,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 `` /* 154-byte string literal not displayed */
	// reject_reason contains the reason for the rejection.
	RejectReason CheckResponse_RejectReason `` /* 154-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 added in v0.1.2 

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

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

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

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

func (*CheckResponse) GetControlPointInfo added in v0.3.0 

func (x *CheckResponse) GetControlPointInfo() *ControlPointInfo

func (*CheckResponse) GetDecisionType 

func (x *CheckResponse) GetDecisionType() CheckResponse_DecisionType

func (*CheckResponse) GetEnd added in v0.2.1 

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

func (*CheckResponse) GetError added in v0.2.1 

func (x *CheckResponse) GetError() CheckResponse_Error

func (*CheckResponse) GetFlowLabelKeys 

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

func (*CheckResponse) GetFluxMeterInfos added in v0.3.0 

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

func (*CheckResponse) GetLimiterDecisions 

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

func (*CheckResponse) GetRejectReason added in v0.2.1 

func (x *CheckResponse) GetRejectReason() CheckResponse_RejectReason

func (*CheckResponse) GetServices added in v0.2.1 

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

func (*CheckResponse) GetStart added in v0.2.1 

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

func (*CheckResponse) GetTelemetryFlowLabels added in v0.2.1 

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

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

func (CheckResponse_DecisionType) Descriptor() protoreflect.EnumDescriptor

func (CheckResponse_DecisionType) Enum added in v0.2.1 

func (x CheckResponse_DecisionType) Enum() *CheckResponse_DecisionType

func (CheckResponse_DecisionType) EnumDescriptor deprecated added in v0.2.1 

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

Deprecated: Use CheckResponse_DecisionType.Descriptor instead.

func (CheckResponse_DecisionType) Number added in v0.2.1 

func (x CheckResponse_DecisionType) Number() protoreflect.EnumNumber

func (CheckResponse_DecisionType) String added in v0.2.1 

func (x CheckResponse_DecisionType) String() string

func (CheckResponse_DecisionType) Type added in v0.2.1 

func (CheckResponse_DecisionType) Type() protoreflect.EnumType

type CheckResponse_Error added in v0.2.1 

type CheckResponse_Error int32

Error information. 

const (
	CheckResponse_ERROR_NONE                      CheckResponse_Error = 0
	CheckResponse_ERROR_MISSING_TRAFFIC_DIRECTION CheckResponse_Error = 1
	CheckResponse_ERROR_INVALID_TRAFFIC_DIRECTION CheckResponse_Error = 2
	CheckResponse_ERROR_CONVERT_TO_MAP_STRUCT     CheckResponse_Error = 3
	CheckResponse_ERROR_CONVERT_TO_REGO_AST       CheckResponse_Error = 4
	CheckResponse_ERROR_CLASSIFY                  CheckResponse_Error = 5
)

func (CheckResponse_Error) Descriptor added in v0.2.1 

func (CheckResponse_Error) Descriptor() protoreflect.EnumDescriptor

func (CheckResponse_Error) Enum added in v0.2.1 

func (x CheckResponse_Error) Enum() *CheckResponse_Error

func (CheckResponse_Error) EnumDescriptor deprecated added in v0.2.1 

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

Deprecated: Use CheckResponse_Error.Descriptor instead.

func (CheckResponse_Error) Number added in v0.2.1 

func (x CheckResponse_Error) Number() protoreflect.EnumNumber

func (CheckResponse_Error) String added in v0.2.1 

func (x CheckResponse_Error) String() string

func (CheckResponse_Error) Type added in v0.2.1 

func (CheckResponse_Error) Type() protoreflect.EnumType

type CheckResponse_RejectReason added in v0.2.1 

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

func (CheckResponse_RejectReason) Descriptor() protoreflect.EnumDescriptor

func (CheckResponse_RejectReason) Enum added in v0.2.1 

func (x CheckResponse_RejectReason) Enum() *CheckResponse_RejectReason

func (CheckResponse_RejectReason) EnumDescriptor deprecated added in v0.2.1 

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

Deprecated: Use CheckResponse_RejectReason.Descriptor instead.

func (CheckResponse_RejectReason) Number added in v0.2.1 

func (x CheckResponse_RejectReason) Number() protoreflect.EnumNumber

func (CheckResponse_RejectReason) String added in v0.2.1 

func (x CheckResponse_RejectReason) String() string

func (CheckResponse_RejectReason) Type added in v0.2.1 

func (CheckResponse_RejectReason) Type() protoreflect.EnumType

type ClassifierInfo added in v0.3.0 

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.v1.ClassifierInfo_Error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ClassifierInfo describes details for each ClassifierInfo.

func (*ClassifierInfo) DeepCopy added in v0.3.0 

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

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

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

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

func (*ClassifierInfo) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ClassifierInfo.ProtoReflect.Descriptor instead.

func (*ClassifierInfo) GetClassifierIndex added in v0.3.0 

func (x *ClassifierInfo) GetClassifierIndex() int64

func (*ClassifierInfo) GetError added in v0.3.0 

func (x *ClassifierInfo) GetError() ClassifierInfo_Error

func (*ClassifierInfo) GetLabelKey added in v0.3.0 

func (x *ClassifierInfo) GetLabelKey() string

func (*ClassifierInfo) GetPolicyHash added in v0.3.0 

func (x *ClassifierInfo) GetPolicyHash() string

func (*ClassifierInfo) GetPolicyName added in v0.3.0 

func (x *ClassifierInfo) GetPolicyName() string

func (*ClassifierInfo) MarshalJSON added in v0.3.0 

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

MarshalJSON implements json.Marshaler

func (*ClassifierInfo) ProtoMessage added in v0.3.0 

func (*ClassifierInfo) ProtoMessage()

func (*ClassifierInfo) ProtoReflect added in v0.3.0 

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

func (*ClassifierInfo) Reset added in v0.3.0 

func (x *ClassifierInfo) Reset()

func (*ClassifierInfo) String added in v0.3.0 

func (x *ClassifierInfo) String() string

func (*ClassifierInfo) UnmarshalJSON added in v0.3.0 

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

UnmarshalJSON implements json.Unmarshaler

type ClassifierInfo_Error added in v0.3.0 

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

func (ClassifierInfo_Error) Descriptor() protoreflect.EnumDescriptor

func (ClassifierInfo_Error) Enum added in v0.3.0 

func (x ClassifierInfo_Error) Enum() *ClassifierInfo_Error

func (ClassifierInfo_Error) EnumDescriptor deprecated added in v0.3.0 

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

Deprecated: Use ClassifierInfo_Error.Descriptor instead.

func (ClassifierInfo_Error) Number added in v0.3.0 

func (x ClassifierInfo_Error) Number() protoreflect.EnumNumber

func (ClassifierInfo_Error) String added in v0.3.0 

func (x ClassifierInfo_Error) String() string

func (ClassifierInfo_Error) Type added in v0.3.0 

func (ClassifierInfo_Error) Type() protoreflect.EnumType

type ControlPointInfo added in v0.3.0 

type ControlPointInfo struct {
	Type    ControlPointInfo_Type `protobuf:"varint,1,opt,name=type,proto3,enum=aperture.flowcontrol.v1.ControlPointInfo_Type" json:"type,omitempty"`
	Feature string                `protobuf:"bytes,2,opt,name=feature,proto3" json:"feature,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlPointInfo) DeepCopy added in v0.3.0 

func (in *ControlPointInfo) DeepCopy() *ControlPointInfo

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

func (*ControlPointInfo) DeepCopyInterface added in v0.3.0 

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

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

func (*ControlPointInfo) DeepCopyInto added in v0.3.0 

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

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

func (*ControlPointInfo) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ControlPointInfo.ProtoReflect.Descriptor instead.

func (*ControlPointInfo) GetFeature added in v0.3.0 

func (x *ControlPointInfo) GetFeature() string

func (*ControlPointInfo) GetType added in v0.3.0 

func (x *ControlPointInfo) GetType() ControlPointInfo_Type

func (*ControlPointInfo) MarshalJSON added in v0.3.0 

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

MarshalJSON implements json.Marshaler

func (*ControlPointInfo) ProtoMessage added in v0.3.0 

func (*ControlPointInfo) ProtoMessage()

func (*ControlPointInfo) ProtoReflect added in v0.3.0 

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

func (*ControlPointInfo) Reset added in v0.3.0 

func (x *ControlPointInfo) Reset()

func (*ControlPointInfo) String added in v0.3.0 

func (x *ControlPointInfo) String() string

func (*ControlPointInfo) UnmarshalJSON added in v0.3.0 

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

UnmarshalJSON implements json.Unmarshaler

type ControlPointInfo_Type added in v0.3.0 

type ControlPointInfo_Type int32

Type contains fields that represent type of ControlPointInfo. 

const (
	ControlPointInfo_TYPE_UNKNOWN ControlPointInfo_Type = 0
	ControlPointInfo_TYPE_FEATURE ControlPointInfo_Type = 1
	ControlPointInfo_TYPE_INGRESS ControlPointInfo_Type = 2
	ControlPointInfo_TYPE_EGRESS  ControlPointInfo_Type = 3
)

func (ControlPointInfo_Type) Descriptor added in v0.3.0 

func (ControlPointInfo_Type) Descriptor() protoreflect.EnumDescriptor

func (ControlPointInfo_Type) Enum added in v0.3.0 

func (x ControlPointInfo_Type) Enum() *ControlPointInfo_Type

func (ControlPointInfo_Type) EnumDescriptor deprecated added in v0.3.0 

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

Deprecated: Use ControlPointInfo_Type.Descriptor instead.

func (ControlPointInfo_Type) Number added in v0.3.0 

func (x ControlPointInfo_Type) Number() protoreflect.EnumNumber

func (ControlPointInfo_Type) String added in v0.3.0 

func (x ControlPointInfo_Type) String() string

func (ControlPointInfo_Type) Type added in v0.3.0 

func (ControlPointInfo_Type) 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 added in v0.3.0 

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

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

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

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

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

func (*FluxMeterInfo) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use FluxMeterInfo.ProtoReflect.Descriptor instead.

func (*FluxMeterInfo) GetFluxMeterName added in v0.3.0 

func (x *FluxMeterInfo) GetFluxMeterName() string

func (*FluxMeterInfo) MarshalJSON added in v0.3.0 

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

MarshalJSON implements json.Marshaler

func (*FluxMeterInfo) ProtoMessage added in v0.3.0 

func (*FluxMeterInfo) ProtoMessage()

func (*FluxMeterInfo) ProtoReflect added in v0.3.0 

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

func (*FluxMeterInfo) Reset added in v0.3.0 

func (x *FluxMeterInfo) Reset()

func (*FluxMeterInfo) String added in v0.3.0 

func (x *FluxMeterInfo) String() string

func (*FluxMeterInfo) UnmarshalJSON added in v0.3.0 

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"`
	ComponentIndex int64                         `protobuf:"varint,3,opt,name=component_index,json=componentIndex,proto3" json:"component_index,omitempty"`
	Dropped        bool                          `protobuf:"varint,4,opt,name=dropped,proto3" json:"dropped,omitempty"`
	Reason         LimiterDecision_LimiterReason `protobuf:"varint,5,opt,name=reason,proto3,enum=aperture.flowcontrol.v1.LimiterDecision_LimiterReason" json:"reason,omitempty"`
	// 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 added in v0.1.2 

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

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

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

func (x *LimiterDecision) GetComponentIndex() int64

func (*LimiterDecision) GetConcurrencyLimiterInfo added in v0.3.0 

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

func (x *LimiterDecision) GetRateLimiterInfo() *LimiterDecision_RateLimiterInfo

func (*LimiterDecision) GetReason 

func (x *LimiterDecision) GetReason() LimiterDecision_LimiterReason

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

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

func (in *LimiterDecision_ConcurrencyLimiterInfo) DeepCopy() *LimiterDecision_ConcurrencyLimiterInfo

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

func (*LimiterDecision_ConcurrencyLimiterInfo) DeepCopyInterface added in v0.3.0 

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

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

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

func (*LimiterDecision_ConcurrencyLimiterInfo) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use LimiterDecision_ConcurrencyLimiterInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_ConcurrencyLimiterInfo) GetWorkloadIndex added in v0.3.0 

func (x *LimiterDecision_ConcurrencyLimiterInfo) GetWorkloadIndex() string

func (*LimiterDecision_ConcurrencyLimiterInfo) MarshalJSON added in v0.3.0 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoMessage added in v0.3.0 

func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoMessage()

func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoReflect added in v0.3.0 

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

func (*LimiterDecision_ConcurrencyLimiterInfo) Reset added in v0.3.0 

func (x *LimiterDecision_ConcurrencyLimiterInfo) Reset()

func (*LimiterDecision_ConcurrencyLimiterInfo) String added in v0.3.0 

func (x *LimiterDecision_ConcurrencyLimiterInfo) String() string

func (*LimiterDecision_ConcurrencyLimiterInfo) UnmarshalJSON added in v0.3.0 

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

UnmarshalJSON implements json.Unmarshaler

type LimiterDecision_ConcurrencyLimiterInfo_ added in v0.3.0 

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) 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_RateLimiterInfo added in v0.3.0 

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

func (in *LimiterDecision_RateLimiterInfo) DeepCopy() *LimiterDecision_RateLimiterInfo

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

func (*LimiterDecision_RateLimiterInfo) DeepCopyInterface added in v0.3.0 

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

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

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

func (*LimiterDecision_RateLimiterInfo) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use LimiterDecision_RateLimiterInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_RateLimiterInfo) GetCurrent added in v0.3.0 

func (x *LimiterDecision_RateLimiterInfo) GetCurrent() int64

func (*LimiterDecision_RateLimiterInfo) GetLabel added in v0.3.0 

func (x *LimiterDecision_RateLimiterInfo) GetLabel() string

func (*LimiterDecision_RateLimiterInfo) GetRemaining added in v0.3.0 

func (x *LimiterDecision_RateLimiterInfo) GetRemaining() int64

func (*LimiterDecision_RateLimiterInfo) MarshalJSON added in v0.3.0 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_RateLimiterInfo) ProtoMessage added in v0.3.0 

func (*LimiterDecision_RateLimiterInfo) ProtoMessage()

func (*LimiterDecision_RateLimiterInfo) ProtoReflect added in v0.3.0 

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

func (*LimiterDecision_RateLimiterInfo) Reset added in v0.3.0 

func (x *LimiterDecision_RateLimiterInfo) Reset()

func (*LimiterDecision_RateLimiterInfo) String added in v0.3.0 

func (x *LimiterDecision_RateLimiterInfo) String() string

func (*LimiterDecision_RateLimiterInfo) UnmarshalJSON added in v0.3.0 

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

UnmarshalJSON implements json.Unmarshaler

type LimiterDecision_RateLimiterInfo_ added in v0.3.0 

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 

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.