checkv1

package
v2.0.0-...-d8f0e26 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2024 License: Apache-2.0 Imports: 28 Imported by: 21

Documentation

Index

Constants

View Source 
const (
	FlowControlService_Check_FullMethodName       = "/aperture.flowcontrol.check.v1.FlowControlService/Check"
	FlowControlService_CacheLookup_FullMethodName = "/aperture.flowcontrol.check.v1.FlowControlService/CacheLookup"
	FlowControlService_CacheUpsert_FullMethodName = "/aperture.flowcontrol.check.v1.FlowControlService/CacheUpsert"
	FlowControlService_CacheDelete_FullMethodName = "/aperture.flowcontrol.check.v1.FlowControlService/CacheDelete"
	FlowControlService_FlowEnd_FullMethodName     = "/aperture.flowcontrol.check.v1.FlowControlService/FlowEnd"
)

Variables

View Source 
var (
	CacheLookupStatus_name = map[int32]string{
		0: "HIT",
		1: "MISS",
	}
	CacheLookupStatus_value = map[string]int32{
		"HIT":  0,
		"MISS": 1,
	}
)

Enum value maps for CacheLookupStatus.

View Source 
var (
	CacheOperationStatus_name = map[int32]string{
		0: "SUCCESS",
		1: "ERROR",
	}
	CacheOperationStatus_value = map[string]int32{
		"SUCCESS": 0,
		"ERROR":   1,
	}
)

Enum value maps for CacheOperationStatus.

View Source 
var (
	StatusCode_name = map[int32]string{
		0:   "Empty",
		100: "Continue",
		200: "OK",
		201: "Created",
		202: "Accepted",
		203: "NonAuthoritativeInformation",
		204: "NoContent",
		205: "ResetContent",
		206: "PartialContent",
		207: "MultiStatus",
		208: "AlreadyReported",
		226: "IMUsed",
		300: "MultipleChoices",
		301: "MovedPermanently",
		302: "Found",
		303: "SeeOther",
		304: "NotModified",
		305: "UseProxy",
		307: "TemporaryRedirect",
		308: "PermanentRedirect",
		400: "BadRequest",
		401: "Unauthorized",
		402: "PaymentRequired",
		403: "Forbidden",
		404: "NotFound",
		405: "MethodNotAllowed",
		406: "NotAcceptable",
		407: "ProxyAuthenticationRequired",
		408: "RequestTimeout",
		409: "Conflict",
		410: "Gone",
		411: "LengthRequired",
		412: "PreconditionFailed",
		413: "PayloadTooLarge",
		414: "URITooLong",
		415: "UnsupportedMediaType",
		416: "RangeNotSatisfiable",
		417: "ExpectationFailed",
		421: "MisdirectedRequest",
		422: "UnprocessableEntity",
		423: "Locked",
		424: "FailedDependency",
		426: "UpgradeRequired",
		428: "PreconditionRequired",
		429: "TooManyRequests",
		431: "RequestHeaderFieldsTooLarge",
		500: "InternalServerError",
		501: "NotImplemented",
		502: "BadGateway",
		503: "ServiceUnavailable",
		504: "GatewayTimeout",
		505: "HTTPVersionNotSupported",
		506: "VariantAlsoNegotiates",
		507: "InsufficientStorage",
		508: "LoopDetected",
		510: "NotExtended",
		511: "NetworkAuthenticationRequired",
	}
	StatusCode_value = map[string]int32{
		"Empty":                         0,
		"Continue":                      100,
		"OK":                            200,
		"Created":                       201,
		"Accepted":                      202,
		"NonAuthoritativeInformation":   203,
		"NoContent":                     204,
		"ResetContent":                  205,
		"PartialContent":                206,
		"MultiStatus":                   207,
		"AlreadyReported":               208,
		"IMUsed":                        226,
		"MultipleChoices":               300,
		"MovedPermanently":              301,
		"Found":                         302,
		"SeeOther":                      303,
		"NotModified":                   304,
		"UseProxy":                      305,
		"TemporaryRedirect":             307,
		"PermanentRedirect":             308,
		"BadRequest":                    400,
		"Unauthorized":                  401,
		"PaymentRequired":               402,
		"Forbidden":                     403,
		"NotFound":                      404,
		"MethodNotAllowed":              405,
		"NotAcceptable":                 406,
		"ProxyAuthenticationRequired":   407,
		"RequestTimeout":                408,
		"Conflict":                      409,
		"Gone":                          410,
		"LengthRequired":                411,
		"PreconditionFailed":            412,
		"PayloadTooLarge":               413,
		"URITooLong":                    414,
		"UnsupportedMediaType":          415,
		"RangeNotSatisfiable":           416,
		"ExpectationFailed":             417,
		"MisdirectedRequest":            421,
		"UnprocessableEntity":           422,
		"Locked":                        423,
		"FailedDependency":              424,
		"UpgradeRequired":               426,
		"PreconditionRequired":          428,
		"TooManyRequests":               429,
		"RequestHeaderFieldsTooLarge":   431,
		"InternalServerError":           500,
		"NotImplemented":                501,
		"BadGateway":                    502,
		"ServiceUnavailable":            503,
		"GatewayTimeout":                504,
		"HTTPVersionNotSupported":       505,
		"VariantAlsoNegotiates":         506,
		"InsufficientStorage":           507,
		"LoopDetected":                  508,
		"NotExtended":                   510,
		"NetworkAuthenticationRequired": 511,
	}
)

Enum value maps for StatusCode.

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_NOT_SAMPLED",
		4: "REJECT_REASON_NO_MATCHING_RAMP",
	}
	CheckResponse_RejectReason_value = map[string]int32{
		"REJECT_REASON_NONE":             0,
		"REJECT_REASON_RATE_LIMITED":     1,
		"REJECT_REASON_NO_TOKENS":        2,
		"REJECT_REASON_NOT_SAMPLED":      3,
		"REJECT_REASON_NO_MATCHING_RAMP": 4,
	}
)

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,
		},
		{
			MethodName: "CacheLookup",
			Handler:    _FlowControlService_CacheLookup_Handler,
		},
		{
			MethodName: "CacheUpsert",
			Handler:    _FlowControlService_CacheUpsert_Handler,
		},
		{
			MethodName: "CacheDelete",
			Handler:    _FlowControlService_CacheDelete_Handler,
		},
		{
			MethodName: "FlowEnd",
			Handler:    _FlowControlService_FlowEnd_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 CacheDeleteRequest 

type CacheDeleteRequest struct {
	ControlPoint    string   `protobuf:"bytes,1,opt,name=control_point,json=controlPoint,proto3" json:"control_point,omitempty"`
	ResultCacheKey  string   `protobuf:"bytes,2,opt,name=result_cache_key,json=resultCacheKey,proto3" json:"result_cache_key,omitempty"`
	GlobalCacheKeys []string `protobuf:"bytes,3,rep,name=global_cache_keys,json=globalCacheKeys,proto3" json:"global_cache_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheDeleteRequest) Descriptor deprecated 

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

Deprecated: Use CacheDeleteRequest.ProtoReflect.Descriptor instead.

func (*CacheDeleteRequest) GetControlPoint 

func (x *CacheDeleteRequest) GetControlPoint() string

func (*CacheDeleteRequest) GetGlobalCacheKeys 

func (x *CacheDeleteRequest) GetGlobalCacheKeys() []string

func (*CacheDeleteRequest) GetResultCacheKey 

func (x *CacheDeleteRequest) GetResultCacheKey() string

func (*CacheDeleteRequest) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CacheDeleteRequest) MarshalToSizedBufferVT 

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

func (*CacheDeleteRequest) MarshalToVT 

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

func (*CacheDeleteRequest) MarshalVT 

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

func (*CacheDeleteRequest) ProtoMessage 

func (*CacheDeleteRequest) ProtoMessage()

func (*CacheDeleteRequest) ProtoReflect 

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

func (*CacheDeleteRequest) Reset 

func (x *CacheDeleteRequest) Reset()

func (*CacheDeleteRequest) SizeVT 

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

func (*CacheDeleteRequest) String 

func (x *CacheDeleteRequest) String() string

func (*CacheDeleteRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CacheDeleteRequest) UnmarshalVT 

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

func (*CacheDeleteRequest) Validate 

func (m *CacheDeleteRequest) Validate() error

Validate checks the field values on CacheDeleteRequest 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 (*CacheDeleteRequest) ValidateAll 

func (m *CacheDeleteRequest) ValidateAll() error

ValidateAll checks the field values on CacheDeleteRequest 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 CacheDeleteRequestMultiError, or nil if none found.

type CacheDeleteRequestMultiError 

type CacheDeleteRequestMultiError []error

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

func (CacheDeleteRequestMultiError) AllErrors 

func (m CacheDeleteRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CacheDeleteRequestMultiError) Error 

func (m CacheDeleteRequestMultiError) Error() string

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

type CacheDeleteRequestValidationError 

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

CacheDeleteRequestValidationError is the validation error returned by CacheDeleteRequest.Validate if the designated constraints aren't met.

func (CacheDeleteRequestValidationError) Cause 

func (e CacheDeleteRequestValidationError) Cause() error

Cause function returns cause value.

func (CacheDeleteRequestValidationError) Error 

func (e CacheDeleteRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CacheDeleteRequestValidationError) ErrorName 

func (e CacheDeleteRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CacheDeleteRequestValidationError) Field 

func (e CacheDeleteRequestValidationError) Field() string

Field function returns field value.

func (CacheDeleteRequestValidationError) Key 

func (e CacheDeleteRequestValidationError) Key() bool

Key function returns key value.

func (CacheDeleteRequestValidationError) Reason 

func (e CacheDeleteRequestValidationError) Reason() string

Reason function returns reason value.

type CacheDeleteResponse 

type CacheDeleteResponse struct {
	ResultCacheResponse  *KeyDeleteResponse            `protobuf:"bytes,1,opt,name=result_cache_response,json=resultCacheResponse,proto3" json:"result_cache_response,omitempty"`
	GlobalCacheResponses map[string]*KeyDeleteResponse `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CacheDeleteResponse) Descriptor deprecated 

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

Deprecated: Use CacheDeleteResponse.ProtoReflect.Descriptor instead.

func (*CacheDeleteResponse) GetGlobalCacheResponses 

func (x *CacheDeleteResponse) GetGlobalCacheResponses() map[string]*KeyDeleteResponse

func (*CacheDeleteResponse) GetResultCacheResponse 

func (x *CacheDeleteResponse) GetResultCacheResponse() *KeyDeleteResponse

func (*CacheDeleteResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CacheDeleteResponse) MarshalToSizedBufferVT 

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

func (*CacheDeleteResponse) MarshalToVT 

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

func (*CacheDeleteResponse) MarshalVT 

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

func (*CacheDeleteResponse) ProtoMessage 

func (*CacheDeleteResponse) ProtoMessage()

func (*CacheDeleteResponse) ProtoReflect 

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

func (*CacheDeleteResponse) Reset 

func (x *CacheDeleteResponse) Reset()

func (*CacheDeleteResponse) SizeVT 

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

func (*CacheDeleteResponse) String 

func (x *CacheDeleteResponse) String() string

func (*CacheDeleteResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CacheDeleteResponse) UnmarshalVT 

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

func (*CacheDeleteResponse) Validate 

func (m *CacheDeleteResponse) Validate() error

Validate checks the field values on CacheDeleteResponse 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 (*CacheDeleteResponse) ValidateAll 

func (m *CacheDeleteResponse) ValidateAll() error

ValidateAll checks the field values on CacheDeleteResponse 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 CacheDeleteResponseMultiError, or nil if none found.

type CacheDeleteResponseMultiError 

type CacheDeleteResponseMultiError []error

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

func (CacheDeleteResponseMultiError) AllErrors 

func (m CacheDeleteResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CacheDeleteResponseMultiError) Error 

func (m CacheDeleteResponseMultiError) Error() string

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

type CacheDeleteResponseValidationError 

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

CacheDeleteResponseValidationError is the validation error returned by CacheDeleteResponse.Validate if the designated constraints aren't met.

func (CacheDeleteResponseValidationError) Cause 

func (e CacheDeleteResponseValidationError) Cause() error

Cause function returns cause value.

func (CacheDeleteResponseValidationError) Error 

func (e CacheDeleteResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CacheDeleteResponseValidationError) ErrorName 

func (e CacheDeleteResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CacheDeleteResponseValidationError) Field 

func (e CacheDeleteResponseValidationError) Field() string

Field function returns field value.

func (CacheDeleteResponseValidationError) Key 

func (e CacheDeleteResponseValidationError) Key() bool

Key function returns key value.

func (CacheDeleteResponseValidationError) Reason 

func (e CacheDeleteResponseValidationError) Reason() string

Reason function returns reason value.

type CacheEntry 

type CacheEntry struct {
	Key   string               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte               `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Ttl   *durationpb.Duration `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheEntry) Descriptor deprecated 

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

Deprecated: Use CacheEntry.ProtoReflect.Descriptor instead.

func (*CacheEntry) GetKey 

func (x *CacheEntry) GetKey() string

func (*CacheEntry) GetTtl 

func (x *CacheEntry) GetTtl() *durationpb.Duration

func (*CacheEntry) GetValue 

func (x *CacheEntry) GetValue() []byte

func (*CacheEntry) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CacheEntry) MarshalToSizedBufferVT 

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

