hubv1

package
v1.36.11-2023102612341... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 7 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
var (
	Config_name = map[int32]string{
		0: "CONFIG_UNSPECIFIED",
		1: "CONFIG_CACHED_OK",
		2: "CONFIG_FETCHED_OK",
		3: "CONFIG_NOT_FOUND",
		4: "CONFIG_FETCH_ERROR",
		5: "CONFIG_FETCH_TIMEOUT",
	}
	Config_value = map[string]int32{
		"CONFIG_UNSPECIFIED":   0,
		"CONFIG_CACHED_OK":     1,
		"CONFIG_FETCHED_OK":    2,
		"CONFIG_NOT_FOUND":     3,
		"CONFIG_FETCH_ERROR":   4,
		"CONFIG_FETCH_TIMEOUT": 5,
	}
)

Enum value maps for Config.

View Source 
var (
	Local_name = map[int32]string{
		0: "LOCAL_UNSPECIFIED",
		1: "LOCAL_NOT_SUPPORTED",
		2: "LOCAL_NOT_EVAL",
		3: "LOCAL_EVAL_DISABLED",
		4: "LOCAL_ALLOWED",
		5: "LOCAL_BLOCKED",
		6: "LOCAL_ERROR",
	}
	Local_value = map[string]int32{
		"LOCAL_UNSPECIFIED":   0,
		"LOCAL_NOT_SUPPORTED": 1,
		"LOCAL_NOT_EVAL":      2,
		"LOCAL_EVAL_DISABLED": 3,
		"LOCAL_ALLOWED":       4,
		"LOCAL_BLOCKED":       5,
		"LOCAL_ERROR":         6,
	}
)

Enum value maps for Local.

View Source 
var (
	Token_name = map[int32]string{
		0: "TOKEN_UNSPECIFIED",
		1: "TOKEN_NOT_EVAL",
		2: "TOKEN_EVAL_DISABLED",
		3: "TOKEN_NOT_VALID",
		4: "TOKEN_VALID",
		5: "TOKEN_VALIDATION_ERROR",
		6: "TOKEN_VALIDATION_TIMEOUT",
	}
	Token_value = map[string]int32{
		"TOKEN_UNSPECIFIED":        0,
		"TOKEN_NOT_EVAL":           1,
		"TOKEN_EVAL_DISABLED":      2,
		"TOKEN_NOT_VALID":          3,
		"TOKEN_VALID":              4,
		"TOKEN_VALIDATION_ERROR":   5,
		"TOKEN_VALIDATION_TIMEOUT": 6,
	}
)

Enum value maps for Token.

View Source 
var (
	Quota_name = map[int32]string{
		0: "QUOTA_UNSPECIFIED",
		1: "QUOTA_NOT_EVAL",
		2: "QUOTA_EVAL_DISABLED",
		3: "QUOTA_LOCAL_ERROR",
		4: "QUOTA_BLOCKED",
		5: "QUOTA_GRANTED",
		6: "QUOTA_ERROR",
		7: "QUOTA_TIMEOUT",
	}
	Quota_value = map[string]int32{
		"QUOTA_UNSPECIFIED":   0,
		"QUOTA_NOT_EVAL":      1,
		"QUOTA_EVAL_DISABLED": 2,
		"QUOTA_LOCAL_ERROR":   3,
		"QUOTA_BLOCKED":       4,
		"QUOTA_GRANTED":       5,
		"QUOTA_ERROR":         6,
		"QUOTA_TIMEOUT":       7,
	}
)

Enum value maps for Quota.

View Source 
var (
	Mode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		1: "MODE_NORMAL",
		2: "MODE_REPORT_ONLY",
	}
	Mode_value = map[string]int32{
		"MODE_UNSPECIFIED": 0,
		"MODE_NORMAL":      1,
		"MODE_REPORT_ONLY": 2,
	}
)

Enum value maps for Mode.

View Source 
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.

View Source 
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.

View Source 
var File_stanza_hub_v1_auth_proto protoreflect.FileDescriptor
View Source 
var File_stanza_hub_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_stanza_hub_v1_config_proto protoreflect.FileDescriptor
View Source 
var File_stanza_hub_v1_health_proto protoreflect.FileDescriptor
View Source 
var File_stanza_hub_v1_quota_proto protoreflect.FileDescriptor
View Source 
var File_stanza_hub_v1_stream_proto protoreflect.FileDescriptor
View Source 
var File_stanza_hub_v1_usage_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

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

func (x *BrowserConfig) ClearActionCodeDisabled()

func (*BrowserConfig) ClearActionCodeEnabled 

func (x *BrowserConfig) ClearActionCodeEnabled()

func (*BrowserConfig) ClearEnabledPercent 

func (x *BrowserConfig) ClearEnabledPercent()

func (*BrowserConfig) ClearMessageDisabled 

func (x *BrowserConfig) ClearMessageDisabled()

func (*BrowserConfig) ClearMessageEnabled 

func (x *BrowserConfig) ClearMessageEnabled()

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

func (x *BrowserConfig) HasActionCodeDisabled() bool

func (*BrowserConfig) HasActionCodeEnabled 

func (x *BrowserConfig) HasActionCodeEnabled() bool

func (*BrowserConfig) HasEnabledPercent 

func (x *BrowserConfig) HasEnabledPercent() bool

func (*BrowserConfig) HasMessageDisabled 

func (x *BrowserConfig) HasMessageDisabled() bool

func (*BrowserConfig) HasMessageEnabled 

func (x *BrowserConfig) HasMessageEnabled() bool

func (*BrowserConfig) ProtoMessage 

func (*BrowserConfig) ProtoMessage()

func (*BrowserConfig) ProtoReflect 

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

func (*BrowserConfig) Reset 

func (x *BrowserConfig) Reset()

func (*BrowserConfig) SetActionCodeDisabled 

func (x *BrowserConfig) SetActionCodeDisabled(v uint32)

func (*BrowserConfig) SetActionCodeEnabled 

func (x *BrowserConfig) SetActionCodeEnabled(v uint32)

func (*BrowserConfig) SetEnabledPercent 

func (x *BrowserConfig) SetEnabledPercent(v uint32)

func (*BrowserConfig) SetMessageDisabled 

func (x *BrowserConfig) SetMessageDisabled(v string)

func (*BrowserConfig) SetMessageEnabled 

func (x *BrowserConfig) SetMessageEnabled(v string)

func (*BrowserConfig) String 

func (x *BrowserConfig) String() string

type BrowserConfig_builder 

type BrowserConfig_builder struct {
	EnabledPercent     *uint32
	ActionCodeEnabled  *uint32
	MessageEnabled     *string
	ActionCodeDisabled *uint32
	MessageDisabled    *string
	// contains filtered or unexported fields
}

func (BrowserConfig_builder) Build 

func (b0 BrowserConfig_builder) Build() *BrowserConfig

type Config 

type Config int32

Config describes config state reasons used by Stanza SDKs 

const (
	Config_CONFIG_UNSPECIFIED   Config = 0
	Config_CONFIG_CACHED_OK     Config = 1 // SDK has successfully fetched guard config previously and cached it
	Config_CONFIG_FETCHED_OK    Config = 2 // SDK has successfully fetched guard config in response to this request
	Config_CONFIG_NOT_FOUND     Config = 3 // SDK tried to fetch a Guard whose config could not be found
	Config_CONFIG_FETCH_ERROR   Config = 4 // SDK received an error from the Stanza control plane
	Config_CONFIG_FETCH_TIMEOUT Config = 5 // SDK timed out trying to get config from the Stanza control plane
)

func (Config) Descriptor 

func (Config) Descriptor() protoreflect.EnumDescriptor

func (Config) Enum 

func (x Config) Enum() *Config

func (Config) Number 

func (x Config) Number() protoreflect.EnumNumber

func (Config) String 

func (x Config) String() string

func (Config) Type 

func (Config) Type() protoreflect.EnumType

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

func (x *FeatureConfig) ClearConfig()

func (*FeatureConfig) GetConfig 

func (x *FeatureConfig) GetConfig() *BrowserConfig

func (*FeatureConfig) GetName 

func (x *FeatureConfig) GetName() string

func (*FeatureConfig) HasConfig 

func (x *FeatureConfig) HasConfig() bool

func (*FeatureConfig) ProtoMessage 

func (*FeatureConfig) ProtoMessage()

func (*FeatureConfig) ProtoReflect 

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

func (*FeatureConfig) Reset 

func (x *FeatureConfig) Reset()

func (*FeatureConfig) SetConfig 

func (x *FeatureConfig) SetConfig(v *BrowserConfig)

func (*FeatureConfig) SetName 

func (x *FeatureConfig) SetName(v string)

func (*FeatureConfig) String 

func (x *FeatureConfig) String() string

type FeatureConfig_builder 

type FeatureConfig_builder struct {
	Name   string
	Config *BrowserConfig
	// contains filtered or unexported fields
}

func (FeatureConfig_builder) Build 

func (b0 FeatureConfig_builder) Build() *FeatureConfig

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

func (x *FeatureSelector) SetEnvironment(v string)

func (*FeatureSelector) SetNames 

func (x *FeatureSelector) SetNames(v []string)

func (*FeatureSelector) SetTags 

func (x *FeatureSelector) SetTags(v []*Tag)

func (*FeatureSelector) String 

func (x *FeatureSelector) String() string

type FeatureSelector_builder 

type FeatureSelector_builder struct {
	Environment string
	Names       []string
	Tags        []*Tag
	// contains filtered or unexported fields
}

func (FeatureSelector_builder) Build 

func (b0 FeatureSelector_builder) Build() *FeatureSelector

type GetBearerTokenRequest 

type GetBearerTokenRequest struct {
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"` // Must be specified.
	// contains filtered or unexported fields
}

GetBearerTokenRequest is empty, please pass your API key via a X-Stanza-Key header.

func (*GetBearerTokenRequest) GetEnvironment 

func (x *GetBearerTokenRequest) GetEnvironment() string

