Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAuthServiceServer(s grpc.ServiceRegistrar, srv AuthServiceServer)
- func RegisterConfigServiceServer(s grpc.ServiceRegistrar, srv ConfigServiceServer)
- func RegisterHealthServiceServer(s grpc.ServiceRegistrar, srv HealthServiceServer)
- func RegisterQuotaServiceServer(s grpc.ServiceRegistrar, srv QuotaServiceServer)
- func RegisterUsageServiceServer(s grpc.ServiceRegistrar, srv UsageServiceServer)
- type AuthServiceClient
- type AuthServiceServer
- type BrowserConfig
- func (*BrowserConfig) Descriptor() ([]byte, []int)deprecated
- func (x *BrowserConfig) GetActionCodeDisabled() uint32
- func (x *BrowserConfig) GetActionCodeEnabled() uint32
- func (x *BrowserConfig) GetEnabledPercent() uint32
- func (x *BrowserConfig) GetMessageDisabled() string
- func (x *BrowserConfig) GetMessageEnabled() string
- func (*BrowserConfig) ProtoMessage()
- func (x *BrowserConfig) ProtoReflect() protoreflect.Message
- func (x *BrowserConfig) Reset()
- func (x *BrowserConfig) String() string
- type ConfigServiceClient
- type ConfigServiceServer
- type FeatureConfig
- func (*FeatureConfig) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureConfig) GetConfig() *BrowserConfig
- func (x *FeatureConfig) GetName() string
- func (*FeatureConfig) ProtoMessage()
- func (x *FeatureConfig) ProtoReflect() protoreflect.Message
- func (x *FeatureConfig) Reset()
- func (x *FeatureConfig) String() string
- type FeatureSelector
- func (*FeatureSelector) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureSelector) GetEnvironment() string
- func (x *FeatureSelector) GetNames() []string
- func (x *FeatureSelector) GetTags() []*Tag
- func (*FeatureSelector) ProtoMessage()
- func (x *FeatureSelector) ProtoReflect() protoreflect.Message
- func (x *FeatureSelector) Reset()
- func (x *FeatureSelector) String() string
- type GetBearerTokenRequest
- type GetBearerTokenResponse
- func (*GetBearerTokenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetBearerTokenResponse) GetBearerToken() string
- func (*GetBearerTokenResponse) ProtoMessage()
- func (x *GetBearerTokenResponse) ProtoReflect() protoreflect.Message
- func (x *GetBearerTokenResponse) Reset()
- func (x *GetBearerTokenResponse) String() string
- type GetBrowserContextRequest
- func (*GetBrowserContextRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetBrowserContextRequest) GetFeature() *FeatureSelector
- func (*GetBrowserContextRequest) ProtoMessage()
- func (x *GetBrowserContextRequest) ProtoReflect() protoreflect.Message
- func (x *GetBrowserContextRequest) Reset()
- func (x *GetBrowserContextRequest) String() string
- type GetBrowserContextResponse
- func (*GetBrowserContextResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetBrowserContextResponse) GetFeatureConfigs() []*FeatureConfig
- func (*GetBrowserContextResponse) ProtoMessage()
- func (x *GetBrowserContextResponse) ProtoReflect() protoreflect.Message
- func (x *GetBrowserContextResponse) Reset()
- func (x *GetBrowserContextResponse) String() string
- type GetGuardConfigRequest
- func (*GetGuardConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetGuardConfigRequest) GetSelector() *GuardServiceSelector
- func (x *GetGuardConfigRequest) GetVersionSeen() string
- func (*GetGuardConfigRequest) ProtoMessage()
- func (x *GetGuardConfigRequest) ProtoReflect() protoreflect.Message
- func (x *GetGuardConfigRequest) Reset()
- func (x *GetGuardConfigRequest) String() string
- type GetGuardConfigResponse
- func (*GetGuardConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetGuardConfigResponse) GetConfig() *GuardConfig
- func (x *GetGuardConfigResponse) GetConfigDataSent() bool
- func (x *GetGuardConfigResponse) GetVersion() string
- func (*GetGuardConfigResponse) ProtoMessage()
- func (x *GetGuardConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetGuardConfigResponse) Reset()
- func (x *GetGuardConfigResponse) String() string
- type GetServiceConfigRequest
- func (*GetServiceConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetServiceConfigRequest) GetClientId() string
- func (x *GetServiceConfigRequest) GetService() *ServiceSelector
- func (x *GetServiceConfigRequest) GetVersionSeen() string
- func (*GetServiceConfigRequest) ProtoMessage()
- func (x *GetServiceConfigRequest) ProtoReflect() protoreflect.Message
- func (x *GetServiceConfigRequest) Reset()
- func (x *GetServiceConfigRequest) String() string
- type GetServiceConfigResponse
- func (*GetServiceConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetServiceConfigResponse) GetConfig() *ServiceConfig
- func (x *GetServiceConfigResponse) GetConfigDataSent() bool
- func (x *GetServiceConfigResponse) GetVersion() string
- func (*GetServiceConfigResponse) ProtoMessage()
- func (x *GetServiceConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetServiceConfigResponse) Reset()
- func (x *GetServiceConfigResponse) String() string
- type GetTokenLeaseRequest
- func (*GetTokenLeaseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTokenLeaseRequest) GetClientId() string
- func (x *GetTokenLeaseRequest) GetDefaultWeight() float32
- func (x *GetTokenLeaseRequest) GetPriorityBoost() int32
- func (x *GetTokenLeaseRequest) GetSelector() *GuardFeatureSelector
- func (*GetTokenLeaseRequest) ProtoMessage()
- func (x *GetTokenLeaseRequest) ProtoReflect() protoreflect.Message
- func (x *GetTokenLeaseRequest) Reset()
- func (x *GetTokenLeaseRequest) String() string
- type GetTokenLeaseResponse
- func (*GetTokenLeaseResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTokenLeaseResponse) GetGranted() bool
- func (x *GetTokenLeaseResponse) GetLeases() []*TokenLease
- func (*GetTokenLeaseResponse) ProtoMessage()
- func (x *GetTokenLeaseResponse) ProtoReflect() protoreflect.Message
- func (x *GetTokenLeaseResponse) Reset()
- func (x *GetTokenLeaseResponse) String() string
- type GetTokenRequest
- func (*GetTokenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTokenRequest) GetClientId() string
- func (x *GetTokenRequest) GetPriorityBoost() int32
- func (x *GetTokenRequest) GetSelector() *GuardFeatureSelector
- func (x *GetTokenRequest) GetWeight() float32
- func (*GetTokenRequest) ProtoMessage()
- func (x *GetTokenRequest) ProtoReflect() protoreflect.Message
- func (x *GetTokenRequest) Reset()
- func (x *GetTokenRequest) String() string
- type GetTokenResponse
- func (*GetTokenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTokenResponse) GetGranted() bool
- func (x *GetTokenResponse) GetReason() Reason
- func (x *GetTokenResponse) GetToken() string
- func (*GetTokenResponse) ProtoMessage()
- func (x *GetTokenResponse) ProtoReflect() protoreflect.Message
- func (x *GetTokenResponse) Reset()
- func (x *GetTokenResponse) String() string
- type GetUsageRequest
- func (*GetUsageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetUsageRequest) GetApikey() string
- func (x *GetUsageRequest) GetEndTs() *timestamppb.Timestamp
- func (x *GetUsageRequest) GetEnvironment() string
- func (x *GetUsageRequest) GetFeature() string
- func (x *GetUsageRequest) GetFeatureQueryMode() QueryMode
- func (x *GetUsageRequest) GetGuard() string
- func (x *GetUsageRequest) GetGuardQueryMode() QueryMode
- func (x *GetUsageRequest) GetPriority() int32
- func (x *GetUsageRequest) GetPriorityQueryMode() QueryMode
- func (x *GetUsageRequest) GetReportAllTags() bool
- func (x *GetUsageRequest) GetReportTags() []string
- func (x *GetUsageRequest) GetStartTs() *timestamppb.Timestamp
- func (x *GetUsageRequest) GetStep() string
- func (x *GetUsageRequest) GetTags() []*Tag
- func (*GetUsageRequest) ProtoMessage()
- func (x *GetUsageRequest) ProtoReflect() protoreflect.Message
- func (x *GetUsageRequest) Reset()
- func (x *GetUsageRequest) String() string
- type GetUsageResponse
- func (*GetUsageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetUsageResponse) GetResult() []*UsageTimeseries
- func (*GetUsageResponse) ProtoMessage()
- func (x *GetUsageResponse) ProtoReflect() protoreflect.Message
- func (x *GetUsageResponse) Reset()
- func (x *GetUsageResponse) String() string
- type GuardConfig
- func (*GuardConfig) Descriptor() ([]byte, []int)deprecated
- func (x *GuardConfig) GetCheckQuota() bool
- func (x *GuardConfig) GetQuotaTags() []string
- func (x *GuardConfig) GetValidateIngressTokens() bool
- func (*GuardConfig) ProtoMessage()
- func (x *GuardConfig) ProtoReflect() protoreflect.Message
- func (x *GuardConfig) Reset()
- func (x *GuardConfig) String() string
- type GuardFeatureSelector
- func (*GuardFeatureSelector) Descriptor() ([]byte, []int)deprecated
- func (x *GuardFeatureSelector) GetEnvironment() string
- func (x *GuardFeatureSelector) GetFeatureName() string
- func (x *GuardFeatureSelector) GetGuardName() string
- func (x *GuardFeatureSelector) GetTags() []*Tag
- func (*GuardFeatureSelector) ProtoMessage()
- func (x *GuardFeatureSelector) ProtoReflect() protoreflect.Message
- func (x *GuardFeatureSelector) Reset()
- func (x *GuardFeatureSelector) String() string
- type GuardSelector
- func (*GuardSelector) Descriptor() ([]byte, []int)deprecated
- func (x *GuardSelector) GetEnvironment() string
- func (x *GuardSelector) GetName() string
- func (x *GuardSelector) GetTags() []*Tag
- func (*GuardSelector) ProtoMessage()
- func (x *GuardSelector) ProtoReflect() protoreflect.Message
- func (x *GuardSelector) Reset()
- func (x *GuardSelector) String() string
- type GuardServiceSelector
- func (*GuardServiceSelector) Descriptor() ([]byte, []int)deprecated
- func (x *GuardServiceSelector) GetEnvironment() string
- func (x *GuardServiceSelector) GetGuardName() string
- func (x *GuardServiceSelector) GetServiceName() string
- func (x *GuardServiceSelector) GetServiceRelease() string
- func (x *GuardServiceSelector) GetTags() []*Tag
- func (*GuardServiceSelector) ProtoMessage()
- func (x *GuardServiceSelector) ProtoReflect() protoreflect.Message
- func (x *GuardServiceSelector) Reset()
- func (x *GuardServiceSelector) String() string
- type HeaderTraceConfig
- func (*HeaderTraceConfig) Descriptor() ([]byte, []int)deprecated
- func (x *HeaderTraceConfig) GetRequestHeaderNames() []string
- func (x *HeaderTraceConfig) GetResponseHeaderNames() []string
- func (x *HeaderTraceConfig) GetSpanSelectors() []*SpanSelector
- func (*HeaderTraceConfig) ProtoMessage()
- func (x *HeaderTraceConfig) ProtoReflect() protoreflect.Message
- func (x *HeaderTraceConfig) Reset()
- func (x *HeaderTraceConfig) String() string
- type Health
- type HealthByPriority
- func (*HealthByPriority) Descriptor() ([]byte, []int)deprecated
- func (x *HealthByPriority) GetHealth() Health
- func (x *HealthByPriority) GetPriority() uint32
- func (*HealthByPriority) ProtoMessage()
- func (x *HealthByPriority) ProtoReflect() protoreflect.Message
- func (x *HealthByPriority) Reset()
- func (x *HealthByPriority) String() string
- type HealthServiceClient
- type HealthServiceServer
- type MetricConfig
- type ParamTraceConfig
- func (*ParamTraceConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ParamTraceConfig) GetParameterNames() []string
- func (x *ParamTraceConfig) GetSpanSelectors() []*SpanSelector
- func (*ParamTraceConfig) ProtoMessage()
- func (x *ParamTraceConfig) ProtoReflect() protoreflect.Message
- func (x *ParamTraceConfig) Reset()
- func (x *ParamTraceConfig) String() string
- type QueryGuardHealthRequest
- func (*QueryGuardHealthRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryGuardHealthRequest) GetPriorityBoost() int32
- func (x *QueryGuardHealthRequest) GetSelector() *GuardFeatureSelector
- func (*QueryGuardHealthRequest) ProtoMessage()
- func (x *QueryGuardHealthRequest) ProtoReflect() protoreflect.Message
- func (x *QueryGuardHealthRequest) Reset()
- func (x *QueryGuardHealthRequest) String() string
- type QueryGuardHealthResponse
- func (*QueryGuardHealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryGuardHealthResponse) GetHealth() Health
- func (*QueryGuardHealthResponse) ProtoMessage()
- func (x *QueryGuardHealthResponse) ProtoReflect() protoreflect.Message
- func (x *QueryGuardHealthResponse) Reset()
- func (x *QueryGuardHealthResponse) String() string
- type QueryMode
- type QuotaServiceClient
- type QuotaServiceServer
- type Reason
- type SentinelConfig
- func (*SentinelConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SentinelConfig) GetCircuitbreakerRulesJson() string
- func (x *SentinelConfig) GetFlowRulesJson() string
- func (x *SentinelConfig) GetIsolationRulesJson() string
- func (x *SentinelConfig) GetSystemRulesJson() string
- func (*SentinelConfig) ProtoMessage()
- func (x *SentinelConfig) ProtoReflect() protoreflect.Message
- func (x *SentinelConfig) Reset()
- func (x *SentinelConfig) String() string
- type ServiceConfig
- func (*ServiceConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceConfig) GetCustomerId() string
- func (x *ServiceConfig) GetMetricConfig() *MetricConfig
- func (x *ServiceConfig) GetSentinelConfig() *SentinelConfig
- func (x *ServiceConfig) GetTraceConfig() *TraceConfig
- func (*ServiceConfig) ProtoMessage()
- func (x *ServiceConfig) ProtoReflect() protoreflect.Message
- func (x *ServiceConfig) Reset()
- func (x *ServiceConfig) String() string
- type ServiceSelector
- func (*ServiceSelector) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceSelector) GetEnvironment() string
- func (x *ServiceSelector) GetName() string
- func (x *ServiceSelector) GetRelease() string
- func (x *ServiceSelector) GetTags() []*Tag
- func (*ServiceSelector) ProtoMessage()
- func (x *ServiceSelector) ProtoReflect() protoreflect.Message
- func (x *ServiceSelector) Reset()
- func (x *ServiceSelector) String() string
- type SetTokenLeaseConsumedRequest
- func (*SetTokenLeaseConsumedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetTokenLeaseConsumedRequest) GetTokens() []string
- func (x *SetTokenLeaseConsumedRequest) GetWeightCorrection() float32
- func (*SetTokenLeaseConsumedRequest) ProtoMessage()
- func (x *SetTokenLeaseConsumedRequest) ProtoReflect() protoreflect.Message
- func (x *SetTokenLeaseConsumedRequest) Reset()
- func (x *SetTokenLeaseConsumedRequest) String() string
- type SetTokenLeaseConsumedResponse
- func (*SetTokenLeaseConsumedResponse) Descriptor() ([]byte, []int)deprecated
- func (*SetTokenLeaseConsumedResponse) ProtoMessage()
- func (x *SetTokenLeaseConsumedResponse) ProtoReflect() protoreflect.Message
- func (x *SetTokenLeaseConsumedResponse) Reset()
- func (x *SetTokenLeaseConsumedResponse) String() string
- type SpanSelector
- func (*SpanSelector) Descriptor() ([]byte, []int)deprecated
- func (x *SpanSelector) GetOtelAttribute() string
- func (x *SpanSelector) GetValue() string
- func (*SpanSelector) ProtoMessage()
- func (x *SpanSelector) ProtoReflect() protoreflect.Message
- func (x *SpanSelector) Reset()
- func (x *SpanSelector) String() string
- type State
- type Tag
- type TokenInfo
- type TokenLease
- func (*TokenLease) Descriptor() ([]byte, []int)deprecated
- func (x *TokenLease) GetDurationMsec() int32
- func (x *TokenLease) GetExpiresAt() *timestamppb.Timestamp
- func (x *TokenLease) GetFeature() string
- func (x *TokenLease) GetPriorityBoost() int32
- func (x *TokenLease) GetReason() Reason
- func (x *TokenLease) GetToken() string
- func (x *TokenLease) GetWeight() float32
- func (*TokenLease) ProtoMessage()
- func (x *TokenLease) ProtoReflect() protoreflect.Message
- func (x *TokenLease) Reset()
- func (x *TokenLease) String() string
- type TokenValid
- type TraceConfig
- func (*TraceConfig) Descriptor() ([]byte, []int)deprecated
- func (x *TraceConfig) GetCollectorUrl() string
- func (x *TraceConfig) GetHeaderSampleConfigs() []*HeaderTraceConfig
- func (x *TraceConfig) GetOverrides() []*TraceConfigOverride
- func (x *TraceConfig) GetParamSampleConfigs() []*ParamTraceConfig
- func (x *TraceConfig) GetSampleRateDefault() float32
- func (*TraceConfig) ProtoMessage()
- func (x *TraceConfig) ProtoReflect() protoreflect.Message
- func (x *TraceConfig) Reset()
- func (x *TraceConfig) String() string
- type TraceConfigOverride
- func (*TraceConfigOverride) Descriptor() ([]byte, []int)deprecated
- func (x *TraceConfigOverride) GetSampleRate() float32
- func (x *TraceConfigOverride) GetSpanSelectors() []*SpanSelector
- func (*TraceConfigOverride) ProtoMessage()
- func (x *TraceConfigOverride) ProtoReflect() protoreflect.Message
- func (x *TraceConfigOverride) Reset()
- func (x *TraceConfigOverride) String() string
- type UnimplementedAuthServiceServer
- type UnimplementedConfigServiceServer
- func (UnimplementedConfigServiceServer) GetBrowserContext(context.Context, *GetBrowserContextRequest) (*GetBrowserContextResponse, error)
- func (UnimplementedConfigServiceServer) GetGuardConfig(context.Context, *GetGuardConfigRequest) (*GetGuardConfigResponse, error)
- func (UnimplementedConfigServiceServer) GetServiceConfig(context.Context, *GetServiceConfigRequest) (*GetServiceConfigResponse, error)
- type UnimplementedHealthServiceServer
- type UnimplementedQuotaServiceServer
- func (UnimplementedQuotaServiceServer) GetToken(context.Context, *GetTokenRequest) (*GetTokenResponse, error)
- func (UnimplementedQuotaServiceServer) GetTokenLease(context.Context, *GetTokenLeaseRequest) (*GetTokenLeaseResponse, error)
- func (UnimplementedQuotaServiceServer) SetTokenLeaseConsumed(context.Context, *SetTokenLeaseConsumedRequest) (*SetTokenLeaseConsumedResponse, error)
- func (UnimplementedQuotaServiceServer) ValidateToken(context.Context, *ValidateTokenRequest) (*ValidateTokenResponse, error)
- type UnimplementedUsageServiceServer
- type UnsafeAuthServiceServer
- type UnsafeConfigServiceServer
- type UnsafeHealthServiceServer
- type UnsafeQuotaServiceServer
- type UnsafeUsageServiceServer
- type UsageServiceClient
- type UsageServiceServer
- type UsageTSDataPoint
- func (*UsageTSDataPoint) Descriptor() ([]byte, []int)deprecated
- func (x *UsageTSDataPoint) GetBeBurst() int32
- func (x *UsageTSDataPoint) GetBeBurstWeight() float32
- func (x *UsageTSDataPoint) GetEndTs() *timestamppb.Timestamp
- func (x *UsageTSDataPoint) GetGranted() int32
- func (x *UsageTSDataPoint) GetGrantedWeight() float32
- func (x *UsageTSDataPoint) GetNotGranted() int32
- func (x *UsageTSDataPoint) GetNotGrantedWeight() float32
- func (x *UsageTSDataPoint) GetParentReject() int32
- func (x *UsageTSDataPoint) GetParentRejectWeight() float32
- func (x *UsageTSDataPoint) GetStartTs() *timestamppb.Timestamp
- func (*UsageTSDataPoint) ProtoMessage()
- func (x *UsageTSDataPoint) ProtoReflect() protoreflect.Message
- func (x *UsageTSDataPoint) Reset()
- func (x *UsageTSDataPoint) String() string
- type UsageTimeseries
- func (*UsageTimeseries) Descriptor() ([]byte, []int)deprecated
- func (x *UsageTimeseries) GetData() []*UsageTSDataPoint
- func (x *UsageTimeseries) GetFeature() string
- func (x *UsageTimeseries) GetGuard() string
- func (x *UsageTimeseries) GetPriority() int32
- func (x *UsageTimeseries) GetTags() []*Tag
- func (*UsageTimeseries) ProtoMessage()
- func (x *UsageTimeseries) ProtoReflect() protoreflect.Message
- func (x *UsageTimeseries) Reset()
- func (x *UsageTimeseries) String() string
- type ValidateTokenRequest
- func (*ValidateTokenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateTokenRequest) GetTokens() []*TokenInfo
- func (*ValidateTokenRequest) ProtoMessage()
- func (x *ValidateTokenRequest) ProtoReflect() protoreflect.Message
- func (x *ValidateTokenRequest) Reset()
- func (x *ValidateTokenRequest) String() string
- type ValidateTokenResponse
- func (*ValidateTokenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateTokenResponse) GetTokensValid() []*TokenValid
- func (x *ValidateTokenResponse) GetValid() bool
- func (*ValidateTokenResponse) ProtoMessage()
- func (x *ValidateTokenResponse) ProtoReflect() protoreflect.Message
- func (x *ValidateTokenResponse) Reset()
- func (x *ValidateTokenResponse) String() string
Constants ¶
const ( ConfigService_GetGuardConfig_FullMethodName = "/stanza.hub.v1.ConfigService/GetGuardConfig" ConfigService_GetBrowserContext_FullMethodName = "/stanza.hub.v1.ConfigService/GetBrowserContext" ConfigService_GetServiceConfig_FullMethodName = "/stanza.hub.v1.ConfigService/GetServiceConfig" )
const ( QuotaService_GetToken_FullMethodName = "/stanza.hub.v1.QuotaService/GetToken" QuotaService_GetTokenLease_FullMethodName = "/stanza.hub.v1.QuotaService/GetTokenLease" QuotaService_SetTokenLeaseConsumed_FullMethodName = "/stanza.hub.v1.QuotaService/SetTokenLeaseConsumed" QuotaService_ValidateToken_FullMethodName = "/stanza.hub.v1.QuotaService/ValidateToken" )
const (
AuthService_GetBearerToken_FullMethodName = "/stanza.hub.v1.AuthService/GetBearerToken"
)
const (
HealthService_QueryGuardHealth_FullMethodName = "/stanza.hub.v1.HealthService/QueryGuardHealth"
)
const (
UsageService_GetUsage_FullMethodName = "/stanza.hub.v1.UsageService/GetUsage"
)
Variables ¶
var ( Health_name = map[int32]string{ 0: "HEALTH_UNSPECIFIED", 1: "HEALTH_OK", 2: "HEALTH_OVERLOAD", 3: "HEALTH_DOWN", } Health_value = map[string]int32{ "HEALTH_UNSPECIFIED": 0, "HEALTH_OK": 1, "HEALTH_OVERLOAD": 2, "HEALTH_DOWN": 3, } )
Enum value maps for Health.
var ( State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "STATE_ENABLED", 2: "STATE_DISABLED", } State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "STATE_ENABLED": 1, "STATE_DISABLED": 2, } )
Enum value maps for State.
var ( Reason_name = map[int32]string{ 0: "REASON_UNSPECIFIED", 1: "REASON_SUFFICIENT_QUOTA", 2: "REASON_INSUFFICIENT_QUOTA", 3: "REASON_INSUFFICIENT_QUOTA_PARENT", 4: "REASON_BURST", 5: "REASON_BEST_EFFORT", } Reason_value = map[string]int32{ "REASON_UNSPECIFIED": 0, "REASON_SUFFICIENT_QUOTA": 1, "REASON_INSUFFICIENT_QUOTA": 2, "REASON_INSUFFICIENT_QUOTA_PARENT": 3, "REASON_BURST": 4, "REASON_BEST_EFFORT": 5, } )
Enum value maps for Reason.
var ( QueryMode_name = map[int32]string{ 0: "QUERY_MODE_UNSPECIFIED", 1: "QUERY_MODE_SUM", 2: "QUERY_MODE_REPORT", } QueryMode_value = map[string]int32{ "QUERY_MODE_UNSPECIFIED": 0, "QUERY_MODE_SUM": 1, "QUERY_MODE_REPORT": 2, } )
Enum value maps for QueryMode.
var AuthService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stanza.hub.v1.AuthService", HandlerType: (*AuthServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetBearerToken", Handler: _AuthService_GetBearerToken_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stanza/hub/v1/auth.proto", }
AuthService_ServiceDesc is the grpc.ServiceDesc for AuthService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ConfigService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stanza.hub.v1.ConfigService", HandlerType: (*ConfigServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetGuardConfig", Handler: _ConfigService_GetGuardConfig_Handler, }, { MethodName: "GetBrowserContext", Handler: _ConfigService_GetBrowserContext_Handler, }, { MethodName: "GetServiceConfig", Handler: _ConfigService_GetServiceConfig_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stanza/hub/v1/config.proto", }
ConfigService_ServiceDesc is the grpc.ServiceDesc for ConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_stanza_hub_v1_auth_proto protoreflect.FileDescriptor
var File_stanza_hub_v1_common_proto protoreflect.FileDescriptor
var File_stanza_hub_v1_config_proto protoreflect.FileDescriptor
var File_stanza_hub_v1_health_proto protoreflect.FileDescriptor
var File_stanza_hub_v1_quota_proto protoreflect.FileDescriptor
var File_stanza_hub_v1_usage_proto protoreflect.FileDescriptor
var HealthService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stanza.hub.v1.HealthService", HandlerType: (*HealthServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "QueryGuardHealth", Handler: _HealthService_QueryGuardHealth_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stanza/hub/v1/health.proto", }
HealthService_ServiceDesc is the grpc.ServiceDesc for HealthService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var QuotaService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stanza.hub.v1.QuotaService", HandlerType: (*QuotaServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetToken", Handler: _QuotaService_GetToken_Handler, }, { MethodName: "GetTokenLease", Handler: _QuotaService_GetTokenLease_Handler, }, { MethodName: "SetTokenLeaseConsumed", Handler: _QuotaService_SetTokenLeaseConsumed_Handler, }, { MethodName: "ValidateToken", Handler: _QuotaService_ValidateToken_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stanza/hub/v1/quota.proto", }
QuotaService_ServiceDesc is the grpc.ServiceDesc for QuotaService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var UsageService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stanza.hub.v1.UsageService", HandlerType: (*UsageServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetUsage", Handler: _UsageService_GetUsage_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "stanza/hub/v1/usage.proto", }
UsageService_ServiceDesc is the grpc.ServiceDesc for UsageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAuthServiceServer ¶
func RegisterAuthServiceServer(s grpc.ServiceRegistrar, srv AuthServiceServer)
func RegisterConfigServiceServer ¶
func RegisterConfigServiceServer(s grpc.ServiceRegistrar, srv ConfigServiceServer)
func RegisterHealthServiceServer ¶
func RegisterHealthServiceServer(s grpc.ServiceRegistrar, srv HealthServiceServer)
func RegisterQuotaServiceServer ¶
func RegisterQuotaServiceServer(s grpc.ServiceRegistrar, srv QuotaServiceServer)
func RegisterUsageServiceServer ¶
func RegisterUsageServiceServer(s grpc.ServiceRegistrar, srv UsageServiceServer)
Types ¶
type AuthServiceClient ¶
type AuthServiceClient interface {
GetBearerToken(ctx context.Context, in *GetBearerTokenRequest, opts ...grpc.CallOption) (*GetBearerTokenResponse, error)
}
AuthServiceClient is the client API for AuthService 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 NewAuthServiceClient ¶
func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient
type AuthServiceServer ¶
type AuthServiceServer interface {
GetBearerToken(context.Context, *GetBearerTokenRequest) (*GetBearerTokenResponse, error)
// contains filtered or unexported methods
}
AuthServiceServer is the server API for AuthService service. All implementations must embed UnimplementedAuthServiceServer for forward compatibility
type BrowserConfig ¶
type BrowserConfig struct {
EnabledPercent *uint32 `protobuf:"varint,2,opt,name=enabled_percent,json=enabledPercent,proto3,oneof" json:"enabled_percent,omitempty"`
ActionCodeEnabled *uint32 `protobuf:"varint,3,opt,name=action_code_enabled,json=actionCodeEnabled,proto3,oneof" json:"action_code_enabled,omitempty"`
MessageEnabled *string `protobuf:"bytes,4,opt,name=message_enabled,json=messageEnabled,proto3,oneof" json:"message_enabled,omitempty"`
ActionCodeDisabled *uint32 `protobuf:"varint,5,opt,name=action_code_disabled,json=actionCodeDisabled,proto3,oneof" json:"action_code_disabled,omitempty"`
MessageDisabled *string `protobuf:"bytes,6,opt,name=message_disabled,json=messageDisabled,proto3,oneof" json:"message_disabled,omitempty"`
// contains filtered or unexported fields
}
BrowserConfig describes the current configuration for one Feature. Instead of being simply enabled or disabled, features are enabled for a particular percentage of clients (0% is entirely disabled, 100% is entirely enabled). Clients are required to self-select a percentile value from 1 to 100 in a way that is random and trusted to consider a Feature disabled if it is disabled for the selected percentile. action_code_disabled describes what the Browser is expected to do if the Feature is not enabled for their assigned percentile. message_disabled may be displayed as a fallback action. action_code_enabled describes what the Browser is expected to do if the Feature is enabled for their assigned percentile. This enabled degraded modes. Can be empty. message_enabled may be displayed while in degraded mode. Can be empty. Likely additional fields will be added here as the Browser SDK behavior set becomes more complex.
func (*BrowserConfig) Descriptor
deprecated
func (*BrowserConfig) Descriptor() ([]byte, []int)
Deprecated: Use BrowserConfig.ProtoReflect.Descriptor instead.
func (*BrowserConfig) GetActionCodeDisabled ¶
func (x *BrowserConfig) GetActionCodeDisabled() uint32
func (*BrowserConfig) GetActionCodeEnabled ¶
func (x *BrowserConfig) GetActionCodeEnabled() uint32
func (*BrowserConfig) GetEnabledPercent ¶
func (x *BrowserConfig) GetEnabledPercent() uint32
func (*BrowserConfig) GetMessageDisabled ¶
func (x *BrowserConfig) GetMessageDisabled() string
func (*BrowserConfig) GetMessageEnabled ¶
func (x *BrowserConfig) GetMessageEnabled() string
func (*BrowserConfig) ProtoMessage ¶
func (*BrowserConfig) ProtoMessage()
func (*BrowserConfig) ProtoReflect ¶
func (x *BrowserConfig) ProtoReflect() protoreflect.Message
func (*BrowserConfig) Reset ¶
func (x *BrowserConfig) Reset()
func (*BrowserConfig) String ¶
func (x *BrowserConfig) String() string
type ConfigServiceClient ¶
type ConfigServiceClient interface {
GetGuardConfig(ctx context.Context, in *GetGuardConfigRequest, opts ...grpc.CallOption) (*GetGuardConfigResponse, error)
GetBrowserContext(ctx context.Context, in *GetBrowserContextRequest, opts ...grpc.CallOption) (*GetBrowserContextResponse, error)
GetServiceConfig(ctx context.Context, in *GetServiceConfigRequest, opts ...grpc.CallOption) (*GetServiceConfigResponse, error)
}
ConfigServiceClient is the client API for ConfigService 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 NewConfigServiceClient ¶
func NewConfigServiceClient(cc grpc.ClientConnInterface) ConfigServiceClient
type ConfigServiceServer ¶
type ConfigServiceServer interface {
GetGuardConfig(context.Context, *GetGuardConfigRequest) (*GetGuardConfigResponse, error)
GetBrowserContext(context.Context, *GetBrowserContextRequest) (*GetBrowserContextResponse, error)
GetServiceConfig(context.Context, *GetServiceConfigRequest) (*GetServiceConfigResponse, error)
// contains filtered or unexported methods
}
ConfigServiceServer is the server API for ConfigService service. All implementations must embed UnimplementedConfigServiceServer for forward compatibility
type FeatureConfig ¶
type FeatureConfig struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Config *BrowserConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*FeatureConfig) Descriptor
deprecated
func (*FeatureConfig) Descriptor() ([]byte, []int)
Deprecated: Use FeatureConfig.ProtoReflect.Descriptor instead.
func (*FeatureConfig) GetConfig ¶
func (x *FeatureConfig) GetConfig() *BrowserConfig
func (*FeatureConfig) GetName ¶
func (x *FeatureConfig) GetName() string
func (*FeatureConfig) ProtoMessage ¶
func (*FeatureConfig) ProtoMessage()
func (*FeatureConfig) ProtoReflect ¶
func (x *FeatureConfig) ProtoReflect() protoreflect.Message
func (*FeatureConfig) Reset ¶
func (x *FeatureConfig) Reset()
func (*FeatureConfig) String ¶
func (x *FeatureConfig) String() string
type FeatureSelector ¶
type FeatureSelector struct {
Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
Names []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
Tags []*Tag `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
// contains filtered or unexported fields
}
func (*FeatureSelector) Descriptor
deprecated
func (*FeatureSelector) Descriptor() ([]byte, []int)
Deprecated: Use FeatureSelector.ProtoReflect.Descriptor instead.
func (*FeatureSelector) GetEnvironment ¶
func (x *FeatureSelector) GetEnvironment() string
func (*FeatureSelector) GetNames ¶
func (x *FeatureSelector) GetNames() []string
func (*FeatureSelector) GetTags ¶
func (x *FeatureSelector) GetTags() []*Tag
func (*FeatureSelector) ProtoMessage ¶
func (*FeatureSelector) ProtoMessage()
func (*FeatureSelector) ProtoReflect ¶
func (x *FeatureSelector) ProtoReflect() protoreflect.Message
func (*FeatureSelector) Reset ¶
func (x *FeatureSelector) Reset()
func (*FeatureSelector) String ¶
func (x *FeatureSelector) String() string
type GetBearerTokenRequest ¶
type GetBearerTokenRequest struct {
// contains filtered or unexported fields
}
GetBearerTokenRequest is empty, please pass your API key via a X-Stanza-Key header.
func (*GetBearerTokenRequest) Descriptor
deprecated
func (*GetBearerTokenRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetBearerTokenRequest.ProtoReflect.Descriptor instead.
func (*GetBearerTokenRequest) ProtoMessage ¶
func (*GetBearerTokenRequest) ProtoMessage()
func (*GetBearerTokenRequest) ProtoReflect ¶
func (x *GetBearerTokenRequest) ProtoReflect() protoreflect.Message
func (*GetBearerTokenRequest) Reset ¶
func (x *GetBearerTokenRequest) Reset()
func (*GetBearerTokenRequest) String ¶
func (x *GetBearerTokenRequest) String() string
type GetBearerTokenResponse ¶
type GetBearerTokenResponse struct {
BearerToken string `protobuf:"bytes,1,opt,name=bearer_token,json=bearerToken,proto3" json:"bearer_token,omitempty"`
// contains filtered or unexported fields
}
GetBearerTokenResponse is a new Bearer Token.
func (*GetBearerTokenResponse) Descriptor
deprecated
func (*GetBearerTokenResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetBearerTokenResponse.ProtoReflect.Descriptor instead.
func (*GetBearerTokenResponse) GetBearerToken ¶
func (x *GetBearerTokenResponse) GetBearerToken() string
func (*GetBearerTokenResponse) ProtoMessage ¶
func (*GetBearerTokenResponse) ProtoMessage()
func (*GetBearerTokenResponse) ProtoReflect ¶
func (x *GetBearerTokenResponse) ProtoReflect() protoreflect.Message
func (*GetBearerTokenResponse) Reset ¶
func (x *GetBearerTokenResponse) Reset()
func (*GetBearerTokenResponse) String ¶
func (x *GetBearerTokenResponse) String() string
type GetBrowserContextRequest ¶
type GetBrowserContextRequest struct {
// Information required to select and return the most recent BrowserContext version. If Feature names is nil, will return all Features in the organization associated with the bearer token/API key, otherwise only information related to the named Features will be returned.
Feature *FeatureSelector `protobuf:"bytes,1,opt,name=feature,proto3" json:"feature,omitempty"`
// contains filtered or unexported fields
}
The request from Browser SDKs for a Browser Context. SDKs are expected to periodically poll, giving the version of the most recent configuration seen. Configurations may be large; we will not re-send them unless they have changed.
func (*GetBrowserContextRequest) Descriptor
deprecated
func (*GetBrowserContextRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetBrowserContextRequest.ProtoReflect.Descriptor instead.
func (*GetBrowserContextRequest) GetFeature ¶
func (x *GetBrowserContextRequest) GetFeature() *FeatureSelector
func (*GetBrowserContextRequest) ProtoMessage ¶
func (*GetBrowserContextRequest) ProtoMessage()
func (*GetBrowserContextRequest) ProtoReflect ¶
func (x *GetBrowserContextRequest) ProtoReflect() protoreflect.Message
func (*GetBrowserContextRequest) Reset ¶
func (x *GetBrowserContextRequest) Reset()
func (*GetBrowserContextRequest) String ¶
func (x *GetBrowserContextRequest) String() string
type GetBrowserContextResponse ¶
type GetBrowserContextResponse struct {
FeatureConfigs []*FeatureConfig `protobuf:"bytes,2,rep,name=feature_configs,json=featureConfigs,proto3" json:"feature_configs,omitempty"`
// contains filtered or unexported fields
}
The response to Browser SDKs is designed to be cacheable for short periods. It is also designed to be shareable between multiple clients (e.g. in case of SSR or use of CDN etc). May return 304 Not Modified with ETag header and empty payload.
func (*GetBrowserContextResponse) Descriptor
deprecated
func (*GetBrowserContextResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetBrowserContextResponse.ProtoReflect.Descriptor instead.
func (*GetBrowserContextResponse) GetFeatureConfigs ¶
func (x *GetBrowserContextResponse) GetFeatureConfigs() []*FeatureConfig
func (*GetBrowserContextResponse) ProtoMessage ¶
func (*GetBrowserContextResponse) ProtoMessage()
func (*GetBrowserContextResponse) ProtoReflect ¶
func (x *GetBrowserContextResponse) ProtoReflect() protoreflect.Message
func (*GetBrowserContextResponse) Reset ¶
func (x *GetBrowserContextResponse) Reset()
func (*GetBrowserContextResponse) String ¶
func (x *GetBrowserContextResponse) String() string
type GetGuardConfigRequest ¶
type GetGuardConfigRequest struct {
// Set if the client has seen a previous version of the config. Server will send data only if newer config available.
VersionSeen *string `protobuf:"bytes,1,opt,name=version_seen,json=versionSeen,proto3,oneof" json:"version_seen,omitempty"`
// Information required to select and return the correct GuardConfig version.
Selector *GuardServiceSelector `protobuf:"bytes,2,opt,name=selector,proto3" json:"selector,omitempty"`
// contains filtered or unexported fields
}
Request from Backend SDKs for a Guard Config. SDKs are expected to periodically poll, giving the version of the most recent configuration seen. Configurations may be large; we will not re-send them unless they have changed. Guard configurations may vary between environments but are SHARED between Services.
func (*GetGuardConfigRequest) Descriptor
deprecated
func (*GetGuardConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetGuardConfigRequest.ProtoReflect.Descriptor instead.
func (*GetGuardConfigRequest) GetSelector ¶
func (x *GetGuardConfigRequest) GetSelector() *GuardServiceSelector
func (*GetGuardConfigRequest) GetVersionSeen ¶
func (x *GetGuardConfigRequest) GetVersionSeen() string
func (*GetGuardConfigRequest) ProtoMessage ¶
func (*GetGuardConfigRequest) ProtoMessage()
func (*GetGuardConfigRequest) ProtoReflect ¶
func (x *GetGuardConfigRequest) ProtoReflect() protoreflect.Message
func (*GetGuardConfigRequest) Reset ¶
func (x *GetGuardConfigRequest) Reset()
func (*GetGuardConfigRequest) String ¶
func (x *GetGuardConfigRequest) String() string
type GetGuardConfigResponse ¶
type GetGuardConfigResponse struct {
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
ConfigDataSent bool `protobuf:"varint,2,opt,name=config_data_sent,json=configDataSent,proto3" json:"config_data_sent,omitempty"`
Config *GuardConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
The response from Hub to Backend SDKs. Note that `config_data_sent` will be false and `config` will be empty if we did not have a newer config version than `version_seen`.
func (*GetGuardConfigResponse) Descriptor
deprecated
func (*GetGuardConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetGuardConfigResponse.ProtoReflect.Descriptor instead.
func (*GetGuardConfigResponse) GetConfig ¶
func (x *GetGuardConfigResponse) GetConfig() *GuardConfig
func (*GetGuardConfigResponse) GetConfigDataSent ¶
func (x *GetGuardConfigResponse) GetConfigDataSent() bool
func (*GetGuardConfigResponse) GetVersion ¶
func (x *GetGuardConfigResponse) GetVersion() string
func (*GetGuardConfigResponse) ProtoMessage ¶
func (*GetGuardConfigResponse) ProtoMessage()
func (*GetGuardConfigResponse) ProtoReflect ¶
func (x *GetGuardConfigResponse) ProtoReflect() protoreflect.Message
func (*GetGuardConfigResponse) Reset ¶
func (x *GetGuardConfigResponse) Reset()
func (*GetGuardConfigResponse) String ¶
func (x *GetGuardConfigResponse) String() string
type GetServiceConfigRequest ¶
type GetServiceConfigRequest struct {
// Set if the client has seen a previous version of the config. Server will send data only if newer config available.
VersionSeen string `protobuf:"bytes,1,opt,name=version_seen,json=versionSeen,proto3" json:"version_seen,omitempty"`
// Information required to select and return the most recent ServiceConfig version
Service *ServiceSelector `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
// This is the same stable client_id that is used when requesting quota via GetTokenRequest/GetTokenLeaseRequest endpoints.
// If supplied, it permits Stanza to provide per-service telemetry and report on service<>guard and service<>feature relationships.
ClientId *string `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3,oneof" json:"client_id,omitempty"`
// contains filtered or unexported fields
}
The request from Backend SDKs for a Service Config. SDKs are expected to periodically poll, giving the version of the most recent configuration seen. Configurations may be large; we will not re-send them unless they have changed.
func (*GetServiceConfigRequest) Descriptor
deprecated
func (*GetServiceConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServiceConfigRequest.ProtoReflect.Descriptor instead.
func (*GetServiceConfigRequest) GetClientId ¶
func (x *GetServiceConfigRequest) GetClientId() string
func (*GetServiceConfigRequest) GetService ¶
func (x *GetServiceConfigRequest) GetService() *ServiceSelector
func (*GetServiceConfigRequest) GetVersionSeen ¶
func (x *GetServiceConfigRequest) GetVersionSeen() string
func (*GetServiceConfigRequest) ProtoMessage ¶
func (*GetServiceConfigRequest) ProtoMessage()
func (*GetServiceConfigRequest) ProtoReflect ¶
func (x *GetServiceConfigRequest) ProtoReflect() protoreflect.Message
func (*GetServiceConfigRequest) Reset ¶
func (x *GetServiceConfigRequest) Reset()
func (*GetServiceConfigRequest) String ¶
func (x *GetServiceConfigRequest) String() string
type GetServiceConfigResponse ¶
type GetServiceConfigResponse struct {
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
ConfigDataSent bool `protobuf:"varint,2,opt,name=config_data_sent,json=configDataSent,proto3" json:"config_data_sent,omitempty"`
Config *ServiceConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
The response to Backend SDKs. Note that `config_data_sent` will be false and `config` will be empty if we did not have a newer config version than `version_seen`.
func (*GetServiceConfigResponse) Descriptor
deprecated
func (*GetServiceConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetServiceConfigResponse.ProtoReflect.Descriptor instead.
func (*GetServiceConfigResponse) GetConfig ¶
func (x *GetServiceConfigResponse) GetConfig() *ServiceConfig
func (*GetServiceConfigResponse) GetConfigDataSent ¶
func (x *GetServiceConfigResponse) GetConfigDataSent() bool
func (*GetServiceConfigResponse) GetVersion ¶
func (x *GetServiceConfigResponse) GetVersion() string
func (*GetServiceConfigResponse) ProtoMessage ¶
func (*GetServiceConfigResponse) ProtoMessage()
func (*GetServiceConfigResponse) ProtoReflect ¶
func (x *GetServiceConfigResponse) ProtoReflect() protoreflect.Message
func (*GetServiceConfigResponse) Reset ¶
func (x *GetServiceConfigResponse) Reset()
func (*GetServiceConfigResponse) String ¶
func (x *GetServiceConfigResponse) String() string
type GetTokenLeaseRequest ¶
type GetTokenLeaseRequest struct {
// Only tags which are used for quota management should be included here - i.e. the list of quota_tags returned by the GetGuardConfig endpoint for this Guard. If tags are in use only one quota token will be issued at a time.
Selector *GuardFeatureSelector `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
// Used for tracking per-client token usage, allowing automatic determination of efficient batch leases. ID should be assigned by Stanza clients and be unique per-customer. Host or instance names may be used, or a UUID.
ClientId *string `protobuf:"bytes,4,opt,name=client_id,json=clientId,proto3,oneof" json:"client_id,omitempty"`
// Used to boost priority - SDK can increase or decrease priority of request, relative to normal feature priority. For instance, a customer may wish to boost the priority of paid user traffic over free tier. Priority boosts may also be negative - for example, one might deprioritise bot traffic.
PriorityBoost *int32 `protobuf:"varint,5,opt,name=priority_boost,json=priorityBoost,proto3,oneof" json:"priority_boost,omitempty"`
// Used for request weighting, i.e. accounting for varying request sizes and costs. The value set here is the default request weight which should be assumed for leases. If not specified, then the median weight is used when granted leases. Actual weights should be set via the SetTokenLeaseConsumed rpc.
//
// default_weight is optional; if not used then it is assumed that all requests have weight of 1.
DefaultWeight *float32 `protobuf:"fixed32,7,opt,name=default_weight,json=defaultWeight,proto3,oneof" json:"default_weight,omitempty"`
// contains filtered or unexported fields
}
Requests token lease for given Guard at priority of specified feature.
func (*GetTokenLeaseRequest) Descriptor
deprecated
func (*GetTokenLeaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTokenLeaseRequest.ProtoReflect.Descriptor instead.
func (*GetTokenLeaseRequest) GetClientId ¶
func (x *GetTokenLeaseRequest) GetClientId() string
func (*GetTokenLeaseRequest) GetDefaultWeight ¶
func (x *GetTokenLeaseRequest) GetDefaultWeight() float32
func (*GetTokenLeaseRequest) GetPriorityBoost ¶
func (x *GetTokenLeaseRequest) GetPriorityBoost() int32
func (*GetTokenLeaseRequest) GetSelector ¶
func (x *GetTokenLeaseRequest) GetSelector() *GuardFeatureSelector
func (*GetTokenLeaseRequest) ProtoMessage ¶
func (*GetTokenLeaseRequest) ProtoMessage()
func (*GetTokenLeaseRequest) ProtoReflect ¶
func (x *GetTokenLeaseRequest) ProtoReflect() protoreflect.Message
func (*GetTokenLeaseRequest) Reset ¶
func (x *GetTokenLeaseRequest) Reset()
func (*GetTokenLeaseRequest) String ¶
func (x *GetTokenLeaseRequest) String() string
type GetTokenLeaseResponse ¶
type GetTokenLeaseResponse struct {
Granted bool `protobuf:"varint,1,opt,name=granted,proto3" json:"granted,omitempty"`
Leases []*TokenLease `protobuf:"bytes,2,rep,name=leases,proto3" json:"leases,omitempty"`
// contains filtered or unexported fields
}
Specifies tokens granted and their duration (may be empty if none granted)
func (*GetTokenLeaseResponse) Descriptor
deprecated
func (*GetTokenLeaseResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTokenLeaseResponse.ProtoReflect.Descriptor instead.
func (*GetTokenLeaseResponse) GetGranted ¶
func (x *GetTokenLeaseResponse) GetGranted() bool
func (*GetTokenLeaseResponse) GetLeases ¶
func (x *GetTokenLeaseResponse) GetLeases() []*TokenLease
func (*GetTokenLeaseResponse) ProtoMessage ¶
func (*GetTokenLeaseResponse) ProtoMessage()
func (*GetTokenLeaseResponse) ProtoReflect ¶
func (x *GetTokenLeaseResponse) ProtoReflect() protoreflect.Message
func (*GetTokenLeaseResponse) Reset ¶
func (x *GetTokenLeaseResponse) Reset()
func (*GetTokenLeaseResponse) String ¶
func (x *GetTokenLeaseResponse) String() string
type GetTokenRequest ¶
type GetTokenRequest struct {
// Only tags which are used for quota management should be included here - i.e. the list of quota_tags returned by the GetGuardConfig endpoint for this Guard. If tags are in use only one quota token will be issued at a time.
Selector *GuardFeatureSelector `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
// Used for tracking per-client token usage, allowing automatic determination of efficient batch leases. ID should be assigned by Stanza clients and be unique per-customer. Host or instance names may be used, or a UUID.
ClientId *string `protobuf:"bytes,4,opt,name=client_id,json=clientId,proto3,oneof" json:"client_id,omitempty"`
// Used to increase or decrease priority of request, relative to normal feature priority.
PriorityBoost *int32 `protobuf:"varint,5,opt,name=priority_boost,json=priorityBoost,proto3,oneof" json:"priority_boost,omitempty"`
// Used for request weighting, i.e. accounting for varying request sizes and costs. If not specified then a default value of 1 is used. In cases where weights/costs are not known upfront, users can send an initial estimate as the weight, and then later, when the exact cost is known, send an updated weight via the SetTokenLeaseConsumed rpc.
//
// weight is optional; if not used then it is assumed that all requests have weight of 1.
Weight *float32 `protobuf:"fixed32,7,opt,name=weight,proto3,oneof" json:"weight,omitempty"`
// contains filtered or unexported fields
}
Requests token for given Guard at priority of specified feature.
func (*GetTokenRequest) Descriptor
deprecated
func (*GetTokenRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTokenRequest.ProtoReflect.Descriptor instead.
func (*GetTokenRequest) GetClientId ¶
func (x *GetTokenRequest) GetClientId() string
func (*GetTokenRequest) GetPriorityBoost ¶
func (x *GetTokenRequest) GetPriorityBoost() int32
func (*GetTokenRequest) GetSelector ¶
func (x *GetTokenRequest) GetSelector() *GuardFeatureSelector
func (*GetTokenRequest) GetWeight ¶
func (x *GetTokenRequest) GetWeight() float32
func (*GetTokenRequest) ProtoMessage ¶
func (*GetTokenRequest) ProtoMessage()
func (*GetTokenRequest) ProtoReflect ¶
func (x *GetTokenRequest) ProtoReflect() protoreflect.Message
func (*GetTokenRequest) Reset ¶
func (x *GetTokenRequest) Reset()
func (*GetTokenRequest) String ¶
func (x *GetTokenRequest) String() string
type GetTokenResponse ¶
type GetTokenResponse struct {
Granted bool `protobuf:"varint,1,opt,name=granted,proto3" json:"granted,omitempty"`
Token *string `protobuf:"bytes,2,opt,name=token,proto3,oneof" json:"token,omitempty"`
Reason *Reason `protobuf:"varint,3,opt,name=reason,proto3,enum=stanza.hub.v1.Reason,oneof" json:"reason,omitempty"`
// contains filtered or unexported fields
}
Specifies whether token granted.
func (*GetTokenResponse) Descriptor
deprecated
func (*GetTokenResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTokenResponse.ProtoReflect.Descriptor instead.
func (*GetTokenResponse) GetGranted ¶
func (x *GetTokenResponse) GetGranted() bool
func (*GetTokenResponse) GetReason ¶
func (x *GetTokenResponse) GetReason() Reason
func (*GetTokenResponse) GetToken ¶
func (x *GetTokenResponse) GetToken() string
func (*GetTokenResponse) ProtoMessage ¶
func (*GetTokenResponse) ProtoMessage()
func (*GetTokenResponse) ProtoReflect ¶
func (x *GetTokenResponse) ProtoReflect() protoreflect.Message
func (*GetTokenResponse) Reset ¶
func (x *GetTokenResponse) Reset()
func (*GetTokenResponse) String ¶
func (x *GetTokenResponse) String() string
type GetUsageRequest ¶
type GetUsageRequest struct {
// If specified, only stats relating to the tags and features in selector will be returned.
//
// If only guard and environment are specified, then stats relating to all tags and features will be returned.
Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
Guard *string `protobuf:"bytes,2,opt,name=guard,proto3,oneof" json:"guard,omitempty"` // Query for stats for this specific guard. If not specified then stats for all guards are returned.
GuardQueryMode *QueryMode `` /* 141-byte string literal not displayed */
StartTs *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
EndTs *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_ts,json=endTs,proto3" json:"end_ts,omitempty"`
Apikey *string `protobuf:"bytes,6,opt,name=apikey,proto3,oneof" json:"apikey,omitempty"` // Query for stats where this specific APIKey was used. If not specified then stats for all APIKeys are returned.
Feature *string `protobuf:"bytes,7,opt,name=feature,proto3,oneof" json:"feature,omitempty"` // Query for stats about a specific feature. If not specified then stats for all features are returned.
FeatureQueryMode *QueryMode `` /* 147-byte string literal not displayed */
Priority *int32 `protobuf:"varint,9,opt,name=priority,proto3,oneof" json:"priority,omitempty"` // Query for stats about a specific priority level. If not specified then stats for all priorities are returned.
PriorityQueryMode *QueryMode `` /* 151-byte string literal not displayed */
ReportTags []string `protobuf:"bytes,11,rep,name=report_tags,json=reportTags,proto3" json:"report_tags,omitempty"` // Tags matching listed tag keys will be reported (individual timeseries returned for each value).
Tags []*Tag `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"` // Only stats relating to the specified tags will be returned.
ReportAllTags *bool `protobuf:"varint,13,opt,name=report_all_tags,json=reportAllTags,proto3,oneof" json:"report_all_tags,omitempty"` // Report all tag values for all tags as separate timeseries. Overrides tags and report_tags params.
Step *string `protobuf:"bytes,14,opt,name=step,proto3,oneof" json:"step,omitempty"` // 1m to 1w - m is minutes; h hours; d days; w weeks (7d). Defaults to a step that results in <100 results. Minimum step 1m.
// contains filtered or unexported fields
}
Usage query.
func (*GetUsageRequest) Descriptor
deprecated
func (*GetUsageRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUsageRequest.ProtoReflect.Descriptor instead.
func (*GetUsageRequest) GetApikey ¶
func (x *GetUsageRequest) GetApikey() string
func (*GetUsageRequest) GetEndTs ¶
func (x *GetUsageRequest) GetEndTs() *timestamppb.Timestamp
func (*GetUsageRequest) GetEnvironment ¶
func (x *GetUsageRequest) GetEnvironment() string
func (*GetUsageRequest) GetFeature ¶
func (x *GetUsageRequest) GetFeature() string
func (*GetUsageRequest) GetFeatureQueryMode ¶
func (x *GetUsageRequest) GetFeatureQueryMode() QueryMode
func (*GetUsageRequest) GetGuard ¶
func (x *GetUsageRequest) GetGuard() string
func (*GetUsageRequest) GetGuardQueryMode ¶
func (x *GetUsageRequest) GetGuardQueryMode() QueryMode
func (*GetUsageRequest) GetPriority ¶
func (x *GetUsageRequest) GetPriority() int32
func (*GetUsageRequest) GetPriorityQueryMode ¶
func (x *GetUsageRequest) GetPriorityQueryMode() QueryMode
func (*GetUsageRequest) GetReportAllTags ¶
func (x *GetUsageRequest) GetReportAllTags() bool
func (*GetUsageRequest) GetReportTags ¶
func (x *GetUsageRequest) GetReportTags() []string
func (*GetUsageRequest) GetStartTs ¶
func (x *GetUsageRequest) GetStartTs() *timestamppb.Timestamp
func (*GetUsageRequest) GetStep ¶
func (x *GetUsageRequest) GetStep() string
func (*GetUsageRequest) GetTags ¶
func (x *GetUsageRequest) GetTags() []*Tag
func (*GetUsageRequest) ProtoMessage ¶
func (*GetUsageRequest) ProtoMessage()
func (*GetUsageRequest) ProtoReflect ¶
func (x *GetUsageRequest) ProtoReflect() protoreflect.Message
func (*GetUsageRequest) Reset ¶
func (x *GetUsageRequest) Reset()
func (*GetUsageRequest) String ¶
func (x *GetUsageRequest) String() string
type GetUsageResponse ¶
type GetUsageResponse struct {
Result []*UsageTimeseries `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
// contains filtered or unexported fields
}
func (*GetUsageResponse) Descriptor
deprecated
func (*GetUsageResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetUsageResponse.ProtoReflect.Descriptor instead.
func (*GetUsageResponse) GetResult ¶
func (x *GetUsageResponse) GetResult() []*UsageTimeseries
func (*GetUsageResponse) ProtoMessage ¶
func (*GetUsageResponse) ProtoMessage()
func (*GetUsageResponse) ProtoReflect ¶
func (x *GetUsageResponse) ProtoReflect() protoreflect.Message
func (*GetUsageResponse) Reset ¶
func (x *GetUsageResponse) Reset()
func (*GetUsageResponse) String ¶
func (x *GetUsageResponse) String() string
type GuardConfig ¶
type GuardConfig struct {
ValidateIngressTokens bool `` // Boolean representing wether to validate contents of the X-Stanza-Token header.
/* 127-byte string literal not displayed */
// Quota
CheckQuota bool `protobuf:"varint,5,opt,name=check_quota,json=checkQuota,proto3" json:"check_quota,omitempty"` // Boolean representing whether quota checks are enabled.
QuotaTags []string `protobuf:"bytes,6,rep,name=quota_tags,json=quotaTags,proto3" json:"quota_tags,omitempty"` // The set of tags which are used for quota management. For example, a 'customer_id' tag might be used to implement per-customer quota limits. Only the tags listed here should be included in GetToken and GetTokenLease requests.
// contains filtered or unexported fields
}
GuardConfig represents a configuration for a given Stanza SDK instrumented Guard, which may be used by multiple services! If check_quota is false, then no ratelimiting will be performed. All quota requests will succeed and the SDK may short-circuit quota requests, i.e. not call Hub for quota. At a later point, there will be additional per-Guard configuration, such as deadline overrides, adaptive circuitbreaking configs, etc.
func (*GuardConfig) Descriptor
deprecated
func (*GuardConfig) Descriptor() ([]byte, []int)
Deprecated: Use GuardConfig.ProtoReflect.Descriptor instead.
func (*GuardConfig) GetCheckQuota ¶
func (x *GuardConfig) GetCheckQuota() bool
func (*GuardConfig) GetQuotaTags ¶
func (x *GuardConfig) GetQuotaTags() []string
func (*GuardConfig) GetValidateIngressTokens ¶
func (x *GuardConfig) GetValidateIngressTokens() bool
func (*GuardConfig) ProtoMessage ¶
func (*GuardConfig) ProtoMessage()
func (*GuardConfig) ProtoReflect ¶
func (x *GuardConfig) ProtoReflect() protoreflect.Message
func (*GuardConfig) Reset ¶
func (x *GuardConfig) Reset()
func (*GuardConfig) String ¶
func (x *GuardConfig) String() string
type GuardFeatureSelector ¶
type GuardFeatureSelector struct {
Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
GuardName string `protobuf:"bytes,2,opt,name=guard_name,json=guardName,proto3" json:"guard_name,omitempty"`
FeatureName *string `protobuf:"bytes,3,opt,name=feature_name,json=featureName,proto3,oneof" json:"feature_name,omitempty"`
Tags []*Tag `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
// contains filtered or unexported fields
}
func (*GuardFeatureSelector) Descriptor
deprecated
func (*GuardFeatureSelector) Descriptor() ([]byte, []int)
Deprecated: Use GuardFeatureSelector.ProtoReflect.Descriptor instead.
func (*GuardFeatureSelector) GetEnvironment ¶
func (x *GuardFeatureSelector) GetEnvironment() string
func (*GuardFeatureSelector) GetFeatureName ¶
func (x *GuardFeatureSelector) GetFeatureName() string
func (*GuardFeatureSelector) GetGuardName ¶
func (x *GuardFeatureSelector) GetGuardName() string
func (*GuardFeatureSelector) GetTags ¶
func (x *GuardFeatureSelector) GetTags() []*Tag
func (*GuardFeatureSelector) ProtoMessage ¶
func (*GuardFeatureSelector) ProtoMessage()
func (*GuardFeatureSelector) ProtoReflect ¶
func (x *GuardFeatureSelector) ProtoReflect() protoreflect.Message
func (*GuardFeatureSelector) Reset ¶
func (x *GuardFeatureSelector) Reset()
func (*GuardFeatureSelector) String ¶
func (x *GuardFeatureSelector) String() string
type GuardSelector ¶
type GuardSelector struct {
Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Tags []*Tag `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
// contains filtered or unexported fields
}
func (*GuardSelector) Descriptor
deprecated
func (*GuardSelector) Descriptor() ([]byte, []int)
Deprecated: Use GuardSelector.ProtoReflect.Descriptor instead.
func (*GuardSelector) GetEnvironment ¶
func (x *GuardSelector) GetEnvironment() string
func (*GuardSelector) GetName ¶
func (x *GuardSelector) GetName() string
func (*GuardSelector) GetTags ¶
func (x *GuardSelector) GetTags() []*Tag
func (*GuardSelector) ProtoMessage ¶
func (*GuardSelector) ProtoMessage()
func (*GuardSelector) ProtoReflect ¶
func (x *GuardSelector) ProtoReflect() protoreflect.Message
func (*GuardSelector) Reset ¶
func (x *GuardSelector) Reset()
func (*GuardSelector) String ¶
func (x *GuardSelector) String() string
type GuardServiceSelector ¶
type GuardServiceSelector struct {
Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
GuardName string `protobuf:"bytes,2,opt,name=guard_name,json=guardName,proto3" json:"guard_name,omitempty"`
ServiceName string `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
ServiceRelease string `protobuf:"bytes,4,opt,name=service_release,json=serviceRelease,proto3" json:"service_release,omitempty"`
Tags []*Tag `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
// contains filtered or unexported fields
}
func (*GuardServiceSelector) Descriptor
deprecated
func (*GuardServiceSelector) Descriptor() ([]byte, []int)
Deprecated: Use GuardServiceSelector.ProtoReflect.Descriptor instead.
func (*GuardServiceSelector) GetEnvironment ¶
func (x *GuardServiceSelector) GetEnvironment() string
func (*GuardServiceSelector) GetGuardName ¶
func (x *GuardServiceSelector) GetGuardName() string
func (*GuardServiceSelector) GetServiceName ¶
func (x *GuardServiceSelector) GetServiceName() string
func (*GuardServiceSelector) GetServiceRelease ¶
func (x *GuardServiceSelector) GetServiceRelease() string
func (*GuardServiceSelector) GetTags ¶
func (x *GuardServiceSelector) GetTags() []*Tag
func (*GuardServiceSelector) ProtoMessage ¶
func (*GuardServiceSelector) ProtoMessage()
func (*GuardServiceSelector) ProtoReflect ¶
func (x *GuardServiceSelector) ProtoReflect() protoreflect.Message
func (*GuardServiceSelector) Reset ¶
func (x *GuardServiceSelector) Reset()
func (*GuardServiceSelector) String ¶
func (x *GuardServiceSelector) String() string
type HeaderTraceConfig ¶
type HeaderTraceConfig struct {
SpanSelectors []*SpanSelector `protobuf:"bytes,1,rep,name=span_selectors,json=spanSelectors,proto3" json:"span_selectors,omitempty"` // If no selectors specified then config is applied to all requests
RequestHeaderNames []string `protobuf:"bytes,2,rep,name=request_header_names,json=requestHeaderNames,proto3" json:"request_header_names,omitempty"` // Names of headers to collect
ResponseHeaderNames []string `protobuf:"bytes,3,rep,name=response_header_names,json=responseHeaderNames,proto3" json:"response_header_names,omitempty"` // Names of headers to collect
// contains filtered or unexported fields
}
Specifies which headers should be sampled - required by OTel spec.
func (*HeaderTraceConfig) Descriptor
deprecated
func (*HeaderTraceConfig) Descriptor() ([]byte, []int)
Deprecated: Use HeaderTraceConfig.ProtoReflect.Descriptor instead.
func (*HeaderTraceConfig) GetRequestHeaderNames ¶
func (x *HeaderTraceConfig) GetRequestHeaderNames() []string
func (*HeaderTraceConfig) GetResponseHeaderNames ¶
func (x *HeaderTraceConfig) GetResponseHeaderNames() []string
func (*HeaderTraceConfig) GetSpanSelectors ¶
func (x *HeaderTraceConfig) GetSpanSelectors() []*SpanSelector
func (*HeaderTraceConfig) ProtoMessage ¶
func (*HeaderTraceConfig) ProtoMessage()
func (*HeaderTraceConfig) ProtoReflect ¶
func (x *HeaderTraceConfig) ProtoReflect() protoreflect.Message
func (*HeaderTraceConfig) Reset ¶
func (x *HeaderTraceConfig) Reset()
func (*HeaderTraceConfig) String ¶
func (x *HeaderTraceConfig) String() string
type Health ¶
type Health int32
func (Health) Descriptor ¶
func (Health) Descriptor() protoreflect.EnumDescriptor
func (Health) EnumDescriptor
deprecated
func (Health) Number ¶
func (x Health) Number() protoreflect.EnumNumber
func (Health) Type ¶
func (Health) Type() protoreflect.EnumType
type HealthByPriority ¶
type HealthByPriority struct {
Priority uint32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
Health Health `protobuf:"varint,2,opt,name=health,proto3,enum=stanza.hub.v1.Health" json:"health,omitempty"`
// contains filtered or unexported fields
}
func (*HealthByPriority) Descriptor
deprecated
func (*HealthByPriority) Descriptor() ([]byte, []int)
Deprecated: Use HealthByPriority.ProtoReflect.Descriptor instead.
func (*HealthByPriority) GetHealth ¶
func (x *HealthByPriority) GetHealth() Health
func (*HealthByPriority) GetPriority ¶
func (x *HealthByPriority) GetPriority() uint32
func (*HealthByPriority) ProtoMessage ¶
func (*HealthByPriority) ProtoMessage()
func (*HealthByPriority) ProtoReflect ¶
func (x *HealthByPriority) ProtoReflect() protoreflect.Message
func (*HealthByPriority) Reset ¶
func (x *HealthByPriority) Reset()
func (*HealthByPriority) String ¶
func (x *HealthByPriority) String() string
type HealthServiceClient ¶
type HealthServiceClient interface {
QueryGuardHealth(ctx context.Context, in *QueryGuardHealthRequest, opts ...grpc.CallOption) (*QueryGuardHealthResponse, error)
}
HealthServiceClient is the client API for HealthService 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 NewHealthServiceClient ¶
func NewHealthServiceClient(cc grpc.ClientConnInterface) HealthServiceClient
type HealthServiceServer ¶
type HealthServiceServer interface {
QueryGuardHealth(context.Context, *QueryGuardHealthRequest) (*QueryGuardHealthResponse, error)
// contains filtered or unexported methods
}
HealthServiceServer is the server API for HealthService service. All implementations must embed UnimplementedHealthServiceServer for forward compatibility
type MetricConfig ¶
type MetricConfig struct {
CollectorUrl *string `protobuf:"bytes,1,opt,name=collector_url,json=collectorUrl,proto3,oneof" json:"collector_url,omitempty"` // URL of OTEL metric collector. If URL begins with http or https it will be treated as an HTTP collector, otherwise it will be treated as a gRPC collector.
// contains filtered or unexported fields
}
func (*MetricConfig) Descriptor
deprecated
func (*MetricConfig) Descriptor() ([]byte, []int)
Deprecated: Use MetricConfig.ProtoReflect.Descriptor instead.
func (*MetricConfig) GetCollectorUrl ¶
func (x *MetricConfig) GetCollectorUrl() string
func (*MetricConfig) ProtoMessage ¶
func (*MetricConfig) ProtoMessage()
func (*MetricConfig) ProtoReflect ¶
func (x *MetricConfig) ProtoReflect() protoreflect.Message
func (*MetricConfig) Reset ¶
func (x *MetricConfig) Reset()
func (*MetricConfig) String ¶
func (x *MetricConfig) String() string
type ParamTraceConfig ¶
type ParamTraceConfig struct {
SpanSelectors []*SpanSelector `protobuf:"bytes,1,rep,name=span_selectors,json=spanSelectors,proto3" json:"span_selectors,omitempty"` // If no selectors specified then config is applied to all requests
ParameterNames []string `protobuf:"bytes,2,rep,name=parameter_names,json=parameterNames,proto3" json:"parameter_names,omitempty"` // Names of parameters to collect
// contains filtered or unexported fields
}
Specifies which request parameters should be sampled.
func (*ParamTraceConfig) Descriptor
deprecated
func (*ParamTraceConfig) Descriptor() ([]byte, []int)
Deprecated: Use ParamTraceConfig.ProtoReflect.Descriptor instead.
func (*ParamTraceConfig) GetParameterNames ¶
func (x *ParamTraceConfig) GetParameterNames() []string
func (*ParamTraceConfig) GetSpanSelectors ¶
func (x *ParamTraceConfig) GetSpanSelectors() []*SpanSelector
func (*ParamTraceConfig) ProtoMessage ¶
func (*ParamTraceConfig) ProtoMessage()
func (*ParamTraceConfig) ProtoReflect ¶
func (x *ParamTraceConfig) ProtoReflect() protoreflect.Message
func (*ParamTraceConfig) Reset ¶
func (x *ParamTraceConfig) Reset()
func (*ParamTraceConfig) String ¶
func (x *ParamTraceConfig) String() string
type QueryGuardHealthRequest ¶
type QueryGuardHealthRequest struct {
// Only tags which are used for quota management should be included here - i.e. the list of quota_tags returned by the GetGuardConfig endpoint for this Guard. If tags are in use only one quota token will be issued at a time.
Selector *GuardFeatureSelector `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"` // Required: GuardName, featureName, environment
// Used to boost priority - SDK can increase or decrease priority of request, relative to normal feature priority. For instance, a customer may wish to boost the priority of paid user traffic over free tier. Priority boosts may also be negative - for example, one might deprioritise bot traffic.
PriorityBoost *int32 `protobuf:"varint,4,opt,name=priority_boost,json=priorityBoost,proto3,oneof" json:"priority_boost,omitempty"`
// contains filtered or unexported fields
}
Called by SDK to determine whether a Guard is overloaded at a given Feature's priority level. Used so that customer code can make good decisions about fail-fast or graceful degradation as high up the stack as possible. SDK may cache the result for up to 10 seconds.
func (*QueryGuardHealthRequest) Descriptor
deprecated
func (*QueryGuardHealthRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryGuardHealthRequest.ProtoReflect.Descriptor instead.
func (*QueryGuardHealthRequest) GetPriorityBoost ¶
func (x *QueryGuardHealthRequest) GetPriorityBoost() int32
func (*QueryGuardHealthRequest) GetSelector ¶
func (x *QueryGuardHealthRequest) GetSelector() *GuardFeatureSelector
func (*QueryGuardHealthRequest) ProtoMessage ¶
func (*QueryGuardHealthRequest) ProtoMessage()
func (*QueryGuardHealthRequest) ProtoReflect ¶
func (x *QueryGuardHealthRequest) ProtoReflect() protoreflect.Message
func (*QueryGuardHealthRequest) Reset ¶
func (x *QueryGuardHealthRequest) Reset()
func (*QueryGuardHealthRequest) String ¶
func (x *QueryGuardHealthRequest) String() string
type QueryGuardHealthResponse ¶
type QueryGuardHealthResponse struct {
Health Health `protobuf:"varint,1,opt,name=health,proto3,enum=stanza.hub.v1.Health" json:"health,omitempty"`
// contains filtered or unexported fields
}
func (*QueryGuardHealthResponse) Descriptor
deprecated
func (*QueryGuardHealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryGuardHealthResponse.ProtoReflect.Descriptor instead.
func (*QueryGuardHealthResponse) GetHealth ¶
func (x *QueryGuardHealthResponse) GetHealth() Health
func (*QueryGuardHealthResponse) ProtoMessage ¶
func (*QueryGuardHealthResponse) ProtoMessage()
func (*QueryGuardHealthResponse) ProtoReflect ¶
func (x *QueryGuardHealthResponse) ProtoReflect() protoreflect.Message
func (*QueryGuardHealthResponse) Reset ¶
func (x *QueryGuardHealthResponse) Reset()
func (*QueryGuardHealthResponse) String ¶
func (x *QueryGuardHealthResponse) String() string
type QueryMode ¶
type QueryMode int32
MODE_SUM: query results across various axes (features, tags, apikeys) are added up and one timeseries is returned. MODE_REPORT: individual timeseries are returned for specified query axes. If not specified then queries will default to MODE_SUM for all axes.
func (QueryMode) Descriptor ¶
func (QueryMode) Descriptor() protoreflect.EnumDescriptor
func (QueryMode) EnumDescriptor
deprecated
func (QueryMode) Number ¶
func (x QueryMode) Number() protoreflect.EnumNumber
func (QueryMode) Type ¶
func (QueryMode) Type() protoreflect.EnumType
type QuotaServiceClient ¶
type QuotaServiceClient interface {
GetToken(ctx context.Context, in *GetTokenRequest, opts ...grpc.CallOption) (*GetTokenResponse, error)
GetTokenLease(ctx context.Context, in *GetTokenLeaseRequest, opts ...grpc.CallOption) (*GetTokenLeaseResponse, error)
SetTokenLeaseConsumed(ctx context.Context, in *SetTokenLeaseConsumedRequest, opts ...grpc.CallOption) (*SetTokenLeaseConsumedResponse, error)
// Used by ingress Guards to validate Hub-generated tokens.
ValidateToken(ctx context.Context, in *ValidateTokenRequest, opts ...grpc.CallOption) (*ValidateTokenResponse, error)
}
QuotaServiceClient is the client API for QuotaService 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 NewQuotaServiceClient ¶
func NewQuotaServiceClient(cc grpc.ClientConnInterface) QuotaServiceClient
type QuotaServiceServer ¶
type QuotaServiceServer interface {
GetToken(context.Context, *GetTokenRequest) (*GetTokenResponse, error)
GetTokenLease(context.Context, *GetTokenLeaseRequest) (*GetTokenLeaseResponse, error)
SetTokenLeaseConsumed(context.Context, *SetTokenLeaseConsumedRequest) (*SetTokenLeaseConsumedResponse, error)
// Used by ingress Guards to validate Hub-generated tokens.
ValidateToken(context.Context, *ValidateTokenRequest) (*ValidateTokenResponse, error)
// contains filtered or unexported methods
}
QuotaServiceServer is the server API for QuotaService service. All implementations must embed UnimplementedQuotaServiceServer for forward compatibility
type Reason ¶
type Reason int32
func (Reason) Descriptor ¶
func (Reason) Descriptor() protoreflect.EnumDescriptor
func (Reason) EnumDescriptor
deprecated
func (Reason) Number ¶
func (x Reason) Number() protoreflect.EnumNumber
func (Reason) Type ¶
func (Reason) Type() protoreflect.EnumType
type SentinelConfig ¶
type SentinelConfig struct {
CircuitbreakerRulesJson *string `` /* 138-byte string literal not displayed */
FlowRulesJson *string `protobuf:"bytes,2,opt,name=flow_rules_json,json=flowRulesJson,proto3,oneof" json:"flow_rules_json,omitempty"`
IsolationRulesJson *string `protobuf:"bytes,3,opt,name=isolation_rules_json,json=isolationRulesJson,proto3,oneof" json:"isolation_rules_json,omitempty"`
SystemRulesJson *string `protobuf:"bytes,4,opt,name=system_rules_json,json=systemRulesJson,proto3,oneof" json:"system_rules_json,omitempty"`
// contains filtered or unexported fields
}
SentinelConfig represents Sentinel compliant JSON configuration for the given Sentinel types. These rules are "per service" (not per Guard) with Guard specific routing encoded in the given JSON blobs (as Sentinel "Resources").
func (*SentinelConfig) Descriptor
deprecated
func (*SentinelConfig) Descriptor() ([]byte, []int)
Deprecated: Use SentinelConfig.ProtoReflect.Descriptor instead.
func (*SentinelConfig) GetCircuitbreakerRulesJson ¶
func (x *SentinelConfig) GetCircuitbreakerRulesJson() string
func (*SentinelConfig) GetFlowRulesJson ¶
func (x *SentinelConfig) GetFlowRulesJson() string
func (*SentinelConfig) GetIsolationRulesJson ¶
func (x *SentinelConfig) GetIsolationRulesJson() string
func (*SentinelConfig) GetSystemRulesJson ¶
func (x *SentinelConfig) GetSystemRulesJson() string
func (*SentinelConfig) ProtoMessage ¶
func (*SentinelConfig) ProtoMessage()
func (*SentinelConfig) ProtoReflect ¶
func (x *SentinelConfig) ProtoReflect() protoreflect.Message
func (*SentinelConfig) Reset ¶
func (x *SentinelConfig) Reset()
func (*SentinelConfig) String ¶
func (x *SentinelConfig) String() string
type ServiceConfig ¶
type ServiceConfig struct {
CustomerId *string `protobuf:"bytes,1,opt,name=customer_id,json=customerId,proto3,oneof" json:"customer_id,omitempty"`
TraceConfig *TraceConfig `protobuf:"bytes,3,opt,name=trace_config,json=traceConfig,proto3,oneof" json:"trace_config,omitempty"`
MetricConfig *MetricConfig `protobuf:"bytes,4,opt,name=metric_config,json=metricConfig,proto3,oneof" json:"metric_config,omitempty"`
SentinelConfig *SentinelConfig `protobuf:"bytes,5,opt,name=sentinel_config,json=sentinelConfig,proto3,oneof" json:"sentinel_config,omitempty"`
// contains filtered or unexported fields
}
ServiceConfig represents a configuration for a given Stanza SDK instrumented service.
func (*ServiceConfig) Descriptor
deprecated
func (*ServiceConfig) Descriptor() ([]byte, []int)
Deprecated: Use ServiceConfig.ProtoReflect.Descriptor instead.
func (*ServiceConfig) GetCustomerId ¶
func (x *ServiceConfig) GetCustomerId() string
func (*ServiceConfig) GetMetricConfig ¶
func (x *ServiceConfig) GetMetricConfig() *MetricConfig
func (*ServiceConfig) GetSentinelConfig ¶
func (x *ServiceConfig) GetSentinelConfig() *SentinelConfig
func (*ServiceConfig) GetTraceConfig ¶
func (x *ServiceConfig) GetTraceConfig() *TraceConfig
func (*ServiceConfig) ProtoMessage ¶
func (*ServiceConfig) ProtoMessage()
func (*ServiceConfig) ProtoReflect ¶
func (x *ServiceConfig) ProtoReflect() protoreflect.Message
func (*ServiceConfig) Reset ¶
func (x *ServiceConfig) Reset()
func (*ServiceConfig) String ¶
func (x *ServiceConfig) String() string
type ServiceSelector ¶
type ServiceSelector struct {
Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Release *string `protobuf:"bytes,3,opt,name=release,proto3,oneof" json:"release,omitempty"`
Tags []*Tag `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
// contains filtered or unexported fields
}
func (*ServiceSelector) Descriptor
deprecated
func (*ServiceSelector) Descriptor() ([]byte, []int)
Deprecated: Use ServiceSelector.ProtoReflect.Descriptor instead.
func (*ServiceSelector) GetEnvironment ¶
func (x *ServiceSelector) GetEnvironment() string
func (*ServiceSelector) GetName ¶
func (x *ServiceSelector) GetName() string
func (*ServiceSelector) GetRelease ¶
func (x *ServiceSelector) GetRelease() string
func (*ServiceSelector) GetTags ¶
func (x *ServiceSelector) GetTags() []*Tag
func (*ServiceSelector) ProtoMessage ¶
func (*ServiceSelector) ProtoMessage()
func (*ServiceSelector) ProtoReflect ¶
func (x *ServiceSelector) ProtoReflect() protoreflect.Message
func (*ServiceSelector) Reset ¶
func (x *ServiceSelector) Reset()
func (*ServiceSelector) String ¶
func (x *ServiceSelector) String() string
type SetTokenLeaseConsumedRequest ¶
type SetTokenLeaseConsumedRequest struct {
Tokens []string `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
// Used for request weighting, i.e. accounting for varying request sizes and costs. If weights are not known before request execution, then a default or estimated weight may be used, followed by a corrected value here. If a value is sent here, it should be the actual request weight.
WeightCorrection *float32 `protobuf:"fixed32,2,opt,name=weight_correction,json=weightCorrection,proto3,oneof" json:"weight_correction,omitempty"`
// contains filtered or unexported fields
}
Notifies Hub that one or more token leases has been used, i.e. Guard has been exercised.
func (*SetTokenLeaseConsumedRequest) Descriptor
deprecated
func (*SetTokenLeaseConsumedRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetTokenLeaseConsumedRequest.ProtoReflect.Descriptor instead.
func (*SetTokenLeaseConsumedRequest) GetTokens ¶
func (x *SetTokenLeaseConsumedRequest) GetTokens() []string
func (*SetTokenLeaseConsumedRequest) GetWeightCorrection ¶
func (x *SetTokenLeaseConsumedRequest) GetWeightCorrection() float32
func (*SetTokenLeaseConsumedRequest) ProtoMessage ¶
func (*SetTokenLeaseConsumedRequest) ProtoMessage()
func (*SetTokenLeaseConsumedRequest) ProtoReflect ¶
func (x *SetTokenLeaseConsumedRequest) ProtoReflect() protoreflect.Message
func (*SetTokenLeaseConsumedRequest) Reset ¶
func (x *SetTokenLeaseConsumedRequest) Reset()
func (*SetTokenLeaseConsumedRequest) String ¶
func (x *SetTokenLeaseConsumedRequest) String() string
type SetTokenLeaseConsumedResponse ¶
type SetTokenLeaseConsumedResponse struct {
// contains filtered or unexported fields
}
No message contents yet
func (*SetTokenLeaseConsumedResponse) Descriptor
deprecated
func (*SetTokenLeaseConsumedResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetTokenLeaseConsumedResponse.ProtoReflect.Descriptor instead.
func (*SetTokenLeaseConsumedResponse) ProtoMessage ¶
func (*SetTokenLeaseConsumedResponse) ProtoMessage()
func (*SetTokenLeaseConsumedResponse) ProtoReflect ¶
func (x *SetTokenLeaseConsumedResponse) ProtoReflect() protoreflect.Message
func (*SetTokenLeaseConsumedResponse) Reset ¶
func (x *SetTokenLeaseConsumedResponse) Reset()
func (*SetTokenLeaseConsumedResponse) String ¶
func (x *SetTokenLeaseConsumedResponse) String() string
type SpanSelector ¶
type SpanSelector struct {
// OTel attribute, e.g. peer.service, status, http.status_code. See:
// https://opentelemetry.io/docs/reference/specification/trace/semantic_conventions/span-general/
// https://opentelemetry.io/docs/reference/specification/trace/semantic_conventions/http/
OtelAttribute string `protobuf:"bytes,1,opt,name=otel_attribute,json=otelAttribute,proto3" json:"otel_attribute,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Selector matches if value of 'otel_attribute' equals 'value'.
// contains filtered or unexported fields
}
func (*SpanSelector) Descriptor
deprecated
func (*SpanSelector) Descriptor() ([]byte, []int)
Deprecated: Use SpanSelector.ProtoReflect.Descriptor instead.
func (*SpanSelector) GetOtelAttribute ¶
func (x *SpanSelector) GetOtelAttribute() string
func (*SpanSelector) GetValue ¶
func (x *SpanSelector) GetValue() string
func (*SpanSelector) ProtoMessage ¶
func (*SpanSelector) ProtoMessage()
func (*SpanSelector) ProtoReflect ¶
func (x *SpanSelector) ProtoReflect() protoreflect.Message
func (*SpanSelector) Reset ¶
func (x *SpanSelector) Reset()
func (*SpanSelector) String ¶
func (x *SpanSelector) String() string
type State ¶
type State int32
func (State) Descriptor ¶
func (State) Descriptor() protoreflect.EnumDescriptor
func (State) EnumDescriptor
deprecated
func (State) Number ¶
func (x State) Number() protoreflect.EnumNumber
func (State) Type ¶
func (State) Type() protoreflect.EnumType
type Tag ¶
type Tag struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*Tag) Descriptor
deprecated
func (*Tag) ProtoMessage ¶
func (*Tag) ProtoMessage()
func (*Tag) ProtoReflect ¶
func (x *Tag) ProtoReflect() protoreflect.Message
type TokenInfo ¶
type TokenInfo struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
Guard *GuardSelector `protobuf:"bytes,2,opt,name=guard,proto3" json:"guard,omitempty"`
// contains filtered or unexported fields
}
func (*TokenInfo) Descriptor
deprecated
func (*TokenInfo) GetGuard ¶
func (x *TokenInfo) GetGuard() *GuardSelector
func (*TokenInfo) ProtoMessage ¶
func (*TokenInfo) ProtoMessage()
func (*TokenInfo) ProtoReflect ¶
func (x *TokenInfo) ProtoReflect() protoreflect.Message
type TokenLease ¶
type TokenLease struct {
DurationMsec int32 `protobuf:"varint,1,opt,name=duration_msec,json=durationMsec,proto3" json:"duration_msec,omitempty"` // How long until lease expires, in milliseconds
Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
Feature string `protobuf:"bytes,3,opt,name=feature,proto3" json:"feature,omitempty"`
PriorityBoost int32 `protobuf:"varint,4,opt,name=priority_boost,json=priorityBoost,proto3" json:"priority_boost,omitempty"`
Weight float32 `protobuf:"fixed32,5,opt,name=weight,proto3" json:"weight,omitempty"`
Reason Reason `protobuf:"varint,6,opt,name=reason,proto3,enum=stanza.hub.v1.Reason" json:"reason,omitempty"`
ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=expires_at,json=expiresAt,proto3,oneof" json:"expires_at,omitempty"` // If nil expiration should be calculated as time you received the lease + duration_msec
// contains filtered or unexported fields
}
func (*TokenLease) Descriptor
deprecated
func (*TokenLease) Descriptor() ([]byte, []int)
Deprecated: Use TokenLease.ProtoReflect.Descriptor instead.
func (*TokenLease) GetDurationMsec ¶
func (x *TokenLease) GetDurationMsec() int32
func (*TokenLease) GetExpiresAt ¶
func (x *TokenLease) GetExpiresAt() *timestamppb.Timestamp
func (*TokenLease) GetFeature ¶
func (x *TokenLease) GetFeature() string
func (*TokenLease) GetPriorityBoost ¶
func (x *TokenLease) GetPriorityBoost() int32
func (*TokenLease) GetReason ¶
func (x *TokenLease) GetReason() Reason
func (*TokenLease) GetToken ¶
func (x *TokenLease) GetToken() string
func (*TokenLease) GetWeight ¶
func (x *TokenLease) GetWeight() float32
func (*TokenLease) ProtoMessage ¶
func (*TokenLease) ProtoMessage()
func (*TokenLease) ProtoReflect ¶
func (x *TokenLease) ProtoReflect() protoreflect.Message
func (*TokenLease) Reset ¶
func (x *TokenLease) Reset()
func (*TokenLease) String ¶
func (x *TokenLease) String() string
type TokenValid ¶
type TokenValid struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
Valid bool `protobuf:"varint,2,opt,name=valid,proto3" json:"valid,omitempty"`
// contains filtered or unexported fields
}
func (*TokenValid) Descriptor
deprecated
func (*TokenValid) Descriptor() ([]byte, []int)
Deprecated: Use TokenValid.ProtoReflect.Descriptor instead.
func (*TokenValid) GetToken ¶
func (x *TokenValid) GetToken() string
func (*TokenValid) GetValid ¶
func (x *TokenValid) GetValid() bool
func (*TokenValid) ProtoMessage ¶
func (*TokenValid) ProtoMessage()
func (*TokenValid) ProtoReflect ¶
func (x *TokenValid) ProtoReflect() protoreflect.Message
func (*TokenValid) Reset ¶
func (x *TokenValid) Reset()
func (*TokenValid) String ¶
func (x *TokenValid) String() string
type TraceConfig ¶
type TraceConfig struct {
CollectorUrl *string `protobuf:"bytes,1,opt,name=collector_url,json=collectorUrl,proto3,oneof" json:"collector_url,omitempty"` // URL of OTEL trace collector. If URL begins with http or https it will be treated as an HTTP collector, otherwise it will be treated as a gRPC collector.
SampleRateDefault *float32 `protobuf:"fixed32,3,opt,name=sample_rate_default,json=sampleRateDefault,proto3,oneof" json:"sample_rate_default,omitempty"` // default base sampling rate
Overrides []*TraceConfigOverride `protobuf:"bytes,4,rep,name=overrides,proto3" json:"overrides,omitempty"` // span sampling rate overrides
HeaderSampleConfigs []*HeaderTraceConfig `protobuf:"bytes,5,rep,name=header_sample_configs,json=headerSampleConfigs,proto3" json:"header_sample_configs,omitempty"` // which headers to capture
ParamSampleConfigs []*ParamTraceConfig `protobuf:"bytes,6,rep,name=param_sample_configs,json=paramSampleConfigs,proto3" json:"param_sample_configs,omitempty"` // which parameters to capture
// contains filtered or unexported fields
}
func (*TraceConfig) Descriptor
deprecated
func (*TraceConfig) Descriptor() ([]byte, []int)
Deprecated: Use TraceConfig.ProtoReflect.Descriptor instead.
func (*TraceConfig) GetCollectorUrl ¶
func (x *TraceConfig) GetCollectorUrl() string
func (*TraceConfig) GetHeaderSampleConfigs ¶
func (x *TraceConfig) GetHeaderSampleConfigs() []*HeaderTraceConfig
func (*TraceConfig) GetOverrides ¶
func (x *TraceConfig) GetOverrides() []*TraceConfigOverride
func (*TraceConfig) GetParamSampleConfigs ¶
func (x *TraceConfig) GetParamSampleConfigs() []*ParamTraceConfig
func (*TraceConfig) GetSampleRateDefault ¶
func (x *TraceConfig) GetSampleRateDefault() float32
func (*TraceConfig) ProtoMessage ¶
func (*TraceConfig) ProtoMessage()
func (*TraceConfig) ProtoReflect ¶
func (x *TraceConfig) ProtoReflect() protoreflect.Message
func (*TraceConfig) Reset ¶
func (x *TraceConfig) Reset()
func (*TraceConfig) String ¶
func (x *TraceConfig) String() string
type TraceConfigOverride ¶
type TraceConfigOverride struct {
SampleRate float32 `protobuf:"fixed32,1,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"`
SpanSelectors []*SpanSelector `protobuf:"bytes,2,rep,name=span_selectors,json=spanSelectors,proto3" json:"span_selectors,omitempty"`
// contains filtered or unexported fields
}
This configuration allows different sample rates to be applied to selected spans.
func (*TraceConfigOverride) Descriptor
deprecated
func (*TraceConfigOverride) Descriptor() ([]byte, []int)
Deprecated: Use TraceConfigOverride.ProtoReflect.Descriptor instead.
func (*TraceConfigOverride) GetSampleRate ¶
func (x *TraceConfigOverride) GetSampleRate() float32
func (*TraceConfigOverride) GetSpanSelectors ¶
func (x *TraceConfigOverride) GetSpanSelectors() []*SpanSelector
func (*TraceConfigOverride) ProtoMessage ¶
func (*TraceConfigOverride) ProtoMessage()
func (*TraceConfigOverride) ProtoReflect ¶
func (x *TraceConfigOverride) ProtoReflect() protoreflect.Message
func (*TraceConfigOverride) Reset ¶
func (x *TraceConfigOverride) Reset()
func (*TraceConfigOverride) String ¶
func (x *TraceConfigOverride) String() string
type UnimplementedAuthServiceServer ¶
type UnimplementedAuthServiceServer struct {
}
UnimplementedAuthServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedAuthServiceServer) GetBearerToken ¶
func (UnimplementedAuthServiceServer) GetBearerToken(context.Context, *GetBearerTokenRequest) (*GetBearerTokenResponse, error)
type UnimplementedConfigServiceServer ¶
type UnimplementedConfigServiceServer struct {
}
UnimplementedConfigServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedConfigServiceServer) GetBrowserContext ¶
func (UnimplementedConfigServiceServer) GetBrowserContext(context.Context, *GetBrowserContextRequest) (*GetBrowserContextResponse, error)
func (UnimplementedConfigServiceServer) GetGuardConfig ¶
func (UnimplementedConfigServiceServer) GetGuardConfig(context.Context, *GetGuardConfigRequest) (*GetGuardConfigResponse, error)
func (UnimplementedConfigServiceServer) GetServiceConfig ¶
func (UnimplementedConfigServiceServer) GetServiceConfig(context.Context, *GetServiceConfigRequest) (*GetServiceConfigResponse, error)
type UnimplementedHealthServiceServer ¶
type UnimplementedHealthServiceServer struct {
}
UnimplementedHealthServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedHealthServiceServer) QueryGuardHealth ¶
func (UnimplementedHealthServiceServer) QueryGuardHealth(context.Context, *QueryGuardHealthRequest) (*QueryGuardHealthResponse, error)
type UnimplementedQuotaServiceServer ¶
type UnimplementedQuotaServiceServer struct {
}
UnimplementedQuotaServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedQuotaServiceServer) GetToken ¶
func (UnimplementedQuotaServiceServer) GetToken(context.Context, *GetTokenRequest) (*GetTokenResponse, error)
func (UnimplementedQuotaServiceServer) GetTokenLease ¶
func (UnimplementedQuotaServiceServer) GetTokenLease(context.Context, *GetTokenLeaseRequest) (*GetTokenLeaseResponse, error)
func (UnimplementedQuotaServiceServer) SetTokenLeaseConsumed ¶
func (UnimplementedQuotaServiceServer) SetTokenLeaseConsumed(context.Context, *SetTokenLeaseConsumedRequest) (*SetTokenLeaseConsumedResponse, error)
func (UnimplementedQuotaServiceServer) ValidateToken ¶
func (UnimplementedQuotaServiceServer) ValidateToken(context.Context, *ValidateTokenRequest) (*ValidateTokenResponse, error)
type UnimplementedUsageServiceServer ¶
type UnimplementedUsageServiceServer struct {
}
UnimplementedUsageServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedUsageServiceServer) GetUsage ¶
func (UnimplementedUsageServiceServer) GetUsage(context.Context, *GetUsageRequest) (*GetUsageResponse, error)
type UnsafeAuthServiceServer ¶
type UnsafeAuthServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAuthServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthServiceServer will result in compilation errors.
type UnsafeConfigServiceServer ¶
type UnsafeConfigServiceServer interface {
// contains filtered or unexported methods
}
UnsafeConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConfigServiceServer will result in compilation errors.
type UnsafeHealthServiceServer ¶
type UnsafeHealthServiceServer interface {
// contains filtered or unexported methods
}
UnsafeHealthServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthServiceServer will result in compilation errors.
type UnsafeQuotaServiceServer ¶
type UnsafeQuotaServiceServer interface {
// contains filtered or unexported methods
}
UnsafeQuotaServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QuotaServiceServer will result in compilation errors.
type UnsafeUsageServiceServer ¶
type UnsafeUsageServiceServer interface {
// contains filtered or unexported methods
}
UnsafeUsageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UsageServiceServer will result in compilation errors.
type UsageServiceClient ¶
type UsageServiceClient interface {
GetUsage(ctx context.Context, in *GetUsageRequest, opts ...grpc.CallOption) (*GetUsageResponse, error)
}
UsageServiceClient is the client API for UsageService 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 NewUsageServiceClient ¶
func NewUsageServiceClient(cc grpc.ClientConnInterface) UsageServiceClient
type UsageServiceServer ¶
type UsageServiceServer interface {
GetUsage(context.Context, *GetUsageRequest) (*GetUsageResponse, error)
// contains filtered or unexported methods
}
UsageServiceServer is the server API for UsageService service. All implementations must embed UnimplementedUsageServiceServer for forward compatibility
type UsageTSDataPoint ¶
type UsageTSDataPoint struct {
StartTs *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
EndTs *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_ts,json=endTs,proto3" json:"end_ts,omitempty"`
Granted int32 `protobuf:"varint,3,opt,name=granted,proto3" json:"granted,omitempty"`
GrantedWeight float32 `protobuf:"fixed32,4,opt,name=granted_weight,json=grantedWeight,proto3" json:"granted_weight,omitempty"`
NotGranted int32 `protobuf:"varint,5,opt,name=not_granted,json=notGranted,proto3" json:"not_granted,omitempty"`
NotGrantedWeight float32 `protobuf:"fixed32,6,opt,name=not_granted_weight,json=notGrantedWeight,proto3" json:"not_granted_weight,omitempty"`
BeBurst *int32 `protobuf:"varint,7,opt,name=be_burst,json=beBurst,proto3,oneof" json:"be_burst,omitempty"`
BeBurstWeight *float32 `protobuf:"fixed32,8,opt,name=be_burst_weight,json=beBurstWeight,proto3,oneof" json:"be_burst_weight,omitempty"`
ParentReject *int32 `protobuf:"varint,9,opt,name=parent_reject,json=parentReject,proto3,oneof" json:"parent_reject,omitempty"`
ParentRejectWeight *float32 `` /* 126-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*UsageTSDataPoint) Descriptor
deprecated
func (*UsageTSDataPoint) Descriptor() ([]byte, []int)
Deprecated: Use UsageTSDataPoint.ProtoReflect.Descriptor instead.
func (*UsageTSDataPoint) GetBeBurst ¶
func (x *UsageTSDataPoint) GetBeBurst() int32
func (*UsageTSDataPoint) GetBeBurstWeight ¶
func (x *UsageTSDataPoint) GetBeBurstWeight() float32
func (*UsageTSDataPoint) GetEndTs ¶
func (x *UsageTSDataPoint) GetEndTs() *timestamppb.Timestamp
func (*UsageTSDataPoint) GetGranted ¶
func (x *UsageTSDataPoint) GetGranted() int32
func (*UsageTSDataPoint) GetGrantedWeight ¶
func (x *UsageTSDataPoint) GetGrantedWeight() float32
func (*UsageTSDataPoint) GetNotGranted ¶
func (x *UsageTSDataPoint) GetNotGranted() int32
func (*UsageTSDataPoint) GetNotGrantedWeight ¶
func (x *UsageTSDataPoint) GetNotGrantedWeight() float32
func (*UsageTSDataPoint) GetParentReject ¶
func (x *UsageTSDataPoint) GetParentReject() int32
func (*UsageTSDataPoint) GetParentRejectWeight ¶
func (x *UsageTSDataPoint) GetParentRejectWeight() float32
func (*UsageTSDataPoint) GetStartTs ¶
func (x *UsageTSDataPoint) GetStartTs() *timestamppb.Timestamp
func (*UsageTSDataPoint) ProtoMessage ¶
func (*UsageTSDataPoint) ProtoMessage()
func (*UsageTSDataPoint) ProtoReflect ¶
func (x *UsageTSDataPoint) ProtoReflect() protoreflect.Message
func (*UsageTSDataPoint) Reset ¶
func (x *UsageTSDataPoint) Reset()
func (*UsageTSDataPoint) String ¶
func (x *UsageTSDataPoint) String() string
type UsageTimeseries ¶
type UsageTimeseries struct {
Data []*UsageTSDataPoint `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
// Axes for this timeseries - may not be applicable if there are no axes being queried in report mode
Feature *string `protobuf:"bytes,3,opt,name=feature,proto3,oneof" json:"feature,omitempty"`
Priority *int32 `protobuf:"varint,4,opt,name=priority,proto3,oneof" json:"priority,omitempty"`
Tags []*Tag `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
Guard *string `protobuf:"bytes,6,opt,name=guard,proto3,oneof" json:"guard,omitempty"`
// contains filtered or unexported fields
}
func (*UsageTimeseries) Descriptor
deprecated
func (*UsageTimeseries) Descriptor() ([]byte, []int)
Deprecated: Use UsageTimeseries.ProtoReflect.Descriptor instead.
func (*UsageTimeseries) GetData ¶
func (x *UsageTimeseries) GetData() []*UsageTSDataPoint
func (*UsageTimeseries) GetFeature ¶
func (x *UsageTimeseries) GetFeature() string
func (*UsageTimeseries) GetGuard ¶
func (x *UsageTimeseries) GetGuard() string
func (*UsageTimeseries) GetPriority ¶
func (x *UsageTimeseries) GetPriority() int32
func (*UsageTimeseries) GetTags ¶
func (x *UsageTimeseries) GetTags() []*Tag
func (*UsageTimeseries) ProtoMessage ¶
func (*UsageTimeseries) ProtoMessage()
func (*UsageTimeseries) ProtoReflect ¶
func (x *UsageTimeseries) ProtoReflect() protoreflect.Message
func (*UsageTimeseries) Reset ¶
func (x *UsageTimeseries) Reset()
func (*UsageTimeseries) String ¶
func (x *UsageTimeseries) String() string
type ValidateTokenRequest ¶
type ValidateTokenRequest struct {
Tokens []*TokenInfo `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
// contains filtered or unexported fields
}
Calls Hub to validate a token (ensures token has not expired, was minted by Hub, and related to the specified Guard). Used from Ingress Guards. Ensures callers have acquired quota prior to expending resources.
func (*ValidateTokenRequest) Descriptor
deprecated
func (*ValidateTokenRequest) Descriptor() ([]byte, []int)
Deprecated: Use ValidateTokenRequest.ProtoReflect.Descriptor instead.
func (*ValidateTokenRequest) GetTokens ¶
func (x *ValidateTokenRequest) GetTokens() []*TokenInfo
func (*ValidateTokenRequest) ProtoMessage ¶
func (*ValidateTokenRequest) ProtoMessage()
func (*ValidateTokenRequest) ProtoReflect ¶
func (x *ValidateTokenRequest) ProtoReflect() protoreflect.Message
func (*ValidateTokenRequest) Reset ¶
func (x *ValidateTokenRequest) Reset()
func (*ValidateTokenRequest) String ¶
func (x *ValidateTokenRequest) String() string
type ValidateTokenResponse ¶
type ValidateTokenResponse struct {
Valid bool `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"` // Unused, does not work in batch mode, will remove in V1 API
TokensValid []*TokenValid `protobuf:"bytes,2,rep,name=tokens_valid,json=tokensValid,proto3" json:"tokens_valid,omitempty"`
// contains filtered or unexported fields
}
Specifies whether tokens were valid or not.
func (*ValidateTokenResponse) Descriptor
deprecated
func (*ValidateTokenResponse) Descriptor() ([]byte, []int)
Deprecated: Use ValidateTokenResponse.ProtoReflect.Descriptor instead.
func (*ValidateTokenResponse) GetTokensValid ¶
func (x *ValidateTokenResponse) GetTokensValid() []*TokenValid
func (*ValidateTokenResponse) GetValid ¶
func (x *ValidateTokenResponse) GetValid() bool
func (*ValidateTokenResponse) ProtoMessage ¶
func (*ValidateTokenResponse) ProtoMessage()
func (*ValidateTokenResponse) ProtoReflect ¶
func (x *ValidateTokenResponse) ProtoReflect() protoreflect.Message
func (*ValidateTokenResponse) Reset ¶
func (x *ValidateTokenResponse) Reset()
func (*ValidateTokenResponse) String ¶
func (x *ValidateTokenResponse) String() string