func (*CacheEntry) MarshalToVT 

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

func (*CacheEntry) MarshalVT 

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

func (*CacheEntry) ProtoMessage 

func (*CacheEntry) ProtoMessage()

func (*CacheEntry) ProtoReflect 

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

func (*CacheEntry) Reset 

func (x *CacheEntry) Reset()

func (*CacheEntry) SizeVT 

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

func (*CacheEntry) String 

func (x *CacheEntry) String() string

func (*CacheEntry) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CacheEntry) UnmarshalVT 

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

func (*CacheEntry) Validate 

func (m *CacheEntry) Validate() error

Validate checks the field values on CacheEntry 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 (*CacheEntry) ValidateAll 

func (m *CacheEntry) ValidateAll() error

ValidateAll checks the field values on CacheEntry 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 CacheEntryMultiError, or nil if none found.

type CacheEntryMultiError 

type CacheEntryMultiError []error

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

func (CacheEntryMultiError) AllErrors 

func (m CacheEntryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CacheEntryMultiError) Error 

func (m CacheEntryMultiError) Error() string

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

type CacheEntryValidationError 

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

CacheEntryValidationError is the validation error returned by CacheEntry.Validate if the designated constraints aren't met.

func (CacheEntryValidationError) Cause 

func (e CacheEntryValidationError) Cause() error

Cause function returns cause value.

func (CacheEntryValidationError) Error 

func (e CacheEntryValidationError) Error() string

Error satisfies the builtin error interface

func (CacheEntryValidationError) ErrorName 

func (e CacheEntryValidationError) ErrorName() string

ErrorName returns error name.

func (CacheEntryValidationError) Field 

func (e CacheEntryValidationError) Field() string

Field function returns field value.

func (CacheEntryValidationError) Key 

func (e CacheEntryValidationError) Key() bool

Key function returns key value.

func (CacheEntryValidationError) Reason 

func (e CacheEntryValidationError) Reason() string

Reason function returns reason value.

type CacheLookupRequest 

type CacheLookupRequest struct {
	ControlPoint string `protobuf:"bytes,1,opt,name=control_point,json=controlPoint,proto3" json:"control_point,omitempty"`
	// Key for result cache that needs to be fetched.
	ResultCacheKey string `protobuf:"bytes,2,opt,name=result_cache_key,json=resultCacheKey,proto3" json:"result_cache_key,omitempty"`
	// Keys for global cache entries that need to be fetched.
	GlobalCacheKeys []string `protobuf:"bytes,3,rep,name=global_cache_keys,json=globalCacheKeys,proto3" json:"global_cache_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheLookupRequest) Descriptor deprecated 

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

Deprecated: Use CacheLookupRequest.ProtoReflect.Descriptor instead.

func (*CacheLookupRequest) GetControlPoint 

func (x *CacheLookupRequest) GetControlPoint() string

func (*CacheLookupRequest) GetGlobalCacheKeys 

func (x *CacheLookupRequest) GetGlobalCacheKeys() []string

func (*CacheLookupRequest) GetResultCacheKey 

func (x *CacheLookupRequest) GetResultCacheKey() string

func (*CacheLookupRequest) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CacheLookupRequest) MarshalToSizedBufferVT 

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

func (*CacheLookupRequest) MarshalToVT 

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

func (*CacheLookupRequest) MarshalVT 

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

func (*CacheLookupRequest) ProtoMessage 

func (*CacheLookupRequest) ProtoMessage()

func (*CacheLookupRequest) ProtoReflect 

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

func (*CacheLookupRequest) Reset 

func (x *CacheLookupRequest) Reset()

func (*CacheLookupRequest) SizeVT 

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

func (*CacheLookupRequest) String 

func (x *CacheLookupRequest) String() string

func (*CacheLookupRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CacheLookupRequest) UnmarshalVT 

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

func (*CacheLookupRequest) Validate 

func (m *CacheLookupRequest) Validate() error

Validate checks the field values on CacheLookupRequest 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 (*CacheLookupRequest) ValidateAll 

func (m *CacheLookupRequest) ValidateAll() error

ValidateAll checks the field values on CacheLookupRequest 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 CacheLookupRequestMultiError, or nil if none found.

type CacheLookupRequestMultiError 

type CacheLookupRequestMultiError []error

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

func (CacheLookupRequestMultiError) AllErrors 

func (m CacheLookupRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CacheLookupRequestMultiError) Error 

func (m CacheLookupRequestMultiError) Error() string

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

type CacheLookupRequestValidationError 

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

CacheLookupRequestValidationError is the validation error returned by CacheLookupRequest.Validate if the designated constraints aren't met.

func (CacheLookupRequestValidationError) Cause 

func (e CacheLookupRequestValidationError) Cause() error

Cause function returns cause value.

func (CacheLookupRequestValidationError) Error 

func (e CacheLookupRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CacheLookupRequestValidationError) ErrorName 

func (e CacheLookupRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CacheLookupRequestValidationError) Field 

func (e CacheLookupRequestValidationError) Field() string

Field function returns field value.

func (CacheLookupRequestValidationError) Key 

func (e CacheLookupRequestValidationError) Key() bool

Key function returns key value.

func (CacheLookupRequestValidationError) Reason 

func (e CacheLookupRequestValidationError) Reason() string

Reason function returns reason value.

type CacheLookupResponse 

type CacheLookupResponse struct {
	ResultCacheResponse  *KeyLookupResponse            `protobuf:"bytes,1,opt,name=result_cache_response,json=resultCacheResponse,proto3" json:"result_cache_response,omitempty"`
	GlobalCacheResponses map[string]*KeyLookupResponse `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CacheLookupResponse) Descriptor deprecated 

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

Deprecated: Use CacheLookupResponse.ProtoReflect.Descriptor instead.

func (*CacheLookupResponse) GetGlobalCacheResponses 

func (x *CacheLookupResponse) GetGlobalCacheResponses() map[string]*KeyLookupResponse

func (*CacheLookupResponse) GetResultCacheResponse 

func (x *CacheLookupResponse) GetResultCacheResponse() *KeyLookupResponse

func (*CacheLookupResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CacheLookupResponse) MarshalToSizedBufferVT 

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

func (*CacheLookupResponse) MarshalToVT 

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

func (*CacheLookupResponse) MarshalVT 

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

func (*CacheLookupResponse) ProtoMessage 

func (*CacheLookupResponse) ProtoMessage()

func (*CacheLookupResponse) ProtoReflect 

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

func (*CacheLookupResponse) Reset 

func (x *CacheLookupResponse) Reset()

func (*CacheLookupResponse) SizeVT 

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

func (*CacheLookupResponse) String 

func (x *CacheLookupResponse) String() string

func (*CacheLookupResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CacheLookupResponse) UnmarshalVT 

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

func (*CacheLookupResponse) Validate 

func (m *CacheLookupResponse) Validate() error

Validate checks the field values on CacheLookupResponse 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 (*CacheLookupResponse) ValidateAll 

func (m *CacheLookupResponse) ValidateAll() error

ValidateAll checks the field values on CacheLookupResponse 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 CacheLookupResponseMultiError, or nil if none found.

type CacheLookupResponseMultiError 

type CacheLookupResponseMultiError []error

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

func (CacheLookupResponseMultiError) AllErrors 

func (m CacheLookupResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CacheLookupResponseMultiError) Error 

func (m CacheLookupResponseMultiError) Error() string

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

type CacheLookupResponseValidationError 

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

CacheLookupResponseValidationError is the validation error returned by CacheLookupResponse.Validate if the designated constraints aren't met.

func (CacheLookupResponseValidationError) Cause 

func (e CacheLookupResponseValidationError) Cause() error

Cause function returns cause value.

func (CacheLookupResponseValidationError) Error 

func (e CacheLookupResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CacheLookupResponseValidationError) ErrorName 

func (e CacheLookupResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CacheLookupResponseValidationError) Field 

func (e CacheLookupResponseValidationError) Field() string

Field function returns field value.

func (CacheLookupResponseValidationError) Key 

func (e CacheLookupResponseValidationError) Key() bool

Key function returns key value.

func (CacheLookupResponseValidationError) Reason 

func (e CacheLookupResponseValidationError) Reason() string

Reason function returns reason value.

type CacheLookupStatus 