func (*GetBearerTokenRequest) ProtoMessage 

func (*GetBearerTokenRequest) ProtoMessage()

func (*GetBearerTokenRequest) ProtoReflect 

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

func (*GetBearerTokenRequest) Reset 

func (x *GetBearerTokenRequest) Reset()

func (*GetBearerTokenRequest) SetEnvironment 

func (x *GetBearerTokenRequest) SetEnvironment(v string)

func (*GetBearerTokenRequest) String 

func (x *GetBearerTokenRequest) String() string

type GetBearerTokenRequest_builder 

type GetBearerTokenRequest_builder struct {
	Environment string
	// contains filtered or unexported fields
}

func (GetBearerTokenRequest_builder) Build 

func (b0 GetBearerTokenRequest_builder) Build() *GetBearerTokenRequest

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

func (x *GetBearerTokenResponse) SetBearerToken(v string)

func (*GetBearerTokenResponse) String 

func (x *GetBearerTokenResponse) String() string

type GetBearerTokenResponse_builder 

type GetBearerTokenResponse_builder struct {
	BearerToken string
	// contains filtered or unexported fields
}

func (GetBearerTokenResponse_builder) Build 

func (b0 GetBearerTokenResponse_builder) Build() *GetBearerTokenResponse

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

func (x *GetBrowserContextRequest) ClearFeature()

func (*GetBrowserContextRequest) GetFeature 

func (x *GetBrowserContextRequest) GetFeature() *FeatureSelector

func (*GetBrowserContextRequest) HasFeature 

func (x *GetBrowserContextRequest) HasFeature() bool

func (*GetBrowserContextRequest) ProtoMessage 

func (*GetBrowserContextRequest) ProtoMessage()

func (*GetBrowserContextRequest) ProtoReflect 

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

func (*GetBrowserContextRequest) Reset 

func (x *GetBrowserContextRequest) Reset()

func (*GetBrowserContextRequest) SetFeature 

func (x *GetBrowserContextRequest) SetFeature(v *FeatureSelector)

func (*GetBrowserContextRequest) String 

func (x *GetBrowserContextRequest) String() string

type GetBrowserContextRequest_builder 

type GetBrowserContextRequest_builder 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
	// contains filtered or unexported fields
}

func (GetBrowserContextRequest_builder) Build 

func (b0 GetBrowserContextRequest_builder) Build() *GetBrowserContextRequest

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

func (x *GetBrowserContextResponse) SetFeatureConfigs(v []*FeatureConfig)

func (*GetBrowserContextResponse) String 

func (x *GetBrowserContextResponse) String() string

type GetBrowserContextResponse_builder 

type GetBrowserContextResponse_builder struct {
	FeatureConfigs []*FeatureConfig
	// contains filtered or unexported fields
}

func (GetBrowserContextResponse_builder) Build 

func (b0 GetBrowserContextResponse_builder) Build() *GetBrowserContextResponse

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

func (x *GetGuardConfigRequest) ClearSelector()

func (*GetGuardConfigRequest) ClearVersionSeen 

func (x *GetGuardConfigRequest) ClearVersionSeen()

func (*GetGuardConfigRequest) GetSelector 

func (x *GetGuardConfigRequest) GetSelector() *GuardServiceSelector

func (*GetGuardConfigRequest) GetVersionSeen 

func (x *GetGuardConfigRequest) GetVersionSeen() string

func (*GetGuardConfigRequest) HasSelector 

func (x *GetGuardConfigRequest) HasSelector() bool

func (*GetGuardConfigRequest) HasVersionSeen 

func (x *GetGuardConfigRequest) HasVersionSeen() bool

func (*GetGuardConfigRequest) ProtoMessage 

func (*GetGuardConfigRequest) ProtoMessage()

func (*GetGuardConfigRequest) ProtoReflect 

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

func (*GetGuardConfigRequest) Reset 

func (x *GetGuardConfigRequest) Reset()

func (*GetGuardConfigRequest) SetSelector 

func (x *GetGuardConfigRequest) SetSelector(v *GuardServiceSelector)

func (*GetGuardConfigRequest) SetVersionSeen 

func (x *GetGuardConfigRequest) SetVersionSeen(v string)

func (*GetGuardConfigRequest) String 

func (x *GetGuardConfigRequest) String() string

type GetGuardConfigRequest_builder 

type GetGuardConfigRequest_builder struct {

	// Set if the client has seen a previous version of the config. Server will send data only if newer config available.
	VersionSeen *string
	// Information required to select and return the correct GuardConfig version.
	Selector *GuardServiceSelector
	// contains filtered or unexported fields
}

func (GetGuardConfigRequest_builder) Build 

func (b0 GetGuardConfigRequest_builder) Build() *GetGuardConfigRequest

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

func (x *GetGuardConfigResponse) ClearConfig()

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

func (x *GetGuardConfigResponse) HasConfig() bool

func (*GetGuardConfigResponse) ProtoMessage 

func (*GetGuardConfigResponse) ProtoMessage()

func (*GetGuardConfigResponse) ProtoReflect 

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

func (*GetGuardConfigResponse) Reset 

func (x *GetGuardConfigResponse) Reset()

func (*GetGuardConfigResponse) SetConfig 

func (x *GetGuardConfigResponse) SetConfig(v *GuardConfig)

func (*GetGuardConfigResponse) SetConfigDataSent 

func (x *GetGuardConfigResponse) SetConfigDataSent(v bool)

func (*GetGuardConfigResponse) SetVersion 

func (x *GetGuardConfigResponse) SetVersion(v string)

func (*GetGuardConfigResponse) String 

func (x *GetGuardConfigResponse) String() string

type GetGuardConfigResponse_builder 

type GetGuardConfigResponse_builder struct {
	Version        string
	ConfigDataSent bool
	Config         *GuardConfig
	// contains filtered or unexported fields
}

func (GetGuardConfigResponse_builder) Build 

func (b0 GetGuardConfigResponse_builder) Build() *GetGuardConfigResponse

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

func (x *GetServiceConfigRequest) ClearClientId()

func (*GetServiceConfigRequest) ClearService 

func (x *GetServiceConfigRequest) ClearService()

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

func (x *GetServiceConfigRequest) HasClientId() bool

func (*GetServiceConfigRequest) HasService 

func (x *GetServiceConfigRequest) HasService() bool

func (*GetServiceConfigRequest) ProtoMessage 

func (*GetServiceConfigRequest) ProtoMessage()

func (*GetServiceConfigRequest) ProtoReflect 

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

func (*GetServiceConfigRequest) Reset 

func (x *GetServiceConfigRequest) Reset()

func (*GetServiceConfigRequest) SetClientId 

func (x *GetServiceConfigRequest) SetClientId(v string)

func (*GetServiceConfigRequest) SetService 

func (x *GetServiceConfigRequest) SetService(v *ServiceSelector)

func (*GetServiceConfigRequest) SetVersionSeen 

func (x *GetServiceConfigRequest) SetVersionSeen(v string)

func (*GetServiceConfigRequest) String 

func (x *GetServiceConfigRequest) String() string

type GetServiceConfigRequest_builder 

type GetServiceConfigRequest_builder struct {

	// Set if the client has seen a previous version of the config. Server will send data only if newer config available.
	VersionSeen string
	// Information required to select and return the most recent ServiceConfig version
	Service *ServiceSelector
	// 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
	// contains filtered or unexported fields
}

func (GetServiceConfigRequest_builder) Build 

func (b0 GetServiceConfigRequest_builder) Build() *GetServiceConfigRequest

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

func (x *GetServiceConfigResponse) ClearConfig()

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

func (x *GetServiceConfigResponse) HasConfig() bool

func (*GetServiceConfigResponse) ProtoMessage 

func (*GetServiceConfigResponse) ProtoMessage()

func (*GetServiceConfigResponse) ProtoReflect 

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

func (*GetServiceConfigResponse) Reset 

func (x *GetServiceConfigResponse) Reset()

func (*GetServiceConfigResponse) SetConfig 

func (x *GetServiceConfigResponse) SetConfig(v *ServiceConfig)

func (*GetServiceConfigResponse) SetConfigDataSent 

func (x *GetServiceConfigResponse) SetConfigDataSent(v bool)

func (*GetServiceConfigResponse) SetVersion 

func (x *GetServiceConfigResponse) SetVersion(v string)

func (*GetServiceConfigResponse) String 

func (x *GetServiceConfigResponse) String() string

type GetServiceConfigResponse_builder 

type GetServiceConfigResponse_builder struct {
	Version        string
	ConfigDataSent bool
	Config         *ServiceConfig
	// contains filtered or unexported fields
}

func (GetServiceConfigResponse_builder) Build 

func (b0 GetServiceConfigResponse_builder) Build() *GetServiceConfigResponse

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.
	// It is important that this value be stable over the lifetime of an instance: if it changes, then Stanza will not be able to efficiently assign batches of tokens.
	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) ClearClientId 

func (x *GetTokenLeaseRequest) ClearClientId()

func (*GetTokenLeaseRequest) ClearDefaultWeight 

func (x *GetTokenLeaseRequest) ClearDefaultWeight()

func (*GetTokenLeaseRequest) ClearPriorityBoost 

func (x *GetTokenLeaseRequest) ClearPriorityBoost()

func (*GetTokenLeaseRequest) ClearSelector 

func (x *GetTokenLeaseRequest) ClearSelector()

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

func (x *GetTokenLeaseRequest) HasClientId() bool

func (*GetTokenLeaseRequest) HasDefaultWeight 

func (x *GetTokenLeaseRequest) HasDefaultWeight() bool

func (*GetTokenLeaseRequest) HasPriorityBoost 

func (x *GetTokenLeaseRequest) HasPriorityBoost() bool

func (*GetTokenLeaseRequest) HasSelector 

func (x *GetTokenLeaseRequest) HasSelector() bool

func (*GetTokenLeaseRequest) ProtoMessage 

func (*GetTokenLeaseRequest) ProtoMessage()

func (*GetTokenLeaseRequest) ProtoReflect 

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

