Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

checkv1

package

Go to main page

Versions in this module

v1

v1.0.0

Mar 20, 2023

Changes in this version

+ var CheckResponse_DecisionType_name = map[int32]string

+ var CheckResponse_DecisionType_value = map[string]int32

+ var CheckResponse_RejectReason_name = map[int32]string

+ var CheckResponse_RejectReason_value = map[string]int32

+ var ClassifierInfo_Error_name = map[int32]string

+ var ClassifierInfo_Error_value = map[string]int32

+ var File_aperture_flowcontrol_check_v1_check_proto protoreflect.FileDescriptor

+ var FlowControlService_ServiceDesc = grpc.ServiceDesc

+ var LimiterDecision_LimiterReason_name = map[int32]string

+ var LimiterDecision_LimiterReason_value = map[string]int32

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

+ type CheckRequest struct

+ ControlPoint string

+ Labels map[string]string

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

+ func (*CheckRequest) ProtoMessage()

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

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

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

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

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

+ func (x *CheckRequest) GetControlPoint() string

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

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

+ func (x *CheckRequest) Reset()

+ func (x *CheckRequest) String() string

+ type CheckResponse struct

+ ClassifierInfos []*ClassifierInfo

+ ControlPoint string

+ DecisionType CheckResponse_DecisionType

+ End *timestamppb.Timestamp

+ FlowLabelKeys []string

+ FluxMeterInfos []*FluxMeterInfo

+ LimiterDecisions []*LimiterDecision

+ RejectReason CheckResponse_RejectReason

+ Services []string

+ Start *timestamppb.Timestamp

+ TelemetryFlowLabels map[string]string

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

+ func (*CheckResponse) ProtoMessage()

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

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

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

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

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

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

+ func (x *CheckResponse) GetControlPoint() string

+ func (x *CheckResponse) GetDecisionType() CheckResponse_DecisionType

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

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

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

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

+ func (x *CheckResponse) GetRejectReason() CheckResponse_RejectReason

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

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

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

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

+ func (x *CheckResponse) Reset()

+ func (x *CheckResponse) String() string

+ type CheckResponse_DecisionType int32

+ const CheckResponse_DECISION_TYPE_ACCEPTED

+ const CheckResponse_DECISION_TYPE_REJECTED

+ func (CheckResponse_DecisionType) Descriptor() protoreflect.EnumDescriptor

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

+ func (CheckResponse_DecisionType) Type() protoreflect.EnumType

+ func (x CheckResponse_DecisionType) Enum() *CheckResponse_DecisionType

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

+ func (x CheckResponse_DecisionType) String() string

+ type CheckResponse_RejectReason int32

+ const CheckResponse_REJECT_REASON_CONCURRENCY_LIMITED

+ const CheckResponse_REJECT_REASON_NONE

+ const CheckResponse_REJECT_REASON_RATE_LIMITED

+ func (CheckResponse_RejectReason) Descriptor() protoreflect.EnumDescriptor

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

+ func (CheckResponse_RejectReason) Type() protoreflect.EnumType

+ func (x CheckResponse_RejectReason) Enum() *CheckResponse_RejectReason

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

+ func (x CheckResponse_RejectReason) String() string

+ type ClassifierInfo struct

+ ClassifierIndex int64

+ Error ClassifierInfo_Error

+ LabelKey string

+ PolicyHash string

+ PolicyName string

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

+ func (*ClassifierInfo) ProtoMessage()

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

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

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

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

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

+ func (x *ClassifierInfo) GetClassifierIndex() int64

+ func (x *ClassifierInfo) GetError() ClassifierInfo_Error

+ func (x *ClassifierInfo) GetLabelKey() string

+ func (x *ClassifierInfo) GetPolicyHash() string

+ func (x *ClassifierInfo) GetPolicyName() string

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

+ func (x *ClassifierInfo) Reset()

+ func (x *ClassifierInfo) String() string

+ type ClassifierInfo_Error int32

+ const ClassifierInfo_ERROR_AMBIGUOUS_RESULTSET

+ const ClassifierInfo_ERROR_EMPTY_RESULTSET

+ const ClassifierInfo_ERROR_EVAL_FAILED