type CacheLookupStatus int32
const (
	CacheLookupStatus_HIT  CacheLookupStatus = 0
	CacheLookupStatus_MISS CacheLookupStatus = 1
)

func (CacheLookupStatus) Descriptor 

func (CacheLookupStatus) Descriptor() protoreflect.EnumDescriptor

func (CacheLookupStatus) Enum 

func (x CacheLookupStatus) Enum() *CacheLookupStatus

func (CacheLookupStatus) EnumDescriptor deprecated 

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

Deprecated: Use CacheLookupStatus.Descriptor instead.

func (CacheLookupStatus) Number 

func (x CacheLookupStatus) Number() protoreflect.EnumNumber

func (CacheLookupStatus) String 

func (x CacheLookupStatus) String() string

func (CacheLookupStatus) Type 

func (CacheLookupStatus) Type() protoreflect.EnumType

type CacheOperationStatus 

type CacheOperationStatus int32
const (
	CacheOperationStatus_SUCCESS CacheOperationStatus = 0
	CacheOperationStatus_ERROR   CacheOperationStatus = 1
)

func (CacheOperationStatus) Descriptor 

func (CacheOperationStatus) Descriptor() protoreflect.EnumDescriptor

func (CacheOperationStatus) Enum 

func (x CacheOperationStatus) Enum() *CacheOperationStatus

func (CacheOperationStatus) EnumDescriptor deprecated 

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

Deprecated: Use CacheOperationStatus.Descriptor instead.

func (CacheOperationStatus) Number 

func (x CacheOperationStatus) Number() protoreflect.EnumNumber

func (CacheOperationStatus) String 

func (x CacheOperationStatus) String() string

func (CacheOperationStatus) Type 

func (CacheOperationStatus) Type() protoreflect.EnumType

type CacheUpsertRequest 

type CacheUpsertRequest struct {
	ControlPoint       string                 `protobuf:"bytes,1,opt,name=control_point,json=controlPoint,proto3" json:"control_point,omitempty"`
	ResultCacheEntry   *CacheEntry            `protobuf:"bytes,2,opt,name=result_cache_entry,json=resultCacheEntry,proto3" json:"result_cache_entry,omitempty"`
	GlobalCacheEntries map[string]*CacheEntry `` /* 205-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CacheUpsertRequest) Descriptor deprecated 

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

Deprecated: Use CacheUpsertRequest.ProtoReflect.Descriptor instead.

func (*CacheUpsertRequest) GetControlPoint 

func (x *CacheUpsertRequest) GetControlPoint() string

func (*CacheUpsertRequest) GetGlobalCacheEntries 

func (x *CacheUpsertRequest) GetGlobalCacheEntries() map[string]*CacheEntry

func (*CacheUpsertRequest) GetResultCacheEntry 

func (x *CacheUpsertRequest) GetResultCacheEntry() *CacheEntry

func (*CacheUpsertRequest) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CacheUpsertRequest) MarshalToSizedBufferVT 

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

func (*CacheUpsertRequest) MarshalToVT 

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

func (*CacheUpsertRequest) MarshalVT 

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

func (*CacheUpsertRequest) ProtoMessage 

func (*CacheUpsertRequest) ProtoMessage()

func (*CacheUpsertRequest) ProtoReflect 

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

func (*CacheUpsertRequest) Reset 

func (x *CacheUpsertRequest) Reset()

func (*CacheUpsertRequest) SizeVT 

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

func (*CacheUpsertRequest) String 

func (x *CacheUpsertRequest) String() string

func (*CacheUpsertRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CacheUpsertRequest) UnmarshalVT 

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

func (*CacheUpsertRequest) Validate 

func (m *CacheUpsertRequest) Validate() error

Validate checks the field values on CacheUpsertRequest 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 (*CacheUpsertRequest) ValidateAll 

func (m *CacheUpsertRequest) ValidateAll() error

ValidateAll checks the field values on CacheUpsertRequest 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 CacheUpsertRequestMultiError, or nil if none found.

type CacheUpsertRequestMultiError 

type CacheUpsertRequestMultiError []error

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

func (CacheUpsertRequestMultiError) AllErrors 

func (m CacheUpsertRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CacheUpsertRequestMultiError) Error 

func (m CacheUpsertRequestMultiError) Error() string

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

type CacheUpsertRequestValidationError 

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

CacheUpsertRequestValidationError is the validation error returned by CacheUpsertRequest.Validate if the designated constraints aren't met.

func (CacheUpsertRequestValidationError) Cause 

func (e CacheUpsertRequestValidationError) Cause() error

Cause function returns cause value.

func (CacheUpsertRequestValidationError) Error 

func (e CacheUpsertRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CacheUpsertRequestValidationError) ErrorName 

func (e CacheUpsertRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CacheUpsertRequestValidationError) Field 

func (e CacheUpsertRequestValidationError) Field() string

Field function returns field value.

func (CacheUpsertRequestValidationError) Key 

func (e CacheUpsertRequestValidationError) Key() bool

Key function returns key value.

func (CacheUpsertRequestValidationError) Reason 

func (e CacheUpsertRequestValidationError) Reason() string

Reason function returns reason value.

type CacheUpsertResponse 

type CacheUpsertResponse struct {
	ResultCacheResponse  *KeyUpsertResponse            `protobuf:"bytes,1,opt,name=result_cache_response,json=resultCacheResponse,proto3" json:"result_cache_response,omitempty"`
	GlobalCacheResponses map[string]*KeyUpsertResponse `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CacheUpsertResponse) Descriptor deprecated 

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

Deprecated: Use CacheUpsertResponse.ProtoReflect.Descriptor instead.

func (*CacheUpsertResponse) GetGlobalCacheResponses 

func (x *CacheUpsertResponse) GetGlobalCacheResponses() map[string]*KeyUpsertResponse

func (*CacheUpsertResponse) GetResultCacheResponse 

func (x *CacheUpsertResponse) GetResultCacheResponse() *KeyUpsertResponse

func (*CacheUpsertResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CacheUpsertResponse) MarshalToSizedBufferVT 

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

func (*CacheUpsertResponse) MarshalToVT 

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

func (*CacheUpsertResponse) MarshalVT 

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

func (*CacheUpsertResponse) ProtoMessage 

func (*CacheUpsertResponse) ProtoMessage()

func (*CacheUpsertResponse) ProtoReflect 

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

func (*CacheUpsertResponse) Reset 

func (x *CacheUpsertResponse) Reset()

func (*CacheUpsertResponse) SizeVT 

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

func (*CacheUpsertResponse) String 

func (x *CacheUpsertResponse) String() string

func (*CacheUpsertResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*CacheUpsertResponse) UnmarshalVT 

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

func (*CacheUpsertResponse) Validate 

func (m *CacheUpsertResponse) Validate() error

Validate checks the field values on CacheUpsertResponse 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 (*CacheUpsertResponse) ValidateAll 

func (m *CacheUpsertResponse) ValidateAll() error

ValidateAll checks the field values on CacheUpsertResponse 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 CacheUpsertResponseMultiError, or nil if none found.

type CacheUpsertResponseMultiError 

type CacheUpsertResponseMultiError []error

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

func (CacheUpsertResponseMultiError) AllErrors 

func (m CacheUpsertResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CacheUpsertResponseMultiError) Error 

func (m CacheUpsertResponseMultiError) Error() string

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

type CacheUpsertResponseValidationError 

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

CacheUpsertResponseValidationError is the validation error returned by CacheUpsertResponse.Validate if the designated constraints aren't met.

func (CacheUpsertResponseValidationError) Cause 

func (e CacheUpsertResponseValidationError) Cause() error

Cause function returns cause value.

func (CacheUpsertResponseValidationError) Error 

func (e CacheUpsertResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CacheUpsertResponseValidationError) ErrorName 

func (e CacheUpsertResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CacheUpsertResponseValidationError) Field 

func (e CacheUpsertResponseValidationError) Field() string

Field function returns field value.

func (CacheUpsertResponseValidationError) Key 

func (e CacheUpsertResponseValidationError) Key() bool

Key function returns key value.

func (CacheUpsertResponseValidationError) Reason 

func (e CacheUpsertResponseValidationError) Reason() string

Reason function returns reason value.

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 */
	RampMode           bool                `protobuf:"varint,3,opt,name=ramp_mode,json=rampMode,proto3" json:"ramp_mode,omitempty"`
	CacheLookupRequest *CacheLookupRequest `protobuf:"bytes,4,opt,name=cache_lookup_request,json=cacheLookupRequest,proto3" json:"cache_lookup_request,omitempty"`
	ExpectEnd          bool                `protobuf:"varint,5,opt,name=expect_end,json=expectEnd,proto3" json:"expect_end,omitempty"`
	// 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) GetCacheLookupRequest 

func (x *CheckRequest) GetCacheLookupRequest() *CacheLookupRequest

func (*CheckRequest) GetControlPoint 

func (x *CheckRequest) GetControlPoint() string

func (*CheckRequest) GetExpectEnd 

func (x *CheckRequest) GetExpectEnd() bool

func (*CheckRequest) GetLabels 

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

func (*CheckRequest) GetRampMode 

func (x *CheckRequest) GetRampMode() bool

func (*CheckRequest) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CheckRequest) MarshalToSizedBufferVT 

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

func (*CheckRequest) MarshalToVT 

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

func (*CheckRequest) MarshalVT 

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 

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 

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"`
	// http_status contains the http status code to be returned to the client, if
	// decision_type is REJECTED. Optional.
	DeniedResponseStatusCode StatusCode `` /* 185-byte string literal not displayed */
	// CacheLookupResponse contains the result of the cache lookup.
	CacheLookupResponse *CacheLookupResponse `protobuf:"bytes,15,opt,name=cache_lookup_response,json=cacheLookupResponse,proto3" json:"cache_lookup_response,omitempty"`
	// Expected End for this request.
	ExpectEnd bool `protobuf:"varint,16,opt,name=expect_end,json=expectEnd,proto3" json:"expect_end,omitempty"`
	// contains filtered or unexported fields
}

CheckResponse contains fields that represent decision made by Check call.

func CheckResponseFromVTPool 

func CheckResponseFromVTPool() *CheckResponse

func (*CheckResponse) Descriptor deprecated 

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

Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead.

func (*CheckResponse) GetCacheLookupResponse 

func (x *CheckResponse) GetCacheLookupResponse() *CacheLookupResponse

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

func (x *CheckResponse) GetDeniedResponseStatusCode() StatusCode

func (*CheckResponse) GetEnd 

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

func (*CheckResponse) GetExpectEnd 

func (x *CheckResponse) GetExpectEnd() bool

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 

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

func (*CheckResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*CheckResponse) MarshalToSizedBufferVT 

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

func (*CheckResponse) MarshalToVT 

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

func (*CheckResponse) MarshalVT 

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 