func (*GetTokenLeaseRequest) Reset 

func (x *GetTokenLeaseRequest) Reset()

func (*GetTokenLeaseRequest) SetClientId 

func (x *GetTokenLeaseRequest) SetClientId(v string)

func (*GetTokenLeaseRequest) SetDefaultWeight 

func (x *GetTokenLeaseRequest) SetDefaultWeight(v float32)

func (*GetTokenLeaseRequest) SetPriorityBoost 

func (x *GetTokenLeaseRequest) SetPriorityBoost(v int32)

func (*GetTokenLeaseRequest) SetSelector 

func (x *GetTokenLeaseRequest) SetSelector(v *GuardFeatureSelector)

func (*GetTokenLeaseRequest) String 

func (x *GetTokenLeaseRequest) String() string

type GetTokenLeaseRequest_builder 

type GetTokenLeaseRequest_builder 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
	// 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.
	// It is important that this value be stable over the lifetime of an instance: if it changes, then Stanza will not be able to efficiently assign batches of tokens.
	ClientId *string
	// 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
	// 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
	// contains filtered or unexported fields
}

func (GetTokenLeaseRequest_builder) Build 

func (b0 GetTokenLeaseRequest_builder) Build() *GetTokenLeaseRequest

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

func (x *GetTokenLeaseResponse) SetGranted(v bool)

func (*GetTokenLeaseResponse) SetLeases 

func (x *GetTokenLeaseResponse) SetLeases(v []*TokenLease)

func (*GetTokenLeaseResponse) String 

func (x *GetTokenLeaseResponse) String() string

type GetTokenLeaseResponse_builder 

type GetTokenLeaseResponse_builder struct {
	Granted bool
	Leases  []*TokenLease
	// contains filtered or unexported fields
}

func (GetTokenLeaseResponse_builder) Build 

func (b0 GetTokenLeaseResponse_builder) Build() *GetTokenLeaseResponse

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.
	// It is important that this value be stable over the lifetime of an instance: if it changes, then Stanza will not be able to efficiently assign batches of tokens.
	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) ClearClientId 

func (x *GetTokenRequest) ClearClientId()

func (*GetTokenRequest) ClearPriorityBoost 

func (x *GetTokenRequest) ClearPriorityBoost()

func (*GetTokenRequest) ClearSelector 

func (x *GetTokenRequest) ClearSelector()

func (*GetTokenRequest) ClearWeight 

func (x *GetTokenRequest) ClearWeight()

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

func (x *GetTokenRequest) HasClientId() bool

func (*GetTokenRequest) HasPriorityBoost 

func (x *GetTokenRequest) HasPriorityBoost() bool

func (*GetTokenRequest) HasSelector 

func (x *GetTokenRequest) HasSelector() bool

func (*GetTokenRequest) HasWeight 

func (x *GetTokenRequest) HasWeight() bool

func (*GetTokenRequest) ProtoMessage 

func (*GetTokenRequest) ProtoMessage()

func (*GetTokenRequest) ProtoReflect 

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

func (*GetTokenRequest) Reset 

func (x *GetTokenRequest) Reset()

func (*GetTokenRequest) SetClientId 

func (x *GetTokenRequest) SetClientId(v string)

func (*GetTokenRequest) SetPriorityBoost 

func (x *GetTokenRequest) SetPriorityBoost(v int32)

func (*GetTokenRequest) SetSelector 

func (x *GetTokenRequest) SetSelector(v *GuardFeatureSelector)

func (*GetTokenRequest) SetWeight 

func (x *GetTokenRequest) SetWeight(v float32)

func (*GetTokenRequest) String 

func (x *GetTokenRequest) String() string

type GetTokenRequest_builder 

type GetTokenRequest_builder 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
	// 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.
	// It is important that this value be stable over the lifetime of an instance: if it changes, then Stanza will not be able to efficiently assign batches of tokens.
	ClientId *string
	// Used to increase or decrease priority of request, relative to normal feature priority.
	PriorityBoost *int32
	// 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
	// contains filtered or unexported fields
}

func (GetTokenRequest_builder) Build 

func (b0 GetTokenRequest_builder) Build() *GetTokenRequest

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"`
	Mode    *Mode   `protobuf:"varint,4,opt,name=mode,proto3,enum=stanza.hub.v1.Mode,oneof" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

Specifies whether token granted.

func (*GetTokenResponse) ClearMode 

func (x *GetTokenResponse) ClearMode()

func (*GetTokenResponse) ClearReason 

func (x *GetTokenResponse) ClearReason()

func (*GetTokenResponse) ClearToken 

func (x *GetTokenResponse) ClearToken()

func (*GetTokenResponse) GetGranted 

func (x *GetTokenResponse) GetGranted() bool

func (*GetTokenResponse) GetMode 

func (x *GetTokenResponse) GetMode() Mode

func (*GetTokenResponse) GetReason 

func (x *GetTokenResponse) GetReason() Reason

func (*GetTokenResponse) GetToken 

func (x *GetTokenResponse) GetToken() string

func (*GetTokenResponse) HasMode 

func (x *GetTokenResponse) HasMode() bool

func (*GetTokenResponse) HasReason 

func (x *GetTokenResponse) HasReason() bool

func (*GetTokenResponse) HasToken 

func (x *GetTokenResponse) HasToken() bool

func (*GetTokenResponse) ProtoMessage 

func (*GetTokenResponse) ProtoMessage()

func (*GetTokenResponse) ProtoReflect 

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

func (*GetTokenResponse) Reset 

func (x *GetTokenResponse) Reset()

func (*GetTokenResponse) SetGranted 

func (x *GetTokenResponse) SetGranted(v bool)

func (*GetTokenResponse) SetMode 

func (x *GetTokenResponse) SetMode(v Mode)

func (*GetTokenResponse) SetReason 

func (x *GetTokenResponse) SetReason(v Reason)

func (*GetTokenResponse) SetToken 

func (x *GetTokenResponse) SetToken(v string)

func (*GetTokenResponse) String 

func (x *GetTokenResponse) String() string

type GetTokenResponse_builder 

type GetTokenResponse_builder struct {
	Granted bool
	Token   *string
	Reason  *Reason
	Mode    *Mode
	// contains filtered or unexported fields
}

func (GetTokenResponse_builder) Build 

func (b0 GetTokenResponse_builder) Build() *GetTokenResponse

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 */
	// Query for stats about a specific service. If not specified then stats for all services are returned.
	// Note that Stanza can only track service statistics if client_id is used when requesting service configuration at startup, and sent with quota requests.
	Service           *string    `protobuf:"bytes,15,opt,name=service,proto3,oneof" json:"service,omitempty"`
	ServiceQueryMode  *QueryMode ``                                                                                                               /* 148-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) ClearApikey 

func (x *GetUsageRequest) ClearApikey()

func (*GetUsageRequest) ClearEndTs 

func (x *GetUsageRequest) ClearEndTs()

func (*GetUsageRequest) ClearFeature 

func (x *GetUsageRequest) ClearFeature()

func (*GetUsageRequest) ClearFeatureQueryMode 

func (x *GetUsageRequest) ClearFeatureQueryMode()

func (*GetUsageRequest) ClearGuard 

func (x *GetUsageRequest) ClearGuard()

func (*GetUsageRequest) ClearGuardQueryMode 

func (x *GetUsageRequest) ClearGuardQueryMode()

func (*GetUsageRequest) ClearPriority 

func (x *GetUsageRequest) ClearPriority()

func (*GetUsageRequest) ClearPriorityQueryMode 

func (x *GetUsageRequest) ClearPriorityQueryMode()

func (*GetUsageRequest) ClearReportAllTags 

func (x *GetUsageRequest) ClearReportAllTags()

func (*GetUsageRequest) ClearService 

func (x *GetUsageRequest) ClearService()

func (*GetUsageRequest) ClearServiceQueryMode 

func (x *GetUsageRequest) ClearServiceQueryMode()

func (*GetUsageRequest) ClearStartTs 

func (x *GetUsageRequest) ClearStartTs()

func (*GetUsageRequest) ClearStep 

func (x *GetUsageRequest) ClearStep()

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

func (x *GetUsageRequest) GetService() string

func (*GetUsageRequest) GetServiceQueryMode 

func (x *GetUsageRequest) GetServiceQueryMode() QueryMode

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

func (x *GetUsageRequest) HasApikey() bool

func (*GetUsageRequest) HasEndTs 

func (x *GetUsageRequest) HasEndTs() bool

func (*GetUsageRequest) HasFeature 

func (x *GetUsageRequest) HasFeature() bool

func (*GetUsageRequest) HasFeatureQueryMode 

func (x *GetUsageRequest) HasFeatureQueryMode() bool

func (*GetUsageRequest) HasGuard 

func (x *GetUsageRequest) HasGuard() bool

func (*GetUsageRequest) HasGuardQueryMode 

func (x *GetUsageRequest) HasGuardQueryMode() bool

func (*GetUsageRequest) HasPriority 

func (x *GetUsageRequest) HasPriority() bool

func (*GetUsageRequest) HasPriorityQueryMode 

func (x *GetUsageRequest) HasPriorityQueryMode() bool

func (*GetUsageRequest) HasReportAllTags 

func (x *GetUsageRequest) HasReportAllTags() bool

func (*GetUsageRequest) HasService 

func (x *GetUsageRequest) HasService() bool

func (*GetUsageRequest) HasServiceQueryMode 

func (x *GetUsageRequest) HasServiceQueryMode() bool

func (*GetUsageRequest) HasStartTs 

func (x *GetUsageRequest) HasStartTs() bool

func (*GetUsageRequest) HasStep 

func (x *GetUsageRequest) HasStep() bool

func (*GetUsageRequest) ProtoMessage 

func (*GetUsageRequest) ProtoMessage()

func (*GetUsageRequest) ProtoReflect 

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

func (*GetUsageRequest) Reset 

func (x *GetUsageRequest) Reset()

func (*GetUsageRequest) SetApikey 

func (x *GetUsageRequest) SetApikey(v string)

func (*GetUsageRequest) SetEndTs 

func (x *GetUsageRequest) SetEndTs(v *timestamppb.Timestamp)

func (*GetUsageRequest) SetEnvironment 

func (x *GetUsageRequest) SetEnvironment(v string)

func (*GetUsageRequest) SetFeature 

func (x *GetUsageRequest) SetFeature(v string)

func (*GetUsageRequest) SetFeatureQueryMode 

func (x *GetUsageRequest) SetFeatureQueryMode(v QueryMode)

func (*GetUsageRequest) SetGuard 

func (x *GetUsageRequest) SetGuard(v string)

func (*GetUsageRequest) SetGuardQueryMode 

func (x *GetUsageRequest) SetGuardQueryMode(v QueryMode)

func (*GetUsageRequest) SetPriority 

func (x *GetUsageRequest) SetPriority(v int32)

func (*GetUsageRequest) SetPriorityQueryMode 

func (x *GetUsageRequest) SetPriorityQueryMode(v QueryMode)

func (*GetUsageRequest) SetReportAllTags 

func (x *GetUsageRequest) SetReportAllTags(v bool)

func (*GetUsageRequest) SetReportTags 

func (x *GetUsageRequest) SetReportTags(v []string)

func (*GetUsageRequest) SetService 

func (x *GetUsageRequest) SetService(v string)

func (*GetUsageRequest) SetServiceQueryMode 

func (x *GetUsageRequest) SetServiceQueryMode(v QueryMode)

func (*GetUsageRequest) SetStartTs 

func (x *GetUsageRequest) SetStartTs(v *timestamppb.Timestamp)

func (*GetUsageRequest) SetStep 

func (x *GetUsageRequest) SetStep(v string)

func (*GetUsageRequest) SetTags 

func (x *GetUsageRequest) SetTags(v []*Tag)

func (*GetUsageRequest) String 

func (x *GetUsageRequest) String() string

type GetUsageRequest_builder 

type GetUsageRequest_builder 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
	Guard            *string
	GuardQueryMode   *QueryMode
	StartTs          *timestamppb.Timestamp
	EndTs            *timestamppb.Timestamp
	Apikey           *string
	Feature          *string
	FeatureQueryMode *QueryMode
	// Query for stats about a specific service. If not specified then stats for all services are returned.
	// Note that Stanza can only track service statistics if client_id is used when requesting service configuration at startup, and sent with quota requests.
	Service           *string
	ServiceQueryMode  *QueryMode
	Priority          *int32
	PriorityQueryMode *QueryMode
	ReportTags        []string
	Tags              []*Tag
	ReportAllTags     *bool
	Step              *string
	// contains filtered or unexported fields
}

func (GetUsageRequest_builder) Build 

func (b0 GetUsageRequest_builder) Build() *GetUsageRequest

type GetUsageResponse 

type GetUsageResponse struct {
	Result []*UsageTimeseries `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *GetUsageResponse) SetResult(v []*UsageTimeseries)