+ const ClassifierInfo_ERROR_EXPRESSION_NOT_MAP

+ const ClassifierInfo_ERROR_MULTI_EXPRESSION

+ const ClassifierInfo_ERROR_NONE

+ func (ClassifierInfo_Error) Descriptor() protoreflect.EnumDescriptor

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

+ func (ClassifierInfo_Error) Type() protoreflect.EnumType

+ func (x ClassifierInfo_Error) Enum() *ClassifierInfo_Error

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

+ func (x ClassifierInfo_Error) String() string

+ type FlowControlServiceClient interface

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

+ func NewFlowControlServiceClient(cc grpc.ClientConnInterface) FlowControlServiceClient

+ type FlowControlServiceServer interface

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

+ type FluxMeterInfo struct

+ FluxMeterName string

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

+ func (*FluxMeterInfo) ProtoMessage()

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

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

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

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

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

+ func (x *FluxMeterInfo) GetFluxMeterName() string

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

+ func (x *FluxMeterInfo) Reset()

+ func (x *FluxMeterInfo) String() string

+ type LimiterDecision struct

+ ComponentId string

+ Details isLimiterDecision_Details

+ Dropped bool

+ PolicyHash string

+ PolicyName string

+ Reason LimiterDecision_LimiterReason

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

+ func (*LimiterDecision) ProtoMessage()

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

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

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

+ func (m *LimiterDecision) GetDetails() isLimiterDecision_Details

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

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

+ func (x *LimiterDecision) GetComponentId() string

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

+ func (x *LimiterDecision) GetDropped() bool

+ func (x *LimiterDecision) GetPolicyHash() string

+ func (x *LimiterDecision) GetPolicyName() string

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

+ func (x *LimiterDecision) GetReason() LimiterDecision_LimiterReason

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

+ func (x *LimiterDecision) Reset()

+ func (x *LimiterDecision) String() string

+ type LimiterDecision_ConcurrencyLimiterInfo struct

+ WorkloadIndex string

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

+ func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoMessage()

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

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

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

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

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

+ func (x *LimiterDecision_ConcurrencyLimiterInfo) GetWorkloadIndex() string

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

+ func (x *LimiterDecision_ConcurrencyLimiterInfo) Reset()

+ func (x *LimiterDecision_ConcurrencyLimiterInfo) String() string

+ type LimiterDecision_ConcurrencyLimiterInfo_ struct

+ ConcurrencyLimiterInfo *LimiterDecision_ConcurrencyLimiterInfo

+ type LimiterDecision_LimiterReason int32

+ const LimiterDecision_LIMITER_REASON_KEY_NOT_FOUND

+ const LimiterDecision_LIMITER_REASON_UNSPECIFIED

+ func (LimiterDecision_LimiterReason) Descriptor() protoreflect.EnumDescriptor

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

+ func (LimiterDecision_LimiterReason) Type() protoreflect.EnumType

+ func (x LimiterDecision_LimiterReason) Enum() *LimiterDecision_LimiterReason

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

+ func (x LimiterDecision_LimiterReason) String() string

+ type LimiterDecision_RateLimiterInfo struct

+ Current int64

+ Label string

+ Remaining int64

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

+ func (*LimiterDecision_RateLimiterInfo) ProtoMessage()

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

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

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

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

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

+ func (x *LimiterDecision_RateLimiterInfo) GetCurrent() int64

+ func (x *LimiterDecision_RateLimiterInfo) GetLabel() string

+ func (x *LimiterDecision_RateLimiterInfo) GetRemaining() int64

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

+ func (x *LimiterDecision_RateLimiterInfo) Reset()

+ func (x *LimiterDecision_RateLimiterInfo) String() string

+ type LimiterDecision_RateLimiterInfo_ struct

+ RateLimiterInfo *LimiterDecision_RateLimiterInfo

+ type UnimplementedFlowControlServiceServer struct

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

+ type UnsafeFlowControlServiceServer interface

v1.0.0-rc.2

Mar 20, 2023

v1.0.0-rc.1

Mar 16, 2023

v0

v0.3.0-rc.3

Feb 15, 2023

v0.3.0-rc.2

Feb 14, 2023

Other modules containing this package

github.com/fluxninja/aperture-go/v2