func (m *CheckResponse) ResetVT()

func (*CheckResponse) ReturnToVTPool 

func (m *CheckResponse) ReturnToVTPool()

func (*CheckResponse) SizeVT 

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 

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_NOT_SAMPLED      CheckResponse_RejectReason = 3
	CheckResponse_REJECT_REASON_NO_MATCHING_RAMP CheckResponse_RejectReason = 4
)

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 

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

func (*ClassifierInfo) MarshalToVT 

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

func (*ClassifierInfo) MarshalVT 

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 

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 

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)
	CacheLookup(ctx context.Context, in *CacheLookupRequest, opts ...grpc.CallOption) (*CacheLookupResponse, error)
	CacheUpsert(ctx context.Context, in *CacheUpsertRequest, opts ...grpc.CallOption) (*CacheUpsertResponse, error)
	CacheDelete(ctx context.Context, in *CacheDeleteRequest, opts ...grpc.CallOption) (*CacheDeleteResponse, error)
	FlowEnd(ctx context.Context, in *FlowEndRequest, opts ...grpc.CallOption) (*FlowEndResponse, 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)
	CacheLookup(context.Context, *CacheLookupRequest) (*CacheLookupResponse, error)
	CacheUpsert(context.Context, *CacheUpsertRequest) (*CacheUpsertResponse, error)
	CacheDelete(context.Context, *CacheDeleteRequest) (*CacheDeleteResponse, error)
	FlowEnd(context.Context, *FlowEndRequest) (*FlowEndResponse, error)
}

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

type FlowEndRequest 

type FlowEndRequest struct {
	ControlPoint     string                `protobuf:"bytes,1,opt,name=control_point,json=controlPoint,proto3" json:"control_point,omitempty"` // needed for telemetry
	InflightRequests []*InflightRequestRef `protobuf:"bytes,2,rep,name=inflight_requests,json=inflightRequests,proto3" json:"inflight_requests,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowEndRequest) Descriptor deprecated 

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

Deprecated: Use FlowEndRequest.ProtoReflect.Descriptor instead.

func (*FlowEndRequest) GetControlPoint 

func (x *FlowEndRequest) GetControlPoint() string

func (*FlowEndRequest) GetInflightRequests 

func (x *FlowEndRequest) GetInflightRequests() []*InflightRequestRef

func (*FlowEndRequest) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*FlowEndRequest) MarshalToSizedBufferVT 

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

func (*FlowEndRequest) MarshalToVT 

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

func (*FlowEndRequest) MarshalVT 

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

func (*FlowEndRequest) ProtoMessage 

func (*FlowEndRequest) ProtoMessage()

func (*FlowEndRequest) ProtoReflect 

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

func (*FlowEndRequest) Reset 

func (x *FlowEndRequest) Reset()

func (*FlowEndRequest) SizeVT 

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

func (*FlowEndRequest) String 

func (x *FlowEndRequest) String() string

func (*FlowEndRequest) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*FlowEndRequest) UnmarshalVT 

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

func (*FlowEndRequest) Validate 

func (m *FlowEndRequest) Validate() error

Validate checks the field values on FlowEndRequest 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 (*FlowEndRequest) ValidateAll 

func (m *FlowEndRequest) ValidateAll() error

ValidateAll checks the field values on FlowEndRequest 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 FlowEndRequestMultiError, or nil if none found.

type FlowEndRequestMultiError 

type FlowEndRequestMultiError []error

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

func (FlowEndRequestMultiError) AllErrors 

func (m FlowEndRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FlowEndRequestMultiError) Error 

func (m FlowEndRequestMultiError) Error() string

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

type FlowEndRequestValidationError 

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

FlowEndRequestValidationError is the validation error returned by FlowEndRequest.Validate if the designated constraints aren't met.

func (FlowEndRequestValidationError) Cause 

func (e FlowEndRequestValidationError) Cause() error

Cause function returns cause value.

func (FlowEndRequestValidationError) Error 

func (e FlowEndRequestValidationError) Error() string

Error satisfies the builtin error interface

func (FlowEndRequestValidationError) ErrorName 

func (e FlowEndRequestValidationError) ErrorName() string

ErrorName returns error name.

func (FlowEndRequestValidationError) Field 

func (e FlowEndRequestValidationError) Field() string

Field function returns field value.

func (FlowEndRequestValidationError) Key 

func (e FlowEndRequestValidationError) Key() bool

Key function returns key value.

func (FlowEndRequestValidationError) Reason 

func (e FlowEndRequestValidationError) Reason() string

Reason function returns reason value.

type FlowEndResponse 

type FlowEndResponse struct {
	TokenReturnStatuses []*TokenReturnStatus `protobuf:"bytes,1,rep,name=token_return_statuses,json=tokenReturnStatuses,proto3" json:"token_return_statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowEndResponse) Descriptor deprecated 

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

Deprecated: Use FlowEndResponse.ProtoReflect.Descriptor instead.

func (*FlowEndResponse) GetTokenReturnStatuses 

func (x *FlowEndResponse) GetTokenReturnStatuses() []*TokenReturnStatus

func (*FlowEndResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*FlowEndResponse) MarshalToSizedBufferVT 

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

func (*FlowEndResponse) MarshalToVT 

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

func (*FlowEndResponse) MarshalVT 

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

func (*FlowEndResponse) ProtoMessage 

func (*FlowEndResponse) ProtoMessage()

func (*FlowEndResponse) ProtoReflect 

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

func (*FlowEndResponse) Reset 

func (x *FlowEndResponse) Reset()

func (*FlowEndResponse) SizeVT 

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

func (*FlowEndResponse) String 

func (x *FlowEndResponse) String() string

func (*FlowEndResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*FlowEndResponse) UnmarshalVT 

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

func (*FlowEndResponse) Validate 

func (m *FlowEndResponse) Validate() error

Validate checks the field values on FlowEndResponse 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 (*FlowEndResponse) ValidateAll 

func (m *FlowEndResponse) ValidateAll() error

ValidateAll checks the field values on FlowEndResponse 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 FlowEndResponseMultiError, or nil if none found.

type FlowEndResponseMultiError 

type FlowEndResponseMultiError []error

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

func (FlowEndResponseMultiError) AllErrors 

func (m FlowEndResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FlowEndResponseMultiError) Error 

func (m FlowEndResponseMultiError) Error() string

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

type FlowEndResponseValidationError 

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

FlowEndResponseValidationError is the validation error returned by FlowEndResponse.Validate if the designated constraints aren't met.

func (FlowEndResponseValidationError) Cause 

func (e FlowEndResponseValidationError) Cause() error

Cause function returns cause value.

func (FlowEndResponseValidationError) Error 

func (e FlowEndResponseValidationError) Error() string

Error satisfies the builtin error interface

func (FlowEndResponseValidationError) ErrorName 

func (e FlowEndResponseValidationError) ErrorName() string

ErrorName returns error name.

func (FlowEndResponseValidationError) Field 

func (e FlowEndResponseValidationError) Field() string

Field function returns field value.

func (FlowEndResponseValidationError) Key 

func (e FlowEndResponseValidationError) Key() bool

Key function returns key value.

func (FlowEndResponseValidationError) Reason 

func (e FlowEndResponseValidationError) Reason() string

Reason function returns reason value.

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 

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

func (*FluxMeterInfo) MarshalToVT 

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

func (*FluxMeterInfo) MarshalVT 

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 

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 

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 InflightRequestRef 

type InflightRequestRef 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"`
	Label       string  `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	RequestId   string  `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Tokens      float64 `protobuf:"fixed64,6,opt,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*InflightRequestRef) Descriptor deprecated 

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

Deprecated: Use InflightRequestRef.ProtoReflect.Descriptor instead.

func (*InflightRequestRef) GetComponentId 

func (x *InflightRequestRef) GetComponentId() string

func (*InflightRequestRef) GetLabel 

func (x *InflightRequestRef) GetLabel() string

func (*InflightRequestRef) GetPolicyHash 

func (x *InflightRequestRef) GetPolicyHash() string

func (*InflightRequestRef) GetPolicyName 

func (x *InflightRequestRef) GetPolicyName() string

func (*InflightRequestRef) GetRequestId 

func (x *InflightRequestRef) GetRequestId() string

func (*InflightRequestRef) GetTokens 

func (x *InflightRequestRef) GetTokens() float64

func (*InflightRequestRef) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*InflightRequestRef) MarshalToSizedBufferVT 

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

func (*InflightRequestRef) MarshalToVT 

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

func (*InflightRequestRef) MarshalVT 

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

func (*InflightRequestRef) ProtoMessage 

func (*InflightRequestRef) ProtoMessage()

func (*InflightRequestRef) ProtoReflect 

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

func (*InflightRequestRef) Reset 

func (x *InflightRequestRef) Reset()

func (*InflightRequestRef) SizeVT 

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

func (*InflightRequestRef) String 

func (x *InflightRequestRef) String() string

func (*InflightRequestRef) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*InflightRequestRef) UnmarshalVT 

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

func (*InflightRequestRef) Validate 

func (m *InflightRequestRef) Validate() error

Validate checks the field values on InflightRequestRef 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 (*InflightRequestRef) ValidateAll 

func (m *InflightRequestRef) ValidateAll() error

ValidateAll checks the field values on InflightRequestRef 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 InflightRequestRefMultiError, or nil if none found.

type InflightRequestRefMultiError 

type InflightRequestRefMultiError []error

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

func (InflightRequestRefMultiError) AllErrors 

func (m InflightRequestRefMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InflightRequestRefMultiError) Error 

func (m InflightRequestRefMultiError) Error() string

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

type InflightRequestRefValidationError 

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

InflightRequestRefValidationError is the validation error returned by InflightRequestRef.Validate if the designated constraints aren't met.

func (InflightRequestRefValidationError) Cause 

func (e InflightRequestRefValidationError) Cause() error

Cause function returns cause value.

func (InflightRequestRefValidationError) Error 

func (e InflightRequestRefValidationError) Error() string

Error satisfies the builtin error interface

func (InflightRequestRefValidationError) ErrorName 

func (e InflightRequestRefValidationError) ErrorName() string

ErrorName returns error name.

func (InflightRequestRefValidationError) Field 

func (e InflightRequestRefValidationError) Field() string

Field function returns field value.

func (InflightRequestRefValidationError) Key 

func (e InflightRequestRefValidationError) Key() bool

Key function returns key value.

func (InflightRequestRefValidationError) Reason 

func (e InflightRequestRefValidationError) Reason() string

Reason function returns reason value.

type KeyDeleteResponse 

type KeyDeleteResponse struct {
	OperationStatus CacheOperationStatus `` /* 163-byte string literal not displayed */
	Error           string               `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyDeleteResponse) Descriptor deprecated 

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

Deprecated: Use KeyDeleteResponse.ProtoReflect.Descriptor instead.