func (*GetUsageResponse) String 

func (x *GetUsageResponse) String() string

type GetUsageResponse_builder 

type GetUsageResponse_builder struct {
	Result []*UsageTimeseries
	// contains filtered or unexported fields
}

func (GetUsageResponse_builder) Build 

func (b0 GetUsageResponse_builder) Build() *GetUsageResponse

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.
	// If report_only is true then the SDK should perform all load management logic and emit statistics, but never actually throttle or deny requests for any reason.
	// However, the SDK should emit accurate metrics about what actions would normally be taken if Report Only mode were not enabled. The purpose of this is to allow
	// users to assess the impact of enabling a Guard without risking over-throttling traffic.
	// The label mode="report_only" should be set on all metrics sent to Stanza.
	ReportOnly bool `protobuf:"varint,7,opt,name=report_only,json=reportOnly,proto3" json:"report_only,omitempty"`
	// 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) GetCheckQuota 

func (x *GuardConfig) GetCheckQuota() bool

func (*GuardConfig) GetQuotaTags 

func (x *GuardConfig) GetQuotaTags() []string

func (*GuardConfig) GetReportOnly 

func (x *GuardConfig) GetReportOnly() bool

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

func (x *GuardConfig) SetCheckQuota(v bool)

func (*GuardConfig) SetQuotaTags 

func (x *GuardConfig) SetQuotaTags(v []string)

func (*GuardConfig) SetReportOnly 

func (x *GuardConfig) SetReportOnly(v bool)

func (*GuardConfig) SetValidateIngressTokens 

func (x *GuardConfig) SetValidateIngressTokens(v bool)

func (*GuardConfig) String 

func (x *GuardConfig) String() string

type GuardConfig_builder 

type GuardConfig_builder struct {
	ValidateIngressTokens bool
	// Quota
	CheckQuota bool
	QuotaTags  []string
	// If report_only is true then the SDK should perform all load management logic and emit statistics, but never actually throttle or deny requests for any reason.
	// However, the SDK should emit accurate metrics about what actions would normally be taken if Report Only mode were not enabled. The purpose of this is to allow
	// users to assess the impact of enabling a Guard without risking over-throttling traffic.
	// The label mode="report_only" should be set on all metrics sent to Stanza.
	ReportOnly bool
	// contains filtered or unexported fields
}

func (GuardConfig_builder) Build 

func (b0 GuardConfig_builder) Build() *GuardConfig

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

func (x *GuardFeatureSelector) ClearFeatureName()

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

func (x *GuardFeatureSelector) HasFeatureName() bool

func (*GuardFeatureSelector) ProtoMessage 

func (*GuardFeatureSelector) ProtoMessage()

func (*GuardFeatureSelector) ProtoReflect 

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

func (*GuardFeatureSelector) Reset 

func (x *GuardFeatureSelector) Reset()

func (*GuardFeatureSelector) SetEnvironment 

func (x *GuardFeatureSelector) SetEnvironment(v string)

func (*GuardFeatureSelector) SetFeatureName 

func (x *GuardFeatureSelector) SetFeatureName(v string)

func (*GuardFeatureSelector) SetGuardName 

func (x *GuardFeatureSelector) SetGuardName(v string)

func (*GuardFeatureSelector) SetTags 

func (x *GuardFeatureSelector) SetTags(v []*Tag)

func (*GuardFeatureSelector) String 

func (x *GuardFeatureSelector) String() string

type GuardFeatureSelector_builder 

type GuardFeatureSelector_builder struct {
	Environment string
	GuardName   string
	FeatureName *string
	Tags        []*Tag
	// contains filtered or unexported fields
}

func (GuardFeatureSelector_builder) Build 

func (b0 GuardFeatureSelector_builder) Build() *GuardFeatureSelector

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

func (x *GuardSelector) SetEnvironment(v string)

func (*GuardSelector) SetName 

func (x *GuardSelector) SetName(v string)

func (*GuardSelector) SetTags 

func (x *GuardSelector) SetTags(v []*Tag)

func (*GuardSelector) String 

func (x *GuardSelector) String() string

type GuardSelector_builder 

type GuardSelector_builder struct {
	Environment string
	Name        string
	Tags        []*Tag
	// contains filtered or unexported fields
}

func (GuardSelector_builder) Build 

func (b0 GuardSelector_builder) Build() *GuardSelector

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

func (x *GuardServiceSelector) SetEnvironment(v string)

func (*GuardServiceSelector) SetGuardName 

func (x *GuardServiceSelector) SetGuardName(v string)

func (*GuardServiceSelector) SetServiceName 

func (x *GuardServiceSelector) SetServiceName(v string)

func (*GuardServiceSelector) SetServiceRelease 

func (x *GuardServiceSelector) SetServiceRelease(v string)

func (*GuardServiceSelector) SetTags 

func (x *GuardServiceSelector) SetTags(v []*Tag)

func (*GuardServiceSelector) String 

func (x *GuardServiceSelector) String() string

type GuardServiceSelector_builder 

type GuardServiceSelector_builder struct {
	Environment    string
	GuardName      string
	ServiceName    string
	ServiceRelease string
	Tags           []*Tag
	// contains filtered or unexported fields
}

func (GuardServiceSelector_builder) Build 

func (b0 GuardServiceSelector_builder) Build() *GuardServiceSelector

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

func (x *HeaderTraceConfig) SetRequestHeaderNames(v []string)

func (*HeaderTraceConfig) SetResponseHeaderNames 

func (x *HeaderTraceConfig) SetResponseHeaderNames(v []string)

func (*HeaderTraceConfig) SetSpanSelectors 

func (x *HeaderTraceConfig) SetSpanSelectors(v []*SpanSelector)

func (*HeaderTraceConfig) String 

func (x *HeaderTraceConfig) String() string

type HeaderTraceConfig_builder 

type HeaderTraceConfig_builder struct {
	SpanSelectors       []*SpanSelector
	RequestHeaderNames  []string
	ResponseHeaderNames []string
	// contains filtered or unexported fields
}

func (HeaderTraceConfig_builder) Build 

func (b0 HeaderTraceConfig_builder) Build() *HeaderTraceConfig

type Health 

type Health int32
const (
	Health_HEALTH_UNSPECIFIED Health = 0
	Health_HEALTH_OK          Health = 1
	Health_HEALTH_OVERLOAD    Health = 2
	Health_HEALTH_DOWN        Health = 3
)

func (Health) Descriptor 

func (Health) Descriptor() protoreflect.EnumDescriptor

func (Health) Enum 

func (x Health) Enum() *Health

func (Health) Number 

func (x Health) Number() protoreflect.EnumNumber

func (Health) String 

func (x Health) String() string

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

func (x *HealthByPriority) SetHealth(v Health)

func (*HealthByPriority) SetPriority 

func (x *HealthByPriority) SetPriority(v uint32)

func (*HealthByPriority) String 

func (x *HealthByPriority) String() string

type HealthByPriority_builder 

type HealthByPriority_builder struct {
	Priority uint32
	Health   Health
	// contains filtered or unexported fields
}