func (*KeyDeleteResponse) GetError 

func (x *KeyDeleteResponse) GetError() string

func (*KeyDeleteResponse) GetOperationStatus 

func (x *KeyDeleteResponse) GetOperationStatus() CacheOperationStatus

func (*KeyDeleteResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*KeyDeleteResponse) MarshalToSizedBufferVT 

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

func (*KeyDeleteResponse) MarshalToVT 

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

func (*KeyDeleteResponse) MarshalVT 

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

func (*KeyDeleteResponse) ProtoMessage 

func (*KeyDeleteResponse) ProtoMessage()

func (*KeyDeleteResponse) ProtoReflect 

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

func (*KeyDeleteResponse) Reset 

func (x *KeyDeleteResponse) Reset()

func (*KeyDeleteResponse) SizeVT 

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

func (*KeyDeleteResponse) String 

func (x *KeyDeleteResponse) String() string

func (*KeyDeleteResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*KeyDeleteResponse) UnmarshalVT 

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

func (*KeyDeleteResponse) Validate 

func (m *KeyDeleteResponse) Validate() error

Validate checks the field values on KeyDeleteResponse 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 (*KeyDeleteResponse) ValidateAll 

func (m *KeyDeleteResponse) ValidateAll() error

ValidateAll checks the field values on KeyDeleteResponse 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 KeyDeleteResponseMultiError, or nil if none found.

type KeyDeleteResponseMultiError 

type KeyDeleteResponseMultiError []error

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

func (KeyDeleteResponseMultiError) AllErrors 

func (m KeyDeleteResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KeyDeleteResponseMultiError) Error 

func (m KeyDeleteResponseMultiError) Error() string

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

type KeyDeleteResponseValidationError 

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

KeyDeleteResponseValidationError is the validation error returned by KeyDeleteResponse.Validate if the designated constraints aren't met.

func (KeyDeleteResponseValidationError) Cause 

func (e KeyDeleteResponseValidationError) Cause() error

Cause function returns cause value.

func (KeyDeleteResponseValidationError) Error 

func (e KeyDeleteResponseValidationError) Error() string

Error satisfies the builtin error interface

func (KeyDeleteResponseValidationError) ErrorName 

func (e KeyDeleteResponseValidationError) ErrorName() string

ErrorName returns error name.

func (KeyDeleteResponseValidationError) Field 

func (e KeyDeleteResponseValidationError) Field() string

Field function returns field value.

func (KeyDeleteResponseValidationError) Key 

func (e KeyDeleteResponseValidationError) Key() bool

Key function returns key value.

func (KeyDeleteResponseValidationError) Reason 

func (e KeyDeleteResponseValidationError) Reason() string

Reason function returns reason value.

type KeyLookupResponse 

type KeyLookupResponse struct {
	Value           []byte               `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	LookupStatus    CacheLookupStatus    `` /* 151-byte string literal not displayed */
	OperationStatus CacheOperationStatus `` /* 163-byte string literal not displayed */
	Error           string               `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyLookupResponse) Descriptor deprecated 

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

Deprecated: Use KeyLookupResponse.ProtoReflect.Descriptor instead.

func (*KeyLookupResponse) GetError 

func (x *KeyLookupResponse) GetError() string

func (*KeyLookupResponse) GetLookupStatus 

func (x *KeyLookupResponse) GetLookupStatus() CacheLookupStatus

func (*KeyLookupResponse) GetOperationStatus 

func (x *KeyLookupResponse) GetOperationStatus() CacheOperationStatus

func (*KeyLookupResponse) GetValue 

func (x *KeyLookupResponse) GetValue() []byte

func (*KeyLookupResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*KeyLookupResponse) MarshalToSizedBufferVT 

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

func (*KeyLookupResponse) MarshalToVT 

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

func (*KeyLookupResponse) MarshalVT 

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

func (*KeyLookupResponse) ProtoMessage 

func (*KeyLookupResponse) ProtoMessage()

func (*KeyLookupResponse) ProtoReflect 

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

func (*KeyLookupResponse) Reset 

func (x *KeyLookupResponse) Reset()

func (*KeyLookupResponse) SizeVT 

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

func (*KeyLookupResponse) String 

func (x *KeyLookupResponse) String() string

func (*KeyLookupResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*KeyLookupResponse) UnmarshalVT 

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

func (*KeyLookupResponse) Validate 

func (m *KeyLookupResponse) Validate() error

Validate checks the field values on KeyLookupResponse 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 (*KeyLookupResponse) ValidateAll 

func (m *KeyLookupResponse) ValidateAll() error

ValidateAll checks the field values on KeyLookupResponse 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 KeyLookupResponseMultiError, or nil if none found.

type KeyLookupResponseMultiError 

type KeyLookupResponseMultiError []error

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

func (KeyLookupResponseMultiError) AllErrors 

func (m KeyLookupResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KeyLookupResponseMultiError) Error 

func (m KeyLookupResponseMultiError) Error() string

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

type KeyLookupResponseValidationError 

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

KeyLookupResponseValidationError is the validation error returned by KeyLookupResponse.Validate if the designated constraints aren't met.

func (KeyLookupResponseValidationError) Cause 

func (e KeyLookupResponseValidationError) Cause() error

Cause function returns cause value.

func (KeyLookupResponseValidationError) Error 

func (e KeyLookupResponseValidationError) Error() string

Error satisfies the builtin error interface

func (KeyLookupResponseValidationError) ErrorName 

func (e KeyLookupResponseValidationError) ErrorName() string

ErrorName returns error name.

func (KeyLookupResponseValidationError) Field 

func (e KeyLookupResponseValidationError) Field() string

Field function returns field value.

func (KeyLookupResponseValidationError) Key 

func (e KeyLookupResponseValidationError) Key() bool

Key function returns key value.

func (KeyLookupResponseValidationError) Reason 

func (e KeyLookupResponseValidationError) Reason() string

Reason function returns reason value.

type KeyUpsertResponse 

type KeyUpsertResponse struct {
	OperationStatus CacheOperationStatus `` /* 163-byte string literal not displayed */
	Error           string               `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyUpsertResponse) Descriptor deprecated 

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

Deprecated: Use KeyUpsertResponse.ProtoReflect.Descriptor instead.

func (*KeyUpsertResponse) GetError 

func (x *KeyUpsertResponse) GetError() string

func (*KeyUpsertResponse) GetOperationStatus 

func (x *KeyUpsertResponse) GetOperationStatus() CacheOperationStatus

func (*KeyUpsertResponse) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*KeyUpsertResponse) MarshalToSizedBufferVT 

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

func (*KeyUpsertResponse) MarshalToVT 

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

func (*KeyUpsertResponse) MarshalVT 

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

func (*KeyUpsertResponse) ProtoMessage 

func (*KeyUpsertResponse) ProtoMessage()

func (*KeyUpsertResponse) ProtoReflect 

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

func (*KeyUpsertResponse) Reset 

func (x *KeyUpsertResponse) Reset()

func (*KeyUpsertResponse) SizeVT 

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

func (*KeyUpsertResponse) String 

func (x *KeyUpsertResponse) String() string

func (*KeyUpsertResponse) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*KeyUpsertResponse) UnmarshalVT 

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

func (*KeyUpsertResponse) Validate 

func (m *KeyUpsertResponse) Validate() error

Validate checks the field values on KeyUpsertResponse 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 (*KeyUpsertResponse) ValidateAll 

func (m *KeyUpsertResponse) ValidateAll() error

ValidateAll checks the field values on KeyUpsertResponse 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 KeyUpsertResponseMultiError, or nil if none found.

type KeyUpsertResponseMultiError 

type KeyUpsertResponseMultiError []error

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

func (KeyUpsertResponseMultiError) AllErrors 

func (m KeyUpsertResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KeyUpsertResponseMultiError) Error 

func (m KeyUpsertResponseMultiError) Error() string

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

type KeyUpsertResponseValidationError 

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

KeyUpsertResponseValidationError is the validation error returned by KeyUpsertResponse.Validate if the designated constraints aren't met.

func (KeyUpsertResponseValidationError) Cause 

func (e KeyUpsertResponseValidationError) Cause() error

Cause function returns cause value.

func (KeyUpsertResponseValidationError) Error 

func (e KeyUpsertResponseValidationError) Error() string

Error satisfies the builtin error interface

func (KeyUpsertResponseValidationError) ErrorName 

func (e KeyUpsertResponseValidationError) ErrorName() string

ErrorName returns error name.

func (KeyUpsertResponseValidationError) Field 

func (e KeyUpsertResponseValidationError) Field() string

Field function returns field value.

func (KeyUpsertResponseValidationError) Key 

func (e KeyUpsertResponseValidationError) Key() bool

Key function returns key value.

func (KeyUpsertResponseValidationError) Reason 

func (e KeyUpsertResponseValidationError) 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 */
	DeniedResponseStatusCode StatusCode                    `` /* 185-byte string literal not displayed */
	WaitTime                 *durationpb.Duration          `protobuf:"bytes,11,opt,name=wait_time,json=waitTime,proto3" json:"wait_time,omitempty"`
	// Types that are assignable to Details:
	//
	//	*LimiterDecision_RateLimiterInfo_
	//	*LimiterDecision_LoadSchedulerInfo
	//	*LimiterDecision_SamplerInfo_
	//	*LimiterDecision_QuotaSchedulerInfo_
	//	*LimiterDecision_ConcurrencyLimiterInfo_
	//	*LimiterDecision_ConcurrencySchedulerInfo_
	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) GetConcurrencyLimiterInfo 

func (x *LimiterDecision) GetConcurrencyLimiterInfo() *LimiterDecision_ConcurrencyLimiterInfo

func (*LimiterDecision) GetConcurrencySchedulerInfo 

func (x *LimiterDecision) GetConcurrencySchedulerInfo() *LimiterDecision_ConcurrencySchedulerInfo

func (*LimiterDecision) GetDeniedResponseStatusCode 

func (x *LimiterDecision) GetDeniedResponseStatusCode() StatusCode

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 

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 

func (x *LimiterDecision) GetSamplerInfo() *LimiterDecision_SamplerInfo

func (*LimiterDecision) GetWaitTime 

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

func (*LimiterDecision) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision) MarshalToSizedBufferVT 

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

func (*LimiterDecision) MarshalToVT 

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

func (*LimiterDecision) MarshalVT 

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 

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 

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_ConcurrencyLimiterInfo 

type LimiterDecision_ConcurrencyLimiterInfo struct {
	Label      string                      `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	TokensInfo *LimiterDecision_TokensInfo `protobuf:"bytes,2,opt,name=tokens_info,json=tokensInfo,proto3" json:"tokens_info,omitempty"`
	RequestId  string                      `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LimiterDecision_ConcurrencyLimiterInfo) Descriptor deprecated 

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

Deprecated: Use LimiterDecision_ConcurrencyLimiterInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_ConcurrencyLimiterInfo) GetLabel 

func (x *LimiterDecision_ConcurrencyLimiterInfo) GetLabel() string

func (*LimiterDecision_ConcurrencyLimiterInfo) GetRequestId 

func (x *LimiterDecision_ConcurrencyLimiterInfo) GetRequestId() string

func (*LimiterDecision_ConcurrencyLimiterInfo) GetTokensInfo 

func (x *LimiterDecision_ConcurrencyLimiterInfo) GetTokensInfo() *LimiterDecision_TokensInfo

func (*LimiterDecision_ConcurrencyLimiterInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_ConcurrencyLimiterInfo) MarshalToSizedBufferVT 

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

func (*LimiterDecision_ConcurrencyLimiterInfo) MarshalToVT 

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

func (*LimiterDecision_ConcurrencyLimiterInfo) MarshalVT 

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

func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoMessage 

func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoMessage()

func (*LimiterDecision_ConcurrencyLimiterInfo) ProtoReflect 

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

func (*LimiterDecision_ConcurrencyLimiterInfo) Reset 

func (x *LimiterDecision_ConcurrencyLimiterInfo) Reset()

func (*LimiterDecision_ConcurrencyLimiterInfo) SizeVT 

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

func (*LimiterDecision_ConcurrencyLimiterInfo) String 

func (x *LimiterDecision_ConcurrencyLimiterInfo) String() string

func (*LimiterDecision_ConcurrencyLimiterInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_ConcurrencyLimiterInfo) UnmarshalVT 

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

func (*LimiterDecision_ConcurrencyLimiterInfo) Validate 

func (m *LimiterDecision_ConcurrencyLimiterInfo) Validate() error

Validate checks the field values on LimiterDecision_ConcurrencyLimiterInfo 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_ConcurrencyLimiterInfo) ValidateAll 

func (m *LimiterDecision_ConcurrencyLimiterInfo) ValidateAll() error

ValidateAll checks the field values on LimiterDecision_ConcurrencyLimiterInfo 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_ConcurrencyLimiterInfoMultiError, or nil if none found.

type LimiterDecision_ConcurrencyLimiterInfoMultiError 

type LimiterDecision_ConcurrencyLimiterInfoMultiError []error

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

func (LimiterDecision_ConcurrencyLimiterInfoMultiError) AllErrors 

func (m LimiterDecision_ConcurrencyLimiterInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_ConcurrencyLimiterInfoMultiError) Error 

func (m LimiterDecision_ConcurrencyLimiterInfoMultiError) Error() string

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

type LimiterDecision_ConcurrencyLimiterInfoValidationError 

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

LimiterDecision_ConcurrencyLimiterInfoValidationError is the validation error returned by LimiterDecision_ConcurrencyLimiterInfo.Validate if the designated constraints aren't met.

func (LimiterDecision_ConcurrencyLimiterInfoValidationError) Cause 

func (e LimiterDecision_ConcurrencyLimiterInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_ConcurrencyLimiterInfoValidationError) Error 

func (e LimiterDecision_ConcurrencyLimiterInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_ConcurrencyLimiterInfoValidationError) ErrorName 

func (e LimiterDecision_ConcurrencyLimiterInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_ConcurrencyLimiterInfoValidationError) Field 

func (e LimiterDecision_ConcurrencyLimiterInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_ConcurrencyLimiterInfoValidationError) Key 

func (e LimiterDecision_ConcurrencyLimiterInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_ConcurrencyLimiterInfoValidationError) Reason 

func (e LimiterDecision_ConcurrencyLimiterInfoValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision_ConcurrencyLimiterInfo_ 

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

func (*LimiterDecision_ConcurrencyLimiterInfo_) MarshalToSizedBufferVT 

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

func (*LimiterDecision_ConcurrencyLimiterInfo_) MarshalToVT 

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

func (*LimiterDecision_ConcurrencyLimiterInfo_) SizeVT 

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

type LimiterDecision_ConcurrencySchedulerInfo 

type LimiterDecision_ConcurrencySchedulerInfo struct {
	Label         string                      `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	WorkloadIndex string                      `protobuf:"bytes,2,opt,name=workload_index,json=workloadIndex,proto3" json:"workload_index,omitempty"`
	TokensInfo    *LimiterDecision_TokensInfo `protobuf:"bytes,3,opt,name=tokens_info,json=tokensInfo,proto3" json:"tokens_info,omitempty"`
	Priority      float64                     `protobuf:"fixed64,4,opt,name=priority,proto3" json:"priority,omitempty"`
	RequestId     string                      `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LimiterDecision_ConcurrencySchedulerInfo) Descriptor deprecated 

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

Deprecated: Use LimiterDecision_ConcurrencySchedulerInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_ConcurrencySchedulerInfo) GetLabel 

func (x *LimiterDecision_ConcurrencySchedulerInfo) GetLabel() string

func (*LimiterDecision_ConcurrencySchedulerInfo) GetPriority 

func (x *LimiterDecision_ConcurrencySchedulerInfo) GetPriority() float64

func (*LimiterDecision_ConcurrencySchedulerInfo) GetRequestId 

func (x *LimiterDecision_ConcurrencySchedulerInfo) GetRequestId() string

func (*LimiterDecision_ConcurrencySchedulerInfo) GetTokensInfo 

func (x *LimiterDecision_ConcurrencySchedulerInfo) GetTokensInfo() *LimiterDecision_TokensInfo

func (*LimiterDecision_ConcurrencySchedulerInfo) GetWorkloadIndex 

func (x *LimiterDecision_ConcurrencySchedulerInfo) GetWorkloadIndex() string

func (*LimiterDecision_ConcurrencySchedulerInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_ConcurrencySchedulerInfo) MarshalToSizedBufferVT 

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

func (*LimiterDecision_ConcurrencySchedulerInfo) MarshalToVT 

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

func (*LimiterDecision_ConcurrencySchedulerInfo) MarshalVT 

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

func (*LimiterDecision_ConcurrencySchedulerInfo) ProtoMessage 

func (*LimiterDecision_ConcurrencySchedulerInfo) ProtoMessage()

func (*LimiterDecision_ConcurrencySchedulerInfo) ProtoReflect 

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

func (*LimiterDecision_ConcurrencySchedulerInfo) Reset 

func (x *LimiterDecision_ConcurrencySchedulerInfo) Reset()

func (*LimiterDecision_ConcurrencySchedulerInfo) SizeVT 

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

func (*LimiterDecision_ConcurrencySchedulerInfo) String 

func (x *LimiterDecision_ConcurrencySchedulerInfo) String() string

func (*LimiterDecision_ConcurrencySchedulerInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_ConcurrencySchedulerInfo) UnmarshalVT 

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

func (*LimiterDecision_ConcurrencySchedulerInfo) Validate 

func (m *LimiterDecision_ConcurrencySchedulerInfo) Validate() error

Validate checks the field values on LimiterDecision_ConcurrencySchedulerInfo 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_ConcurrencySchedulerInfo) ValidateAll 

func (m *LimiterDecision_ConcurrencySchedulerInfo) ValidateAll() error

ValidateAll checks the field values on LimiterDecision_ConcurrencySchedulerInfo 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_ConcurrencySchedulerInfoMultiError, or nil if none found.

type LimiterDecision_ConcurrencySchedulerInfoMultiError 

type LimiterDecision_ConcurrencySchedulerInfoMultiError []error

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

func (LimiterDecision_ConcurrencySchedulerInfoMultiError) AllErrors 

func (m LimiterDecision_ConcurrencySchedulerInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_ConcurrencySchedulerInfoMultiError) Error 

func (m LimiterDecision_ConcurrencySchedulerInfoMultiError) Error() string

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

type LimiterDecision_ConcurrencySchedulerInfoValidationError 

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

LimiterDecision_ConcurrencySchedulerInfoValidationError is the validation error returned by LimiterDecision_ConcurrencySchedulerInfo.Validate if the designated constraints aren't met.

func (LimiterDecision_ConcurrencySchedulerInfoValidationError) Cause 

func (e LimiterDecision_ConcurrencySchedulerInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_ConcurrencySchedulerInfoValidationError) Error 

func (e LimiterDecision_ConcurrencySchedulerInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_ConcurrencySchedulerInfoValidationError) ErrorName 

func (e LimiterDecision_ConcurrencySchedulerInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_ConcurrencySchedulerInfoValidationError) Field 

func (e LimiterDecision_ConcurrencySchedulerInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_ConcurrencySchedulerInfoValidationError) Key 

func (e LimiterDecision_ConcurrencySchedulerInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_ConcurrencySchedulerInfoValidationError) Reason 

func (e LimiterDecision_ConcurrencySchedulerInfoValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision_ConcurrencySchedulerInfo_ 

type LimiterDecision_ConcurrencySchedulerInfo_ struct {
	ConcurrencySchedulerInfo *LimiterDecision_ConcurrencySchedulerInfo `protobuf:"bytes,25,opt,name=concurrency_scheduler_info,json=concurrencySchedulerInfo,proto3,oneof"`
}

func (*LimiterDecision_ConcurrencySchedulerInfo_) MarshalToSizedBufferVT 

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

func (*LimiterDecision_ConcurrencySchedulerInfo_) MarshalToVT 

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

func (*LimiterDecision_ConcurrencySchedulerInfo_) SizeVT 

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

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,21,opt,name=load_scheduler_info,json=loadSchedulerInfo,proto3,oneof"`
}

func (*LimiterDecision_LoadSchedulerInfo) MarshalToSizedBufferVT 

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

func (*LimiterDecision_LoadSchedulerInfo) MarshalToVT 

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

func (*LimiterDecision_LoadSchedulerInfo) SizeVT 

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

type LimiterDecision_QuotaSchedulerInfo 

type LimiterDecision_QuotaSchedulerInfo struct {
	Label         string                      `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	WorkloadIndex string                      `protobuf:"bytes,2,opt,name=workload_index,json=workloadIndex,proto3" json:"workload_index,omitempty"`
	TokensInfo    *LimiterDecision_TokensInfo `protobuf:"bytes,3,opt,name=tokens_info,json=tokensInfo,proto3" json:"tokens_info,omitempty"`
	Priority      float64                     `protobuf:"fixed64,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*LimiterDecision_QuotaSchedulerInfo) Descriptor deprecated 

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

Deprecated: Use LimiterDecision_QuotaSchedulerInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_QuotaSchedulerInfo) GetLabel 

func (x *LimiterDecision_QuotaSchedulerInfo) GetLabel() string

func (*LimiterDecision_QuotaSchedulerInfo) GetPriority 

func (x *LimiterDecision_QuotaSchedulerInfo) GetPriority() float64

func (*LimiterDecision_QuotaSchedulerInfo) GetTokensInfo 