func (HealthByPriority_builder) Build 

func (b0 HealthByPriority_builder) Build() *HealthByPriority

type Local 

type Local int32

Local describes Guard reasons used by Stanza SDKs 

const (
	Local_LOCAL_UNSPECIFIED   Local = 0
	Local_LOCAL_NOT_SUPPORTED Local = 1 // SDK does not support locally evaluated rules
	Local_LOCAL_NOT_EVAL      Local = 2 // SDK never evaluated (failed before local validation attempted)
	Local_LOCAL_EVAL_DISABLED Local = 3 // No locally evaluated rules exist for this guard or it was explicitly disabled
	Local_LOCAL_ALLOWED       Local = 4 // Abstract “allowed” by all locally evaluated rules
	Local_LOCAL_BLOCKED       Local = 5 // Abstract “blocked” by any locally evaluated rule
	Local_LOCAL_ERROR         Local = 6 // SDK experienced some locally-sourced error and could not perform local rule evaluation
)

func (Local) Descriptor 

func (Local) Descriptor() protoreflect.EnumDescriptor

func (Local) Enum 

func (x Local) Enum() *Local

func (Local) Number 

func (x Local) Number() protoreflect.EnumNumber

func (Local) String 

func (x Local) String() string

func (Local) Type 

func (Local) Type() protoreflect.EnumType

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

func (x *MetricConfig) ClearCollectorUrl()

func (*MetricConfig) GetCollectorUrl 

func (x *MetricConfig) GetCollectorUrl() string

func (*MetricConfig) HasCollectorUrl 

func (x *MetricConfig) HasCollectorUrl() bool

func (*MetricConfig) ProtoMessage 

func (*MetricConfig) ProtoMessage()

func (*MetricConfig) ProtoReflect 

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

func (*MetricConfig) Reset 

func (x *MetricConfig) Reset()

func (*MetricConfig) SetCollectorUrl 

func (x *MetricConfig) SetCollectorUrl(v string)

func (*MetricConfig) String 

func (x *MetricConfig) String() string

type MetricConfig_builder 

type MetricConfig_builder struct {
	CollectorUrl *string
	// contains filtered or unexported fields
}

func (MetricConfig_builder) Build 

func (b0 MetricConfig_builder) Build() *MetricConfig

type Mode 

type Mode int32

Mode describes what mode the Guard or Service is operating under. 

const (
	Mode_MODE_UNSPECIFIED Mode = 0
	Mode_MODE_NORMAL      Mode = 1 // Normal, Stanza may shed requests according to its configuration
	Mode_MODE_REPORT_ONLY Mode = 2 // Report-only, Stanza never sheds requests, but does perform all processing and records metrics about the actions that would be taken if in normal mode
)

func (Mode) Descriptor 

func (Mode) Descriptor() protoreflect.EnumDescriptor

func (Mode) Enum 

func (x Mode) Enum() *Mode

func (Mode) Number 

func (x Mode) Number() protoreflect.EnumNumber

func (Mode) String 

func (x Mode) String() string

func (Mode) Type 

func (Mode) Type() protoreflect.EnumType

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

func (x *ParamTraceConfig) SetParameterNames(v []string)

func (*ParamTraceConfig) SetSpanSelectors 

func (x *ParamTraceConfig) SetSpanSelectors(v []*SpanSelector)

func (*ParamTraceConfig) String 

func (x *ParamTraceConfig) String() string

type ParamTraceConfig_builder 

type ParamTraceConfig_builder struct {
	SpanSelectors  []*SpanSelector
	ParameterNames []string
	// contains filtered or unexported fields
}

func (ParamTraceConfig_builder) Build 

func (b0 ParamTraceConfig_builder) Build() *ParamTraceConfig

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

func (x *QueryGuardHealthRequest) ClearPriorityBoost()

func (*QueryGuardHealthRequest) ClearSelector 

func (x *QueryGuardHealthRequest) ClearSelector()

func (*QueryGuardHealthRequest) GetPriorityBoost 

func (x *QueryGuardHealthRequest) GetPriorityBoost() int32

func (*QueryGuardHealthRequest) GetSelector 

func (x *QueryGuardHealthRequest) GetSelector() *GuardFeatureSelector

func (*QueryGuardHealthRequest) HasPriorityBoost 

func (x *QueryGuardHealthRequest) HasPriorityBoost() bool

func (*QueryGuardHealthRequest) HasSelector 

func (x *QueryGuardHealthRequest) HasSelector() bool

func (*QueryGuardHealthRequest) ProtoMessage 

func (*QueryGuardHealthRequest) ProtoMessage()

func (*QueryGuardHealthRequest) ProtoReflect 

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

func (*QueryGuardHealthRequest) Reset 

func (x *QueryGuardHealthRequest) Reset()

func (*QueryGuardHealthRequest) SetPriorityBoost 

func (x *QueryGuardHealthRequest) SetPriorityBoost(v int32)

func (*QueryGuardHealthRequest) SetSelector 

func (x *QueryGuardHealthRequest) SetSelector(v *GuardFeatureSelector)

func (*QueryGuardHealthRequest) String 

func (x *QueryGuardHealthRequest) String() string

type QueryGuardHealthRequest_builder 

type QueryGuardHealthRequest_builder 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
	// 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
	// contains filtered or unexported fields
}

func (QueryGuardHealthRequest_builder) Build 

func (b0 QueryGuardHealthRequest_builder) Build() *QueryGuardHealthRequest

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

func (x *QueryGuardHealthResponse) SetHealth(v Health)

func (*QueryGuardHealthResponse) String 

func (x *QueryGuardHealthResponse) String() string

type QueryGuardHealthResponse_builder 

type QueryGuardHealthResponse_builder struct {
	Health Health
	// contains filtered or unexported fields
}

func (QueryGuardHealthResponse_builder) Build 

func (b0 QueryGuardHealthResponse_builder) Build() *QueryGuardHealthResponse

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. 

const (
	QueryMode_QUERY_MODE_UNSPECIFIED QueryMode = 0
	QueryMode_QUERY_MODE_SUM         QueryMode = 1
	QueryMode_QUERY_MODE_REPORT      QueryMode = 2
)

func (QueryMode) Descriptor 

func (QueryMode) Descriptor() protoreflect.EnumDescriptor

func (QueryMode) Enum 

func (x QueryMode) Enum() *QueryMode

func (QueryMode) Number 

func (x QueryMode) Number() protoreflect.EnumNumber

func (QueryMode) String 

func (x QueryMode) String() string

func (QueryMode) Type 

func (QueryMode) Type() protoreflect.EnumType

type Quota 

type Quota int32

Quota describes Guard reasons used by Stanza SDKs 

const (
	Quota_QUOTA_UNSPECIFIED   Quota = 0
	Quota_QUOTA_NOT_EVAL      Quota = 1 // SDK never evaluated (failed before quota validation attempted)
	Quota_QUOTA_EVAL_DISABLED Quota = 2 // Guard configuration does not include evaluating quota
	Quota_QUOTA_LOCAL_ERROR   Quota = 3 // SDK experienced some locally-sourced error and could not check quota
	Quota_QUOTA_BLOCKED       Quota = 4 // Stanza control plane checked quota and blocked the request
	Quota_QUOTA_GRANTED       Quota = 5 // Stanza control plane checked quota and granted the request
	Quota_QUOTA_ERROR         Quota = 6 // Stanza control plane responded with an error when checking quota
	Quota_QUOTA_TIMEOUT       Quota = 7 // Stanza control plane request to check quota timed out
)

func (Quota) Descriptor 

func (Quota) Descriptor() protoreflect.EnumDescriptor

func (Quota) Enum 

func (x Quota) Enum() *Quota

func (Quota) Number 

func (x Quota) Number() protoreflect.EnumNumber

func (Quota) String 

func (x Quota) String() string

func (Quota) Type 

func (Quota) Type() protoreflect.EnumType

type Reason 

type Reason int32
const (
	Reason_REASON_UNSPECIFIED               Reason = 0
	Reason_REASON_SUFFICIENT_QUOTA          Reason = 1
	Reason_REASON_INSUFFICIENT_QUOTA        Reason = 2
	Reason_REASON_INSUFFICIENT_QUOTA_PARENT Reason = 3
	Reason_REASON_BURST                     Reason = 4
	Reason_REASON_BEST_EFFORT               Reason = 5
)

func (Reason) Descriptor 

func (Reason) Descriptor() protoreflect.EnumDescriptor

func (Reason) Enum 

func (x Reason) Enum() *Reason

func (Reason) Number 

func (x Reason) Number() protoreflect.EnumNumber

func (Reason) String 

func (x Reason) String() string

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

func (x *SentinelConfig) ClearCircuitbreakerRulesJson()

func (*SentinelConfig) ClearFlowRulesJson 

func (x *SentinelConfig) ClearFlowRulesJson()

func (*SentinelConfig) ClearIsolationRulesJson 

func (x *SentinelConfig) ClearIsolationRulesJson()

func (*SentinelConfig) ClearSystemRulesJson 

func (x *SentinelConfig) ClearSystemRulesJson()

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

func (x *SentinelConfig) HasCircuitbreakerRulesJson() bool

func (*SentinelConfig) HasFlowRulesJson 

func (x *SentinelConfig) HasFlowRulesJson() bool

func (*SentinelConfig) HasIsolationRulesJson 

func (x *SentinelConfig) HasIsolationRulesJson() bool

func (*SentinelConfig) HasSystemRulesJson 

func (x *SentinelConfig) HasSystemRulesJson() bool

func (*SentinelConfig) ProtoMessage 

func (*SentinelConfig) ProtoMessage()

func (*SentinelConfig) ProtoReflect 

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

func (*SentinelConfig) Reset 

func (x *SentinelConfig) Reset()

func (*SentinelConfig) SetCircuitbreakerRulesJson 

func (x *SentinelConfig) SetCircuitbreakerRulesJson(v string)

func (*SentinelConfig) SetFlowRulesJson 

func (x *SentinelConfig) SetFlowRulesJson(v string)

func (*SentinelConfig) SetIsolationRulesJson 

func (x *SentinelConfig) SetIsolationRulesJson(v string)

func (*SentinelConfig) SetSystemRulesJson 

func (x *SentinelConfig) SetSystemRulesJson(v string)

func (*SentinelConfig) String 

func (x *SentinelConfig) String() string

type SentinelConfig_builder 

type SentinelConfig_builder struct {
	CircuitbreakerRulesJson *string
	FlowRulesJson           *string
	IsolationRulesJson      *string
	SystemRulesJson         *string
	// contains filtered or unexported fields
}

func (SentinelConfig_builder) Build 

func (b0 SentinelConfig_builder) Build() *SentinelConfig

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

func (x *ServiceConfig) ClearCustomerId()

func (*ServiceConfig) ClearMetricConfig 

func (x *ServiceConfig) ClearMetricConfig()

func (*ServiceConfig) ClearSentinelConfig 

func (x *ServiceConfig) ClearSentinelConfig()

func (*ServiceConfig) ClearTraceConfig 

func (x *ServiceConfig) ClearTraceConfig()

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

func (x *ServiceConfig) HasCustomerId() bool

func (*ServiceConfig) HasMetricConfig 

func (x *ServiceConfig) HasMetricConfig() bool

func (*ServiceConfig) HasSentinelConfig 

func (x *ServiceConfig) HasSentinelConfig() bool

func (*ServiceConfig) HasTraceConfig 

func (x *ServiceConfig) HasTraceConfig() bool

func (*ServiceConfig) ProtoMessage 

func (*ServiceConfig) ProtoMessage()

func (*ServiceConfig) ProtoReflect 

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

func (*ServiceConfig) Reset 

func (x *ServiceConfig) Reset()

func (*ServiceConfig) SetCustomerId 

func (x *ServiceConfig) SetCustomerId(v string)

func (*ServiceConfig) SetMetricConfig 

func (x *ServiceConfig) SetMetricConfig(v *MetricConfig)

func (*ServiceConfig) SetSentinelConfig 

func (x *ServiceConfig) SetSentinelConfig(v *SentinelConfig)

func (*ServiceConfig) SetTraceConfig 

func (x *ServiceConfig) SetTraceConfig(v *TraceConfig)

func (*ServiceConfig) String 

func (x *ServiceConfig) String() string

type ServiceConfig_builder 

type ServiceConfig_builder struct {
	CustomerId     *string
	TraceConfig    *TraceConfig
	MetricConfig   *MetricConfig
	SentinelConfig *SentinelConfig
	// contains filtered or unexported fields
}

func (ServiceConfig_builder) Build 

func (b0 ServiceConfig_builder) Build() *ServiceConfig

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

func (x *ServiceSelector) ClearRelease()

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

func (x *ServiceSelector) HasRelease() bool

func (*ServiceSelector) ProtoMessage 

func (*ServiceSelector) ProtoMessage()

func (*ServiceSelector) ProtoReflect 

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

func (*ServiceSelector) Reset 

func (x *ServiceSelector) Reset()

func (*ServiceSelector) SetEnvironment 

func (x *ServiceSelector) SetEnvironment(v string)

func (*ServiceSelector) SetName 

func (x *ServiceSelector) SetName(v string)

func (*ServiceSelector) SetRelease 

func (x *ServiceSelector) SetRelease(v string)

func (*ServiceSelector) SetTags 

func (x *ServiceSelector) SetTags(v []*Tag)

func (*ServiceSelector) String 

func (x *ServiceSelector) String() string

type ServiceSelector_builder 

type ServiceSelector_builder struct {
	Environment string
	Name        string
	Release     *string
	Tags        []*Tag
	// contains filtered or unexported fields
}

func (ServiceSelector_builder) Build 

func (b0 ServiceSelector_builder) Build() *ServiceSelector

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"`
	Environment      string   `protobuf:"bytes,3,opt,name=environment,proto3" json:"environment,omitempty"` // Must be specified.
	// contains filtered or unexported fields
}

Notifies Hub that one or more token leases has been used, i.e. Guard has been exercised.

func (*SetTokenLeaseConsumedRequest) ClearWeightCorrection 

func (x *SetTokenLeaseConsumedRequest) ClearWeightCorrection()

func (*SetTokenLeaseConsumedRequest) GetEnvironment 

func (x *SetTokenLeaseConsumedRequest) GetEnvironment() string

func (*SetTokenLeaseConsumedRequest) GetTokens 

func (x *SetTokenLeaseConsumedRequest) GetTokens() []string

func (*SetTokenLeaseConsumedRequest) GetWeightCorrection 

func (x *SetTokenLeaseConsumedRequest) GetWeightCorrection() float32

func (*SetTokenLeaseConsumedRequest) HasWeightCorrection 

func (x *SetTokenLeaseConsumedRequest) HasWeightCorrection() bool

func (*SetTokenLeaseConsumedRequest) ProtoMessage 

func (*SetTokenLeaseConsumedRequest) ProtoMessage()

func (*SetTokenLeaseConsumedRequest) ProtoReflect 

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

func (*SetTokenLeaseConsumedRequest) Reset 

func (x *SetTokenLeaseConsumedRequest) Reset()

func (*SetTokenLeaseConsumedRequest) SetEnvironment 

func (x *SetTokenLeaseConsumedRequest) SetEnvironment(v string)

func (*SetTokenLeaseConsumedRequest) SetTokens 

func (x *SetTokenLeaseConsumedRequest) SetTokens(v []string)

func (*SetTokenLeaseConsumedRequest) SetWeightCorrection 

func (x *SetTokenLeaseConsumedRequest) SetWeightCorrection(v float32)

func (*SetTokenLeaseConsumedRequest) String 

func (x *SetTokenLeaseConsumedRequest) String() string

type SetTokenLeaseConsumedRequest_builder 

type SetTokenLeaseConsumedRequest_builder struct {
	Tokens []string
	// 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
	Environment      string
	// contains filtered or unexported fields
}

func (SetTokenLeaseConsumedRequest_builder) Build 

func (b0 SetTokenLeaseConsumedRequest_builder) Build() *SetTokenLeaseConsumedRequest

type SetTokenLeaseConsumedResponse 

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

No message contents yet

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 SetTokenLeaseConsumedResponse_builder 

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

func (SetTokenLeaseConsumedResponse_builder) Build 

func (b0 SetTokenLeaseConsumedResponse_builder) Build() *SetTokenLeaseConsumedResponse

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

func (x *SpanSelector) SetOtelAttribute(v string)

func (*SpanSelector) SetValue 

func (x *SpanSelector) SetValue(v string)

func (*SpanSelector) String 

func (x *SpanSelector) String() string

type SpanSelector_builder 

type SpanSelector_builder 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
	Value         string
	// contains filtered or unexported fields
}

func (SpanSelector_builder) Build 

func (b0 SpanSelector_builder) Build() *SpanSelector

type State 

type State int32
const (
	State_STATE_UNSPECIFIED State = 0
	State_STATE_ENABLED     State = 1
	State_STATE_DISABLED    State = 2
)

func (State) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type StreamRequest 