func (x *LimiterDecision_QuotaSchedulerInfo) GetTokensInfo() *LimiterDecision_TokensInfo

func (*LimiterDecision_QuotaSchedulerInfo) GetWorkloadIndex 

func (x *LimiterDecision_QuotaSchedulerInfo) GetWorkloadIndex() string

func (*LimiterDecision_QuotaSchedulerInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_QuotaSchedulerInfo) MarshalToSizedBufferVT 

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

func (*LimiterDecision_QuotaSchedulerInfo) MarshalToVT 

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

func (*LimiterDecision_QuotaSchedulerInfo) MarshalVT 

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

func (*LimiterDecision_QuotaSchedulerInfo) ProtoMessage 

func (*LimiterDecision_QuotaSchedulerInfo) ProtoMessage()

func (*LimiterDecision_QuotaSchedulerInfo) ProtoReflect 

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

func (*LimiterDecision_QuotaSchedulerInfo) Reset 

func (x *LimiterDecision_QuotaSchedulerInfo) Reset()

func (*LimiterDecision_QuotaSchedulerInfo) SizeVT 

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

func (*LimiterDecision_QuotaSchedulerInfo) String 

func (x *LimiterDecision_QuotaSchedulerInfo) String() string

func (*LimiterDecision_QuotaSchedulerInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_QuotaSchedulerInfo) UnmarshalVT 

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

func (*LimiterDecision_QuotaSchedulerInfo) Validate 

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 

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 

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 

func (m LimiterDecision_QuotaSchedulerInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_QuotaSchedulerInfoMultiError) Error 

func (m LimiterDecision_QuotaSchedulerInfoMultiError) Error() string

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

type LimiterDecision_QuotaSchedulerInfoValidationError 

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 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_QuotaSchedulerInfoValidationError) Error 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_QuotaSchedulerInfoValidationError) ErrorName 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_QuotaSchedulerInfoValidationError) Field 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_QuotaSchedulerInfoValidationError) Key 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_QuotaSchedulerInfoValidationError) Reason 

func (e LimiterDecision_QuotaSchedulerInfoValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision_QuotaSchedulerInfo_ 

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

func (*LimiterDecision_QuotaSchedulerInfo_) MarshalToSizedBufferVT 

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

func (*LimiterDecision_QuotaSchedulerInfo_) MarshalToVT 

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

func (*LimiterDecision_QuotaSchedulerInfo_) SizeVT 

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

type LimiterDecision_RateLimiterInfo 

type LimiterDecision_RateLimiterInfo struct {
	Label      string                      `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	TokensInfo *LimiterDecision_TokensInfo `protobuf:"bytes,2,opt,name=tokens_info,json=tokensInfo,proto3" json:"tokens_info,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) GetLabel 

func (x *LimiterDecision_RateLimiterInfo) GetLabel() string

func (*LimiterDecision_RateLimiterInfo) GetTokensInfo 

func (x *LimiterDecision_RateLimiterInfo) GetTokensInfo() *LimiterDecision_TokensInfo

func (*LimiterDecision_RateLimiterInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_RateLimiterInfo) MarshalToSizedBufferVT 

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

func (*LimiterDecision_RateLimiterInfo) MarshalToVT 

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

func (*LimiterDecision_RateLimiterInfo) MarshalVT 

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 

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 

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,20,opt,name=rate_limiter_info,json=rateLimiterInfo,proto3,oneof"`
}

func (*LimiterDecision_RateLimiterInfo_) MarshalToSizedBufferVT 

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

func (*LimiterDecision_RateLimiterInfo_) MarshalToVT 

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

func (*LimiterDecision_RateLimiterInfo_) SizeVT 

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

type LimiterDecision_SamplerInfo 

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 

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

Deprecated: Use LimiterDecision_SamplerInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_SamplerInfo) GetLabel 

func (x *LimiterDecision_SamplerInfo) GetLabel() string

func (*LimiterDecision_SamplerInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_SamplerInfo) MarshalToSizedBufferVT 

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

func (*LimiterDecision_SamplerInfo) MarshalToVT 

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

func (*LimiterDecision_SamplerInfo) MarshalVT 

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

func (*LimiterDecision_SamplerInfo) ProtoMessage 

func (*LimiterDecision_SamplerInfo) ProtoMessage()

func (*LimiterDecision_SamplerInfo) ProtoReflect 

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

func (*LimiterDecision_SamplerInfo) Reset 

func (x *LimiterDecision_SamplerInfo) Reset()

func (*LimiterDecision_SamplerInfo) SizeVT 

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

func (*LimiterDecision_SamplerInfo) String 

func (x *LimiterDecision_SamplerInfo) String() string

func (*LimiterDecision_SamplerInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_SamplerInfo) UnmarshalVT 

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

func (*LimiterDecision_SamplerInfo) Validate 

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 

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 

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 

func (m LimiterDecision_SamplerInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_SamplerInfoMultiError) Error 

func (m LimiterDecision_SamplerInfoMultiError) Error() string

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

type LimiterDecision_SamplerInfoValidationError 

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 

func (e LimiterDecision_SamplerInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_SamplerInfoValidationError) Error 

func (e LimiterDecision_SamplerInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_SamplerInfoValidationError) ErrorName 

func (e LimiterDecision_SamplerInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_SamplerInfoValidationError) Field 

func (e LimiterDecision_SamplerInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_SamplerInfoValidationError) Key 

func (e LimiterDecision_SamplerInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_SamplerInfoValidationError) Reason 

func (e LimiterDecision_SamplerInfoValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision_SamplerInfo_ 

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

func (*LimiterDecision_SamplerInfo_) MarshalToSizedBufferVT 

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

func (*LimiterDecision_SamplerInfo_) MarshalToVT 

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

func (*LimiterDecision_SamplerInfo_) SizeVT 

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

type LimiterDecision_SchedulerInfo 

type LimiterDecision_SchedulerInfo struct {
	WorkloadIndex string                      `protobuf:"bytes,1,opt,name=workload_index,json=workloadIndex,proto3" json:"workload_index,omitempty"`
	TokensInfo    *LimiterDecision_TokensInfo `protobuf:"bytes,2,opt,name=tokens_info,json=tokensInfo,proto3" json:"tokens_info,omitempty"`
	Priority      float64                     `protobuf:"fixed64,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func LimiterDecision_SchedulerInfoFromVTPool 

func LimiterDecision_SchedulerInfoFromVTPool() *LimiterDecision_SchedulerInfo

func (*LimiterDecision_SchedulerInfo) Descriptor deprecated 

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

Deprecated: Use LimiterDecision_SchedulerInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_SchedulerInfo) GetPriority 

func (x *LimiterDecision_SchedulerInfo) GetPriority() float64

func (*LimiterDecision_SchedulerInfo) GetTokensInfo 

func (x *LimiterDecision_SchedulerInfo) GetTokensInfo() *LimiterDecision_TokensInfo

func (*LimiterDecision_SchedulerInfo) GetWorkloadIndex 

func (x *LimiterDecision_SchedulerInfo) GetWorkloadIndex() string

func (*LimiterDecision_SchedulerInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_SchedulerInfo) MarshalToSizedBufferVT 

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

func (*LimiterDecision_SchedulerInfo) MarshalToVT 

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

func (*LimiterDecision_SchedulerInfo) MarshalVT 

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

func (*LimiterDecision_SchedulerInfo) ProtoMessage 

func (*LimiterDecision_SchedulerInfo) ProtoMessage()

func (*LimiterDecision_SchedulerInfo) ProtoReflect 

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

func (*LimiterDecision_SchedulerInfo) Reset 

func (x *LimiterDecision_SchedulerInfo) Reset()

func (*LimiterDecision_SchedulerInfo) ResetVT 

func (m *LimiterDecision_SchedulerInfo) ResetVT()

func (*LimiterDecision_SchedulerInfo) ReturnToVTPool 

func (m *LimiterDecision_SchedulerInfo) ReturnToVTPool()

func (*LimiterDecision_SchedulerInfo) SizeVT 

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

func (*LimiterDecision_SchedulerInfo) String 

func (x *LimiterDecision_SchedulerInfo) String() string

func (*LimiterDecision_SchedulerInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_SchedulerInfo) UnmarshalVT 

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

func (*LimiterDecision_SchedulerInfo) Validate 

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 

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 

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 

func (m LimiterDecision_SchedulerInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_SchedulerInfoMultiError) Error 

func (m LimiterDecision_SchedulerInfoMultiError) Error() string

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

type LimiterDecision_SchedulerInfoValidationError 

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 

func (e LimiterDecision_SchedulerInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_SchedulerInfoValidationError) Error 

func (e LimiterDecision_SchedulerInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_SchedulerInfoValidationError) ErrorName 

func (e LimiterDecision_SchedulerInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_SchedulerInfoValidationError) Field 

func (e LimiterDecision_SchedulerInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_SchedulerInfoValidationError) Key 

func (e LimiterDecision_SchedulerInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_SchedulerInfoValidationError) Reason 

func (e LimiterDecision_SchedulerInfoValidationError) Reason() string

Reason function returns reason value.

type LimiterDecision_TokensInfo 

type LimiterDecision_TokensInfo struct {

	// remaining and current may not
	// provide accurate values in case
	// the request times out while waiting
	// for tokens.
	Remaining float64 `protobuf:"fixed64,1,opt,name=remaining,proto3" json:"remaining,omitempty"`
	Current   float64 `protobuf:"fixed64,2,opt,name=current,proto3" json:"current,omitempty"`
	Consumed  float64 `protobuf:"fixed64,3,opt,name=consumed,proto3" json:"consumed,omitempty"`
	// contains filtered or unexported fields
}

func (*LimiterDecision_TokensInfo) Descriptor deprecated 

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

Deprecated: Use LimiterDecision_TokensInfo.ProtoReflect.Descriptor instead.

func (*LimiterDecision_TokensInfo) GetConsumed 

func (x *LimiterDecision_TokensInfo) GetConsumed() float64

func (*LimiterDecision_TokensInfo) GetCurrent 

func (x *LimiterDecision_TokensInfo) GetCurrent() float64

func (*LimiterDecision_TokensInfo) GetRemaining 

func (x *LimiterDecision_TokensInfo) GetRemaining() float64

func (*LimiterDecision_TokensInfo) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*LimiterDecision_TokensInfo) MarshalToSizedBufferVT 

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

func (*LimiterDecision_TokensInfo) MarshalToVT 

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

func (*LimiterDecision_TokensInfo) MarshalVT 

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

func (*LimiterDecision_TokensInfo) ProtoMessage 

func (*LimiterDecision_TokensInfo) ProtoMessage()

func (*LimiterDecision_TokensInfo) ProtoReflect 

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

func (*LimiterDecision_TokensInfo) Reset 

func (x *LimiterDecision_TokensInfo) Reset()

func (*LimiterDecision_TokensInfo) SizeVT 

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

func (*LimiterDecision_TokensInfo) String 

func (x *LimiterDecision_TokensInfo) String() string

func (*LimiterDecision_TokensInfo) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*LimiterDecision_TokensInfo) UnmarshalVT 

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

func (*LimiterDecision_TokensInfo) Validate 

func (m *LimiterDecision_TokensInfo) Validate() error

Validate checks the field values on LimiterDecision_TokensInfo 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_TokensInfo) ValidateAll 

func (m *LimiterDecision_TokensInfo) ValidateAll() error

ValidateAll checks the field values on LimiterDecision_TokensInfo 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_TokensInfoMultiError, or nil if none found.

type LimiterDecision_TokensInfoMultiError 

type LimiterDecision_TokensInfoMultiError []error

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

func (LimiterDecision_TokensInfoMultiError) AllErrors 

func (m LimiterDecision_TokensInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LimiterDecision_TokensInfoMultiError) Error 

func (m LimiterDecision_TokensInfoMultiError) Error() string

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

type LimiterDecision_TokensInfoValidationError 

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

LimiterDecision_TokensInfoValidationError is the validation error returned by LimiterDecision_TokensInfo.Validate if the designated constraints aren't met.

func (LimiterDecision_TokensInfoValidationError) Cause 

func (e LimiterDecision_TokensInfoValidationError) Cause() error

Cause function returns cause value.

func (LimiterDecision_TokensInfoValidationError) Error 

func (e LimiterDecision_TokensInfoValidationError) Error() string

Error satisfies the builtin error interface

func (LimiterDecision_TokensInfoValidationError) ErrorName 

func (e LimiterDecision_TokensInfoValidationError) ErrorName() string

ErrorName returns error name.

func (LimiterDecision_TokensInfoValidationError) Field 

func (e LimiterDecision_TokensInfoValidationError) Field() string

Field function returns field value.

func (LimiterDecision_TokensInfoValidationError) Key 

func (e LimiterDecision_TokensInfoValidationError) Key() bool

Key function returns key value.

func (LimiterDecision_TokensInfoValidationError) Reason 

func (e LimiterDecision_TokensInfoValidationError) Reason() string

Reason function returns reason value.

type StatusCode 

type StatusCode int32

HTTP response codes. For more details: https://www.iana.org/assignments/http-status-codes/http-status-codes.xhtml 

const (
	// Empty - This code not part of the HTTP status code specification, but it is needed for `enum` type.
	StatusCode_Empty                         StatusCode = 0
	StatusCode_Continue                      StatusCode = 100
	StatusCode_OK                            StatusCode = 200
	StatusCode_Created                       StatusCode = 201
	StatusCode_Accepted                      StatusCode = 202
	StatusCode_NonAuthoritativeInformation   StatusCode = 203
	StatusCode_NoContent                     StatusCode = 204
	StatusCode_ResetContent                  StatusCode = 205
	StatusCode_PartialContent                StatusCode = 206
	StatusCode_MultiStatus                   StatusCode = 207
	StatusCode_AlreadyReported               StatusCode = 208
	StatusCode_IMUsed                        StatusCode = 226
	StatusCode_MultipleChoices               StatusCode = 300
	StatusCode_MovedPermanently              StatusCode = 301
	StatusCode_Found                         StatusCode = 302
	StatusCode_SeeOther                      StatusCode = 303
	StatusCode_NotModified                   StatusCode = 304
	StatusCode_UseProxy                      StatusCode = 305
	StatusCode_TemporaryRedirect             StatusCode = 307
	StatusCode_PermanentRedirect             StatusCode = 308
	StatusCode_BadRequest                    StatusCode = 400
	StatusCode_Unauthorized                  StatusCode = 401
	StatusCode_PaymentRequired               StatusCode = 402
	StatusCode_Forbidden                     StatusCode = 403
	StatusCode_NotFound                      StatusCode = 404
	StatusCode_MethodNotAllowed              StatusCode = 405
	StatusCode_NotAcceptable                 StatusCode = 406
	StatusCode_ProxyAuthenticationRequired   StatusCode = 407
	StatusCode_RequestTimeout                StatusCode = 408
	StatusCode_Conflict                      StatusCode = 409
	StatusCode_Gone                          StatusCode = 410
	StatusCode_LengthRequired                StatusCode = 411
	StatusCode_PreconditionFailed            StatusCode = 412
	StatusCode_PayloadTooLarge               StatusCode = 413
	StatusCode_URITooLong                    StatusCode = 414
	StatusCode_UnsupportedMediaType          StatusCode = 415
	StatusCode_RangeNotSatisfiable           StatusCode = 416
	StatusCode_ExpectationFailed             StatusCode = 417
	StatusCode_MisdirectedRequest            StatusCode = 421
	StatusCode_UnprocessableEntity           StatusCode = 422
	StatusCode_Locked                        StatusCode = 423
	StatusCode_FailedDependency              StatusCode = 424
	StatusCode_UpgradeRequired               StatusCode = 426
	StatusCode_PreconditionRequired          StatusCode = 428
	StatusCode_TooManyRequests               StatusCode = 429
	StatusCode_RequestHeaderFieldsTooLarge   StatusCode = 431
	StatusCode_InternalServerError           StatusCode = 500
	StatusCode_NotImplemented                StatusCode = 501
	StatusCode_BadGateway                    StatusCode = 502
	StatusCode_ServiceUnavailable            StatusCode = 503
	StatusCode_GatewayTimeout                StatusCode = 504
	StatusCode_HTTPVersionNotSupported       StatusCode = 505
	StatusCode_VariantAlsoNegotiates         StatusCode = 506
	StatusCode_InsufficientStorage           StatusCode = 507
	StatusCode_LoopDetected                  StatusCode = 508
	StatusCode_NotExtended                   StatusCode = 510
	StatusCode_NetworkAuthenticationRequired StatusCode = 511
)

func (StatusCode) Descriptor 

func (StatusCode) Descriptor() protoreflect.EnumDescriptor

func (StatusCode) Enum 

func (x StatusCode) Enum() *StatusCode

func (StatusCode) EnumDescriptor deprecated 

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

Deprecated: Use StatusCode.Descriptor instead.

func (StatusCode) Number 

func (x StatusCode) Number() protoreflect.EnumNumber

func (StatusCode) String 

func (x StatusCode) String() string

func (StatusCode) Type 

func (StatusCode) Type() protoreflect.EnumType

type TokenReturnStatus 

type TokenReturnStatus struct {
	InflightRequestRef *InflightRequestRef `protobuf:"bytes,1,opt,name=inflight_request_ref,json=inflightRequestRef,proto3" json:"inflight_request_ref,omitempty"`
	Returned           bool                `protobuf:"varint,2,opt,name=returned,proto3" json:"returned,omitempty"`
	Error              string              `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenReturnStatus) Descriptor deprecated 

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

Deprecated: Use TokenReturnStatus.ProtoReflect.Descriptor instead.

func (*TokenReturnStatus) GetError 

func (x *TokenReturnStatus) GetError() string

func (*TokenReturnStatus) GetInflightRequestRef 

func (x *TokenReturnStatus) GetInflightRequestRef() *InflightRequestRef

func (*TokenReturnStatus) GetReturned 

func (x *TokenReturnStatus) GetReturned() bool

func (*TokenReturnStatus) MarshalJSON 

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

MarshalJSON implements json.Marshaler

func (*TokenReturnStatus) MarshalToSizedBufferVT 

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

func (*TokenReturnStatus) MarshalToVT 

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

func (*TokenReturnStatus) MarshalVT 

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

func (*TokenReturnStatus) ProtoMessage 

func (*TokenReturnStatus) ProtoMessage()

func (*TokenReturnStatus) ProtoReflect 

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

func (*TokenReturnStatus) Reset 

func (x *TokenReturnStatus) Reset()

func (*TokenReturnStatus) SizeVT 

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

func (*TokenReturnStatus) String 

func (x *TokenReturnStatus) String() string

func (*TokenReturnStatus) UnmarshalJSON 

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

UnmarshalJSON implements json.Unmarshaler

func (*TokenReturnStatus) UnmarshalVT 

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

func (*TokenReturnStatus) Validate 

func (m *TokenReturnStatus) Validate() error

Validate checks the field values on TokenReturnStatus 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 (*TokenReturnStatus) ValidateAll 

func (m *TokenReturnStatus) ValidateAll() error

ValidateAll checks the field values on TokenReturnStatus 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 TokenReturnStatusMultiError, or nil if none found.

type TokenReturnStatusMultiError 

type TokenReturnStatusMultiError []error

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

func (TokenReturnStatusMultiError) AllErrors 

func (m TokenReturnStatusMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TokenReturnStatusMultiError) Error 

func (m TokenReturnStatusMultiError) Error() string

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

type TokenReturnStatusValidationError 

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

TokenReturnStatusValidationError is the validation error returned by TokenReturnStatus.Validate if the designated constraints aren't met.

func (TokenReturnStatusValidationError) Cause 

func (e TokenReturnStatusValidationError) Cause() error

Cause function returns cause value.

func (TokenReturnStatusValidationError) Error 

func (e TokenReturnStatusValidationError) Error() string

Error satisfies the builtin error interface

func (TokenReturnStatusValidationError) ErrorName 

func (e TokenReturnStatusValidationError) ErrorName() string

ErrorName returns error name.

func (TokenReturnStatusValidationError) Field 

func (e TokenReturnStatusValidationError) Field() string

Field function returns field value.

func (TokenReturnStatusValidationError) Key 

func (e TokenReturnStatusValidationError) Key() bool

Key function returns key value.

func (TokenReturnStatusValidationError) Reason 

func (e TokenReturnStatusValidationError) Reason() string

Reason function returns reason value.

type UnimplementedFlowControlServiceServer 

type UnimplementedFlowControlServiceServer struct {
}

UnimplementedFlowControlServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedFlowControlServiceServer) CacheDelete 

func (UnimplementedFlowControlServiceServer) CacheDelete(context.Context, *CacheDeleteRequest) (*CacheDeleteResponse, error)

func (UnimplementedFlowControlServiceServer) CacheLookup 

func (UnimplementedFlowControlServiceServer) CacheLookup(context.Context, *CacheLookupRequest) (*CacheLookupResponse, error)

func (UnimplementedFlowControlServiceServer) CacheUpsert 

func (UnimplementedFlowControlServiceServer) CacheUpsert(context.Context, *CacheUpsertRequest) (*CacheUpsertResponse, error)

func (UnimplementedFlowControlServiceServer) Check 

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

func (UnimplementedFlowControlServiceServer) FlowEnd 

func (UnimplementedFlowControlServiceServer) FlowEnd(context.Context, *FlowEndRequest) (*FlowEndResponse, 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.