type StreamRequest struct {
	Feature       string `protobuf:"bytes,1,opt,name=feature,proto3" json:"feature,omitempty"`                                         // optional - if specified then the request inherits the feature priority
	Tags          []*Tag `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`                                               // refers to tags specified in the Guard configuration, used to fairly allocate quota
	PriorityBoost *int32 `protobuf:"varint,3,opt,name=priority_boost,json=priorityBoost,proto3,oneof" json:"priority_boost,omitempty"` // optional - allows priority to be increased or reduced relative to normal default or feature priority.
	// Unique identifier for this stream - may be meaningful or a UUID. Assigned by requestor.
	StreamId string `protobuf:"bytes,4,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Maximum weight that may be allocated to this stream
	MaxWeight float32 `protobuf:"fixed32,5,opt,name=max_weight,json=maxWeight,proto3" json:"max_weight,omitempty"`
	// Minimum weight that may be allocated to this stream. If this weight cannot be allocated then the stream cannot be served.
	MinWeight float32 `protobuf:"fixed32,6,opt,name=min_weight,json=minWeight,proto3" json:"min_weight,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRequest) ClearPriorityBoost 

func (x *StreamRequest) ClearPriorityBoost()

func (*StreamRequest) GetFeature 

func (x *StreamRequest) GetFeature() string

func (*StreamRequest) GetMaxWeight 

func (x *StreamRequest) GetMaxWeight() float32

func (*StreamRequest) GetMinWeight 

func (x *StreamRequest) GetMinWeight() float32

func (*StreamRequest) GetPriorityBoost 

func (x *StreamRequest) GetPriorityBoost() int32

func (*StreamRequest) GetStreamId 

func (x *StreamRequest) GetStreamId() string

func (*StreamRequest) GetTags 

func (x *StreamRequest) GetTags() []*Tag

func (*StreamRequest) HasPriorityBoost 

func (x *StreamRequest) HasPriorityBoost() bool

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect 

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

func (*StreamRequest) Reset 

func (x *StreamRequest) Reset()

func (*StreamRequest) SetFeature 

func (x *StreamRequest) SetFeature(v string)

func (*StreamRequest) SetMaxWeight 

func (x *StreamRequest) SetMaxWeight(v float32)

func (*StreamRequest) SetMinWeight 

func (x *StreamRequest) SetMinWeight(v float32)

func (*StreamRequest) SetPriorityBoost 

func (x *StreamRequest) SetPriorityBoost(v int32)

func (*StreamRequest) SetStreamId 

func (x *StreamRequest) SetStreamId(v string)

func (*StreamRequest) SetTags 

func (x *StreamRequest) SetTags(v []*Tag)

func (*StreamRequest) String 

func (x *StreamRequest) String() string

type StreamRequest_builder 

type StreamRequest_builder struct {
	Feature       string
	Tags          []*Tag
	PriorityBoost *int32
	// Unique identifier for this stream - may be meaningful or a UUID. Assigned by requestor.
	StreamId string
	// Maximum weight that may be allocated to this stream
	MaxWeight float32
	// Minimum weight that may be allocated to this stream. If this weight cannot be allocated then the stream cannot be served.
	MinWeight float32
	// contains filtered or unexported fields
}

func (StreamRequest_builder) Build 

func (b0 StreamRequest_builder) Build() *StreamRequest

type StreamResult 

type StreamResult struct {

	// Unique identifier for this stream - as described in StreamRequest mesage.
	StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Weight allocated to this stream. Zero means it was not allocated.
	AllocatedWeight float32 `protobuf:"fixed32,2,opt,name=allocated_weight,json=allocatedWeight,proto3" json:"allocated_weight,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamResult) GetAllocatedWeight 

func (x *StreamResult) GetAllocatedWeight() float32

func (*StreamResult) GetStreamId 

func (x *StreamResult) GetStreamId() string

func (*StreamResult) ProtoMessage 

func (*StreamResult) ProtoMessage()

func (*StreamResult) ProtoReflect 

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

func (*StreamResult) Reset 

func (x *StreamResult) Reset()

func (*StreamResult) SetAllocatedWeight 

func (x *StreamResult) SetAllocatedWeight(v float32)

func (*StreamResult) SetStreamId 

func (x *StreamResult) SetStreamId(v string)

func (*StreamResult) String 

func (x *StreamResult) String() string

type StreamResult_builder 

type StreamResult_builder struct {

	// Unique identifier for this stream - as described in StreamRequest mesage.
	StreamId string
	// Weight allocated to this stream. Zero means it was not allocated.
	AllocatedWeight float32
	// contains filtered or unexported fields
}

func (StreamResult_builder) Build 

func (b0 StreamResult_builder) Build() *StreamResult

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

func (x *Tag) GetKey() string

func (*Tag) GetValue 

func (x *Tag) GetValue() string

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect 

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

func (*Tag) Reset 

func (x *Tag) Reset()

func (*Tag) SetKey 

func (x *Tag) SetKey(v string)

func (*Tag) SetValue 

func (x *Tag) SetValue(v string)

func (*Tag) String 

func (x *Tag) String() string

type Tag_builder 

type Tag_builder struct {
	Key   string
	Value string
	// contains filtered or unexported fields
}

func (Tag_builder) Build 

func (b0 Tag_builder) Build() *Tag

type Token 

type Token int32

Token describes Guard reasons used by Stanza SDKs 

const (
	Token_TOKEN_UNSPECIFIED        Token = 0
	Token_TOKEN_NOT_EVAL           Token = 1 // SDK never evaluated (failed before token validation attempted)
	Token_TOKEN_EVAL_DISABLED      Token = 2 // Guard configuration does not include evaluating tokens
	Token_TOKEN_NOT_VALID          Token = 3 // Stanza control plane checked the token and responded that it was not valid
	Token_TOKEN_VALID              Token = 4 // Stanza control plane checked the token and responded that it was valid
	Token_TOKEN_VALIDATION_ERROR   Token = 5 // Stanza control plane responded with an error when validating token
	Token_TOKEN_VALIDATION_TIMEOUT Token = 6 // Stanza control plane request to validate token timed out
)

func (Token) Descriptor 

func (Token) Descriptor() protoreflect.EnumDescriptor

func (Token) Enum 

func (x Token) Enum() *Token

func (Token) Number 

func (x Token) Number() protoreflect.EnumNumber

func (Token) String 

func (x Token) String() string

func (Token) Type 

func (Token) Type() protoreflect.EnumType

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

func (x *TokenInfo) ClearGuard()

func (*TokenInfo) GetGuard 

func (x *TokenInfo) GetGuard() *GuardSelector

func (*TokenInfo) GetToken 

func (x *TokenInfo) GetToken() string

func (*TokenInfo) HasGuard 

func (x *TokenInfo) HasGuard() bool

func (*TokenInfo) ProtoMessage 

func (*TokenInfo) ProtoMessage()

func (*TokenInfo) ProtoReflect 

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

func (*TokenInfo) Reset 

func (x *TokenInfo) Reset()

func (*TokenInfo) SetGuard 

func (x *TokenInfo) SetGuard(v *GuardSelector)

func (*TokenInfo) SetToken 

func (x *TokenInfo) SetToken(v string)

func (*TokenInfo) String 

func (x *TokenInfo) String() string

type TokenInfo_builder 

type TokenInfo_builder struct {
	Token string
	Guard *GuardSelector
	// contains filtered or unexported fields
}

func (TokenInfo_builder) Build 

func (b0 TokenInfo_builder) Build() *TokenInfo

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
	Mode          *Mode                  `protobuf:"varint,8,opt,name=mode,proto3,enum=stanza.hub.v1.Mode,oneof" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenLease) ClearExpiresAt 

func (x *TokenLease) ClearExpiresAt()

func (*TokenLease) ClearMode 

func (x *TokenLease) ClearMode()

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

func (x *TokenLease) GetMode() Mode

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

func (x *TokenLease) HasExpiresAt() bool

func (*TokenLease) HasMode 

func (x *TokenLease) HasMode() bool

func (*TokenLease) ProtoMessage 

func (*TokenLease) ProtoMessage()

func (*TokenLease) ProtoReflect 

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

func (*TokenLease) Reset 

func (x *TokenLease) Reset()

func (*TokenLease) SetDurationMsec 

func (x *TokenLease) SetDurationMsec(v int32)

func (*TokenLease) SetExpiresAt 

func (x *TokenLease) SetExpiresAt(v *timestamppb.Timestamp)

func (*TokenLease) SetFeature 

func (x *TokenLease) SetFeature(v string)

func (*TokenLease) SetMode 

func (x *TokenLease) SetMode(v Mode)

func (*TokenLease) SetPriorityBoost 

func (x *TokenLease) SetPriorityBoost(v int32)

func (*TokenLease) SetReason 

func (x *TokenLease) SetReason(v Reason)

func (*TokenLease) SetToken 

func (x *TokenLease) SetToken(v string)

func (*TokenLease) SetWeight 

func (x *TokenLease) SetWeight(v float32)

func (*TokenLease) String 

func (x *TokenLease) String() string

type TokenLease_builder 

type TokenLease_builder struct {
	DurationMsec  int32
	Token         string
	Feature       string
	PriorityBoost int32
	Weight        float32
	Reason        Reason
	ExpiresAt     *timestamppb.Timestamp
	Mode          *Mode
	// contains filtered or unexported fields
}

func (TokenLease_builder) Build 

func (b0 TokenLease_builder) Build() *TokenLease

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

func (x *TokenValid) SetToken(v string)

func (*TokenValid) SetValid 

func (x *TokenValid) SetValid(v bool)

func (*TokenValid) String 

func (x *TokenValid) String() string

type TokenValid_builder 

type TokenValid_builder struct {
	Token string
	Valid bool
	// contains filtered or unexported fields
}

func (TokenValid_builder) Build 

func (b0 TokenValid_builder) Build() *TokenValid

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

func (x *TraceConfig) ClearCollectorUrl()

func (*TraceConfig) ClearSampleRateDefault 

func (x *TraceConfig) ClearSampleRateDefault()

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

func (x *TraceConfig) HasCollectorUrl() bool

func (*TraceConfig) HasSampleRateDefault 

func (x *TraceConfig) HasSampleRateDefault() bool

func (*TraceConfig) ProtoMessage 

func (*TraceConfig) ProtoMessage()

func (*TraceConfig) ProtoReflect 

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

func (*TraceConfig) Reset 

func (x *TraceConfig) Reset()

func (*TraceConfig) SetCollectorUrl 

func (x *TraceConfig) SetCollectorUrl(v string)

func (*TraceConfig) SetHeaderSampleConfigs 

func (x *TraceConfig) SetHeaderSampleConfigs(v []*HeaderTraceConfig)

func (*TraceConfig) SetOverrides 

func (x *TraceConfig) SetOverrides(v []*TraceConfigOverride)

func (*TraceConfig) SetParamSampleConfigs 

func (x *TraceConfig) SetParamSampleConfigs(v []*ParamTraceConfig)

func (*TraceConfig) SetSampleRateDefault 

func (x *TraceConfig) SetSampleRateDefault(v float32)

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

func (x *TraceConfigOverride) SetSampleRate(v float32)

func (*TraceConfigOverride) SetSpanSelectors 

func (x *TraceConfigOverride) SetSpanSelectors(v []*SpanSelector)

func (*TraceConfigOverride) String 

func (x *TraceConfigOverride) String() string

type TraceConfigOverride_builder 

type TraceConfigOverride_builder struct {
	SampleRate    float32
	SpanSelectors []*SpanSelector
	// contains filtered or unexported fields
}

func (TraceConfigOverride_builder) Build 

func (b0 TraceConfigOverride_builder) Build() *TraceConfigOverride

type TraceConfig_builder 

type TraceConfig_builder struct {
	CollectorUrl        *string
	SampleRateDefault   *float32
	Overrides           []*TraceConfigOverride
	HeaderSampleConfigs []*HeaderTraceConfig
	ParamSampleConfigs  []*ParamTraceConfig
	// contains filtered or unexported fields
}

func (TraceConfig_builder) Build 

func (b0 TraceConfig_builder) Build() *TraceConfig

type UpdateStreamsRequest 

type UpdateStreamsRequest struct {
	GuardName   string           `protobuf:"bytes,1,opt,name=guard_name,json=guardName,proto3" json:"guard_name,omitempty"`
	Environment string           `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	Requests    []*StreamRequest `protobuf:"bytes,3,rep,name=requests,proto3" json:"requests,omitempty"`
	Ended       []string         `protobuf:"bytes,4,rep,name=ended,proto3" json:"ended,omitempty"` // IDs of streams that have completed
	// contains filtered or unexported fields
}

func (*UpdateStreamsRequest) GetEnded 

func (x *UpdateStreamsRequest) GetEnded() []string

func (*UpdateStreamsRequest) GetEnvironment 

func (x *UpdateStreamsRequest) GetEnvironment() string

func (*UpdateStreamsRequest) GetGuardName 

func (x *UpdateStreamsRequest) GetGuardName() string

func (*UpdateStreamsRequest) GetRequests 

func (x *UpdateStreamsRequest) GetRequests() []*StreamRequest

func (*UpdateStreamsRequest) ProtoMessage 

func (*UpdateStreamsRequest) ProtoMessage()

func (*UpdateStreamsRequest) ProtoReflect 

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

func (*UpdateStreamsRequest) Reset 

func (x *UpdateStreamsRequest) Reset()

func (*UpdateStreamsRequest) SetEnded 

func (x *UpdateStreamsRequest) SetEnded(v []string)

func (*UpdateStreamsRequest) SetEnvironment 

func (x *UpdateStreamsRequest) SetEnvironment(v string)

func (*UpdateStreamsRequest) SetGuardName 

func (x *UpdateStreamsRequest) SetGuardName(v string)

func (*UpdateStreamsRequest) SetRequests 

func (x *UpdateStreamsRequest) SetRequests(v []*StreamRequest)

func (*UpdateStreamsRequest) String 

func (x *UpdateStreamsRequest) String() string

type UpdateStreamsRequest_builder 

type UpdateStreamsRequest_builder struct {
	GuardName   string
	Environment string
	Requests    []*StreamRequest
	Ended       []string
	// contains filtered or unexported fields
}

func (UpdateStreamsRequest_builder) Build 

func (b0 UpdateStreamsRequest_builder) Build() *UpdateStreamsRequest

type UpdateStreamsResponse 

type UpdateStreamsResponse struct {
	Results []*StreamResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStreamsResponse) GetResults 

func (x *UpdateStreamsResponse) GetResults() []*StreamResult

func (*UpdateStreamsResponse) ProtoMessage 

func (*UpdateStreamsResponse) ProtoMessage()

func (*UpdateStreamsResponse) ProtoReflect 

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

func (*UpdateStreamsResponse) Reset 

func (x *UpdateStreamsResponse) Reset()

func (*UpdateStreamsResponse) SetResults 

func (x *UpdateStreamsResponse) SetResults(v []*StreamResult)

func (*UpdateStreamsResponse) String 

func (x *UpdateStreamsResponse) String() string

type UpdateStreamsResponse_builder 

type UpdateStreamsResponse_builder struct {
	Results []*StreamResult
	// contains filtered or unexported fields
}

func (UpdateStreamsResponse_builder) Build 

func (b0 UpdateStreamsResponse_builder) Build() *UpdateStreamsResponse

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

func (x *UsageTSDataPoint) ClearBeBurst()

func (*UsageTSDataPoint) ClearBeBurstWeight 

func (x *UsageTSDataPoint) ClearBeBurstWeight()

func (*UsageTSDataPoint) ClearEndTs 

func (x *UsageTSDataPoint) ClearEndTs()

func (*UsageTSDataPoint) ClearParentReject 

func (x *UsageTSDataPoint) ClearParentReject()

func (*UsageTSDataPoint) ClearParentRejectWeight 

func (x *UsageTSDataPoint) ClearParentRejectWeight()

func (*UsageTSDataPoint) ClearStartTs 

func (x *UsageTSDataPoint) ClearStartTs()

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

func (x *UsageTSDataPoint) HasBeBurst() bool

func (*UsageTSDataPoint) HasBeBurstWeight 

func (x *UsageTSDataPoint) HasBeBurstWeight() bool

func (*UsageTSDataPoint) HasEndTs 

func (x *UsageTSDataPoint) HasEndTs() bool

func (*UsageTSDataPoint) HasParentReject 

func (x *UsageTSDataPoint) HasParentReject() bool

func (*UsageTSDataPoint) HasParentRejectWeight 

func (x *UsageTSDataPoint) HasParentRejectWeight() bool

func (*UsageTSDataPoint) HasStartTs 

func (x *UsageTSDataPoint) HasStartTs() bool

func (*UsageTSDataPoint) ProtoMessage 

func (*UsageTSDataPoint) ProtoMessage()

func (*UsageTSDataPoint) ProtoReflect 

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

func (*UsageTSDataPoint) Reset 

func (x *UsageTSDataPoint) Reset()

func (*UsageTSDataPoint) SetBeBurst 

func (x *UsageTSDataPoint) SetBeBurst(v int32)

func (*UsageTSDataPoint) SetBeBurstWeight 

func (x *UsageTSDataPoint) SetBeBurstWeight(v float32)

func (*UsageTSDataPoint) SetEndTs 

func (x *UsageTSDataPoint) SetEndTs(v *timestamppb.Timestamp)

func (*UsageTSDataPoint) SetGranted 

func (x *UsageTSDataPoint) SetGranted(v int32)

func (*UsageTSDataPoint) SetGrantedWeight 

func (x *UsageTSDataPoint) SetGrantedWeight(v float32)

func (*UsageTSDataPoint) SetNotGranted 

func (x *UsageTSDataPoint) SetNotGranted(v int32)

func (*UsageTSDataPoint) SetNotGrantedWeight 

func (x *UsageTSDataPoint) SetNotGrantedWeight(v float32)

func (*UsageTSDataPoint) SetParentReject 

func (x *UsageTSDataPoint) SetParentReject(v int32)

func (*UsageTSDataPoint) SetParentRejectWeight 

func (x *UsageTSDataPoint) SetParentRejectWeight(v float32)

func (*UsageTSDataPoint) SetStartTs 

func (x *UsageTSDataPoint) SetStartTs(v *timestamppb.Timestamp)

func (*UsageTSDataPoint) String 

func (x *UsageTSDataPoint) String() string

type UsageTSDataPoint_builder 

type UsageTSDataPoint_builder struct {
	StartTs            *timestamppb.Timestamp
	EndTs              *timestamppb.Timestamp
	Granted            int32
	GrantedWeight      float32
	NotGranted         int32
	NotGrantedWeight   float32
	BeBurst            *int32
	BeBurstWeight      *float32
	ParentReject       *int32
	ParentRejectWeight *float32
	// contains filtered or unexported fields
}

func (UsageTSDataPoint_builder) Build 

func (b0 UsageTSDataPoint_builder) Build() *UsageTSDataPoint

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"`
	Service  *string `protobuf:"bytes,7,opt,name=service,proto3,oneof" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*UsageTimeseries) ClearFeature 

func (x *UsageTimeseries) ClearFeature()

func (*UsageTimeseries) ClearGuard 

func (x *UsageTimeseries) ClearGuard()

func (*UsageTimeseries) ClearPriority 

func (x *UsageTimeseries) ClearPriority()

func (*UsageTimeseries) ClearService 

func (x *UsageTimeseries) ClearService()

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

func (x *UsageTimeseries) GetService() string

func (*UsageTimeseries) GetTags 

func (x *UsageTimeseries) GetTags() []*Tag

func (*UsageTimeseries) HasFeature 

func (x *UsageTimeseries) HasFeature() bool

func (*UsageTimeseries) HasGuard 

func (x *UsageTimeseries) HasGuard() bool

func (*UsageTimeseries) HasPriority 

func (x *UsageTimeseries) HasPriority() bool

func (*UsageTimeseries) HasService 

func (x *UsageTimeseries) HasService() bool

func (*UsageTimeseries) ProtoMessage 

func (*UsageTimeseries) ProtoMessage()

func (*UsageTimeseries) ProtoReflect 

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

func (*UsageTimeseries) Reset 

func (x *UsageTimeseries) Reset()

func (*UsageTimeseries) SetData 

func (x *UsageTimeseries) SetData(v []*UsageTSDataPoint)

func (*UsageTimeseries) SetFeature 

func (x *UsageTimeseries) SetFeature(v string)

func (*UsageTimeseries) SetGuard 

func (x *UsageTimeseries) SetGuard(v string)

func (*UsageTimeseries) SetPriority 

func (x *UsageTimeseries) SetPriority(v int32)

func (*UsageTimeseries) SetService 

func (x *UsageTimeseries) SetService(v string)

func (*UsageTimeseries) SetTags 

func (x *UsageTimeseries) SetTags(v []*Tag)

func (*UsageTimeseries) String 

func (x *UsageTimeseries) String() string

type UsageTimeseries_builder 

type UsageTimeseries_builder struct {
	Data []*UsageTSDataPoint
	// Axes for this timeseries - may not be applicable if there are no axes being queried in report mode
	Feature  *string
	Priority *int32
	Tags     []*Tag
	Guard    *string
	Service  *string
	// contains filtered or unexported fields
}

func (UsageTimeseries_builder) Build 

func (b0 UsageTimeseries_builder) Build() *UsageTimeseries

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

func (x *ValidateTokenRequest) SetTokens(v []*TokenInfo)

func (*ValidateTokenRequest) String 

func (x *ValidateTokenRequest) String() string

type ValidateTokenRequest_builder 

type ValidateTokenRequest_builder struct {
	Tokens []*TokenInfo
	// contains filtered or unexported fields
}

func (ValidateTokenRequest_builder) Build 

func (b0 ValidateTokenRequest_builder) Build() *ValidateTokenRequest

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

func (x *ValidateTokenResponse) SetTokensValid(v []*TokenValid)

func (*ValidateTokenResponse) SetValid 

func (x *ValidateTokenResponse) SetValid(v bool)

func (*ValidateTokenResponse) String 

func (x *ValidateTokenResponse) String() string

type ValidateTokenResponse_builder 

type ValidateTokenResponse_builder struct {
	Valid       bool
	TokensValid []*TokenValid
	// contains filtered or unexported fields
}

func (ValidateTokenResponse_builder) Build 

func (b0 ValidateTokenResponse_builder) Build() *ValidateTokenResponse

Source Files

  • auth.pb.go
  • common.pb.go
  • config.pb.go
  • health.pb.go
  • quota.pb.go
  • stream.pb.go
  • usage.pb.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.