Documentation ¶
Index ¶
- type Configuration
- func (*Configuration) Descriptor() ([]byte, []int)
- func (m *Configuration) GetAgeBadRateAfterSec() int64
- func (m *Configuration) GetBadRateIncrease() float64
- func (m *Configuration) GetEmergencyDecrease() float64
- func (m *Configuration) GetIgnoreNSlowestRdonlys() int32
- func (m *Configuration) GetIgnoreNSlowestReplicas() int32
- func (m *Configuration) GetInitialRate() int64
- func (m *Configuration) GetMaxDurationBetweenIncreasesSec() int64
- func (m *Configuration) GetMaxIncrease() float64
- func (m *Configuration) GetMaxRateApproachThreshold() float64
- func (m *Configuration) GetMaxReplicationLagSec() int64
- func (m *Configuration) GetMinDurationBetweenDecreasesSec() int64
- func (m *Configuration) GetMinDurationBetweenIncreasesSec() int64
- func (m *Configuration) GetSpreadBacklogAcrossSec() int64
- func (m *Configuration) GetTargetReplicationLagSec() int64
- func (*Configuration) ProtoMessage()
- func (m *Configuration) Reset()
- func (m *Configuration) String() string
- func (m *Configuration) XXX_DiscardUnknown()
- func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Configuration) XXX_Merge(src proto.Message)
- func (m *Configuration) XXX_Size() int
- func (m *Configuration) XXX_Unmarshal(b []byte) error
- type GetConfigurationRequest
- func (*GetConfigurationRequest) Descriptor() ([]byte, []int)
- func (m *GetConfigurationRequest) GetThrottlerName() string
- func (*GetConfigurationRequest) ProtoMessage()
- func (m *GetConfigurationRequest) Reset()
- func (m *GetConfigurationRequest) String() string
- func (m *GetConfigurationRequest) XXX_DiscardUnknown()
- func (m *GetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetConfigurationRequest) XXX_Merge(src proto.Message)
- func (m *GetConfigurationRequest) XXX_Size() int
- func (m *GetConfigurationRequest) XXX_Unmarshal(b []byte) error
- type GetConfigurationResponse
- func (*GetConfigurationResponse) Descriptor() ([]byte, []int)
- func (m *GetConfigurationResponse) GetConfigurations() map[string]*Configuration
- func (*GetConfigurationResponse) ProtoMessage()
- func (m *GetConfigurationResponse) Reset()
- func (m *GetConfigurationResponse) String() string
- func (m *GetConfigurationResponse) XXX_DiscardUnknown()
- func (m *GetConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetConfigurationResponse) XXX_Merge(src proto.Message)
- func (m *GetConfigurationResponse) XXX_Size() int
- func (m *GetConfigurationResponse) XXX_Unmarshal(b []byte) error
- type MaxRatesRequest
- func (*MaxRatesRequest) Descriptor() ([]byte, []int)
- func (*MaxRatesRequest) ProtoMessage()
- func (m *MaxRatesRequest) Reset()
- func (m *MaxRatesRequest) String() string
- func (m *MaxRatesRequest) XXX_DiscardUnknown()
- func (m *MaxRatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MaxRatesRequest) XXX_Merge(src proto.Message)
- func (m *MaxRatesRequest) XXX_Size() int
- func (m *MaxRatesRequest) XXX_Unmarshal(b []byte) error
- type MaxRatesResponse
- func (*MaxRatesResponse) Descriptor() ([]byte, []int)
- func (m *MaxRatesResponse) GetRates() map[string]int64
- func (*MaxRatesResponse) ProtoMessage()
- func (m *MaxRatesResponse) Reset()
- func (m *MaxRatesResponse) String() string
- func (m *MaxRatesResponse) XXX_DiscardUnknown()
- func (m *MaxRatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MaxRatesResponse) XXX_Merge(src proto.Message)
- func (m *MaxRatesResponse) XXX_Size() int
- func (m *MaxRatesResponse) XXX_Unmarshal(b []byte) error
- type ResetConfigurationRequest
- func (*ResetConfigurationRequest) Descriptor() ([]byte, []int)
- func (m *ResetConfigurationRequest) GetThrottlerName() string
- func (*ResetConfigurationRequest) ProtoMessage()
- func (m *ResetConfigurationRequest) Reset()
- func (m *ResetConfigurationRequest) String() string
- func (m *ResetConfigurationRequest) XXX_DiscardUnknown()
- func (m *ResetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResetConfigurationRequest) XXX_Merge(src proto.Message)
- func (m *ResetConfigurationRequest) XXX_Size() int
- func (m *ResetConfigurationRequest) XXX_Unmarshal(b []byte) error
- type ResetConfigurationResponse
- func (*ResetConfigurationResponse) Descriptor() ([]byte, []int)
- func (m *ResetConfigurationResponse) GetNames() []string
- func (*ResetConfigurationResponse) ProtoMessage()
- func (m *ResetConfigurationResponse) Reset()
- func (m *ResetConfigurationResponse) String() string
- func (m *ResetConfigurationResponse) XXX_DiscardUnknown()
- func (m *ResetConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResetConfigurationResponse) XXX_Merge(src proto.Message)
- func (m *ResetConfigurationResponse) XXX_Size() int
- func (m *ResetConfigurationResponse) XXX_Unmarshal(b []byte) error
- type SetMaxRateRequest
- func (*SetMaxRateRequest) Descriptor() ([]byte, []int)
- func (m *SetMaxRateRequest) GetRate() int64
- func (*SetMaxRateRequest) ProtoMessage()
- func (m *SetMaxRateRequest) Reset()
- func (m *SetMaxRateRequest) String() string
- func (m *SetMaxRateRequest) XXX_DiscardUnknown()
- func (m *SetMaxRateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetMaxRateRequest) XXX_Merge(src proto.Message)
- func (m *SetMaxRateRequest) XXX_Size() int
- func (m *SetMaxRateRequest) XXX_Unmarshal(b []byte) error
- type SetMaxRateResponse
- func (*SetMaxRateResponse) Descriptor() ([]byte, []int)
- func (m *SetMaxRateResponse) GetNames() []string
- func (*SetMaxRateResponse) ProtoMessage()
- func (m *SetMaxRateResponse) Reset()
- func (m *SetMaxRateResponse) String() string
- func (m *SetMaxRateResponse) XXX_DiscardUnknown()
- func (m *SetMaxRateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetMaxRateResponse) XXX_Merge(src proto.Message)
- func (m *SetMaxRateResponse) XXX_Size() int
- func (m *SetMaxRateResponse) XXX_Unmarshal(b []byte) error
- type UpdateConfigurationRequest
- func (*UpdateConfigurationRequest) Descriptor() ([]byte, []int)
- func (m *UpdateConfigurationRequest) GetConfiguration() *Configuration
- func (m *UpdateConfigurationRequest) GetCopyZeroValues() bool
- func (m *UpdateConfigurationRequest) GetThrottlerName() string
- func (*UpdateConfigurationRequest) ProtoMessage()
- func (m *UpdateConfigurationRequest) Reset()
- func (m *UpdateConfigurationRequest) String() string
- func (m *UpdateConfigurationRequest) XXX_DiscardUnknown()
- func (m *UpdateConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateConfigurationRequest) XXX_Merge(src proto.Message)
- func (m *UpdateConfigurationRequest) XXX_Size() int
- func (m *UpdateConfigurationRequest) XXX_Unmarshal(b []byte) error
- type UpdateConfigurationResponse
- func (*UpdateConfigurationResponse) Descriptor() ([]byte, []int)
- func (m *UpdateConfigurationResponse) GetNames() []string
- func (*UpdateConfigurationResponse) ProtoMessage()
- func (m *UpdateConfigurationResponse) Reset()
- func (m *UpdateConfigurationResponse) String() string
- func (m *UpdateConfigurationResponse) XXX_DiscardUnknown()
- func (m *UpdateConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateConfigurationResponse) XXX_Merge(src proto.Message)
- func (m *UpdateConfigurationResponse) XXX_Size() int
- func (m *UpdateConfigurationResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configuration ¶
type Configuration struct { // target_replication_lag_sec is the replication lag (in seconds) the // MaxReplicationLagModule tries to aim for. // If it is within the target, it tries to increase the throttler // rate, otherwise it will lower it based on an educated guess of the // replica's throughput. TargetReplicationLagSec int64 `` /* 135-byte string literal not displayed */ // max_replication_lag_sec is meant as a last resort. // By default, the module tries to find out the system maximum capacity while // trying to keep the replication lag around "target_replication_lag_sec". // Usually, we'll wait min_duration_between_(increases|decreases)_sec to see // the effect of a throttler rate change on the replication lag. // But if the lag goes above this field's value we will go into an "emergency" // state and throttle more aggressively (see "emergency_decrease" below). // This is the only way to ensure that the system will recover. MaxReplicationLagSec int64 `` /* 126-byte string literal not displayed */ // initial_rate is the rate at which the module will start. InitialRate int64 `protobuf:"varint,3,opt,name=initial_rate,json=initialRate,proto3" json:"initial_rate,omitempty"` // max_increase defines by how much we will increase the rate // e.g. 0.05 increases the rate by 5% while 1.0 by 100%. // Note that any increase will let the system wait for at least // (1 / MaxIncrease) seconds. If we wait for shorter periods of time, we // won't notice if the rate increase also increases the replication lag. // (If the system was already at its maximum capacity (e.g. 1k QPS) and we // increase the rate by e.g. 5% to 1050 QPS, it will take 20 seconds until // 1000 extra queries are buffered and the lag increases by 1 second.) MaxIncrease float64 `protobuf:"fixed64,4,opt,name=max_increase,json=maxIncrease,proto3" json:"max_increase,omitempty"` // emergency_decrease defines by how much we will decrease the current rate // if the observed replication lag is above "max_replication_lag_sec". // E.g. 0.50 decreases the current rate by 50%. EmergencyDecrease float64 `protobuf:"fixed64,5,opt,name=emergency_decrease,json=emergencyDecrease,proto3" json:"emergency_decrease,omitempty"` // min_duration_between_increases_sec specifies how long we'll wait at least // for the last rate increase to have an effect on the system. MinDurationBetweenIncreasesSec int64 `` /* 158-byte string literal not displayed */ // max_duration_between_increases_sec specifies how long we'll wait at most // for the last rate increase to have an effect on the system. MaxDurationBetweenIncreasesSec int64 `` /* 158-byte string literal not displayed */ // min_duration_between_decreases_sec specifies how long we'll wait at least // for the last rate decrease to have an effect on the system. MinDurationBetweenDecreasesSec int64 `` /* 158-byte string literal not displayed */ // spread_backlog_across_sec is used when we set the throttler rate after // we guessed the rate of a replica and determined its backlog. // For example, at a guessed rate of 100 QPS and a lag of 10s, the replica has // a backlog of 1000 queries. // When we set the new, decreased throttler rate, we factor in how long it // will take the replica to go through the backlog (in addition to new // requests). This field specifies over which timespan we plan to spread this. // For example, for a backlog of 1000 queries spread over 5s means that we // have to further reduce the rate by 200 QPS or the backlog will not be // processed within the 5 seconds. SpreadBacklogAcrossSec int64 `` /* 132-byte string literal not displayed */ // ignore_n_slowest_replicas will ignore replication lag updates from the // N slowest REPLICA tablets. Under certain circumstances, replicas are still // considered e.g. a) if the lag is at most max_replication_lag_sec, b) there // are less than N+1 replicas or c) the lag increased on each replica such // that all replicas were ignored in a row. IgnoreNSlowestReplicas int32 `` /* 133-byte string literal not displayed */ // ignore_n_slowest_rdonlys does the same thing as ignore_n_slowest_replicas // but for RDONLY tablets. Note that these two settings are independent. IgnoreNSlowestRdonlys int32 `` /* 130-byte string literal not displayed */ // age_bad_rate_after_sec is the duration after which an unchanged bad rate // will "age out" and increase by "bad_rate_increase". // Bad rates are tracked by the code in memory.go and serve as an upper bound // for future rate changes. This ensures that the adaptive throttler does not // try known too high (bad) rates over and over again. // To avoid that temporary degradations permanently reduce the maximum rate, // a stable bad rate "ages out" after "age_bad_rate_after_sec". AgeBadRateAfterSec int64 `protobuf:"varint,12,opt,name=age_bad_rate_after_sec,json=ageBadRateAfterSec,proto3" json:"age_bad_rate_after_sec,omitempty"` // bad_rate_increase defines the percentage by which a bad rate will be // increased when it's aging out. BadRateIncrease float64 `protobuf:"fixed64,13,opt,name=bad_rate_increase,json=badRateIncrease,proto3" json:"bad_rate_increase,omitempty"` // max_rate_approach_threshold is the fraction of the current rate limit that the actual // rate must exceed for the throttler to increase the limit when the replication lag // is below target_replication_lag_sec. For example, assuming the actual replication lag // is below target_replication_lag_sec, if the current rate limit is 100, then the actual // rate must exceed 100*max_rate_approach_threshold for the throttler to increase the current // limit. MaxRateApproachThreshold float64 `` /* 140-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Configuration holds the configuration parameters for the MaxReplicationLagModule which adaptively adjusts the throttling rate based on the observed replication lag across all replicas.
func (*Configuration) Descriptor ¶
func (*Configuration) Descriptor() ([]byte, []int)
func (*Configuration) GetAgeBadRateAfterSec ¶
func (m *Configuration) GetAgeBadRateAfterSec() int64
func (*Configuration) GetBadRateIncrease ¶
func (m *Configuration) GetBadRateIncrease() float64
func (*Configuration) GetEmergencyDecrease ¶
func (m *Configuration) GetEmergencyDecrease() float64
func (*Configuration) GetIgnoreNSlowestRdonlys ¶
func (m *Configuration) GetIgnoreNSlowestRdonlys() int32
func (*Configuration) GetIgnoreNSlowestReplicas ¶
func (m *Configuration) GetIgnoreNSlowestReplicas() int32
func (*Configuration) GetInitialRate ¶
func (m *Configuration) GetInitialRate() int64
func (*Configuration) GetMaxDurationBetweenIncreasesSec ¶
func (m *Configuration) GetMaxDurationBetweenIncreasesSec() int64
func (*Configuration) GetMaxIncrease ¶
func (m *Configuration) GetMaxIncrease() float64
func (*Configuration) GetMaxRateApproachThreshold ¶
func (m *Configuration) GetMaxRateApproachThreshold() float64
func (*Configuration) GetMaxReplicationLagSec ¶
func (m *Configuration) GetMaxReplicationLagSec() int64
func (*Configuration) GetMinDurationBetweenDecreasesSec ¶
func (m *Configuration) GetMinDurationBetweenDecreasesSec() int64
func (*Configuration) GetMinDurationBetweenIncreasesSec ¶
func (m *Configuration) GetMinDurationBetweenIncreasesSec() int64
func (*Configuration) GetSpreadBacklogAcrossSec ¶
func (m *Configuration) GetSpreadBacklogAcrossSec() int64
func (*Configuration) GetTargetReplicationLagSec ¶
func (m *Configuration) GetTargetReplicationLagSec() int64
func (*Configuration) ProtoMessage ¶
func (*Configuration) ProtoMessage()
func (*Configuration) Reset ¶
func (m *Configuration) Reset()
func (*Configuration) String ¶
func (m *Configuration) String() string
func (*Configuration) XXX_DiscardUnknown ¶
func (m *Configuration) XXX_DiscardUnknown()
func (*Configuration) XXX_Marshal ¶
func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Configuration) XXX_Merge ¶
func (m *Configuration) XXX_Merge(src proto.Message)
func (*Configuration) XXX_Size ¶
func (m *Configuration) XXX_Size() int
func (*Configuration) XXX_Unmarshal ¶
func (m *Configuration) XXX_Unmarshal(b []byte) error
type GetConfigurationRequest ¶
type GetConfigurationRequest struct { // throttler_name specifies which throttler to select. If empty, all active // throttlers will be selected. ThrottlerName string `protobuf:"bytes,1,opt,name=throttler_name,json=throttlerName,proto3" json:"throttler_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
GetConfigurationRequest is the payload for the GetConfiguration RPC.
func (*GetConfigurationRequest) Descriptor ¶
func (*GetConfigurationRequest) Descriptor() ([]byte, []int)
func (*GetConfigurationRequest) GetThrottlerName ¶
func (m *GetConfigurationRequest) GetThrottlerName() string
func (*GetConfigurationRequest) ProtoMessage ¶
func (*GetConfigurationRequest) ProtoMessage()
func (*GetConfigurationRequest) Reset ¶
func (m *GetConfigurationRequest) Reset()
func (*GetConfigurationRequest) String ¶
func (m *GetConfigurationRequest) String() string
func (*GetConfigurationRequest) XXX_DiscardUnknown ¶
func (m *GetConfigurationRequest) XXX_DiscardUnknown()
func (*GetConfigurationRequest) XXX_Marshal ¶
func (m *GetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetConfigurationRequest) XXX_Merge ¶
func (m *GetConfigurationRequest) XXX_Merge(src proto.Message)
func (*GetConfigurationRequest) XXX_Size ¶
func (m *GetConfigurationRequest) XXX_Size() int
func (*GetConfigurationRequest) XXX_Unmarshal ¶
func (m *GetConfigurationRequest) XXX_Unmarshal(b []byte) error
type GetConfigurationResponse ¶
type GetConfigurationResponse struct { // max_rates returns the configurations for each throttler. // It's keyed by the throttler name. Configurations map[string]*Configuration `` /* 169-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
GetConfigurationResponse is returned by the GetConfiguration RPC.
func (*GetConfigurationResponse) Descriptor ¶
func (*GetConfigurationResponse) Descriptor() ([]byte, []int)
func (*GetConfigurationResponse) GetConfigurations ¶
func (m *GetConfigurationResponse) GetConfigurations() map[string]*Configuration
func (*GetConfigurationResponse) ProtoMessage ¶
func (*GetConfigurationResponse) ProtoMessage()
func (*GetConfigurationResponse) Reset ¶
func (m *GetConfigurationResponse) Reset()
func (*GetConfigurationResponse) String ¶
func (m *GetConfigurationResponse) String() string
func (*GetConfigurationResponse) XXX_DiscardUnknown ¶
func (m *GetConfigurationResponse) XXX_DiscardUnknown()
func (*GetConfigurationResponse) XXX_Marshal ¶
func (m *GetConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetConfigurationResponse) XXX_Merge ¶
func (m *GetConfigurationResponse) XXX_Merge(src proto.Message)
func (*GetConfigurationResponse) XXX_Size ¶
func (m *GetConfigurationResponse) XXX_Size() int
func (*GetConfigurationResponse) XXX_Unmarshal ¶
func (m *GetConfigurationResponse) XXX_Unmarshal(b []byte) error
type MaxRatesRequest ¶
type MaxRatesRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
MaxRatesRequest is the payload for the MaxRates RPC.
func (*MaxRatesRequest) Descriptor ¶
func (*MaxRatesRequest) Descriptor() ([]byte, []int)
func (*MaxRatesRequest) ProtoMessage ¶
func (*MaxRatesRequest) ProtoMessage()
func (*MaxRatesRequest) Reset ¶
func (m *MaxRatesRequest) Reset()
func (*MaxRatesRequest) String ¶
func (m *MaxRatesRequest) String() string
func (*MaxRatesRequest) XXX_DiscardUnknown ¶
func (m *MaxRatesRequest) XXX_DiscardUnknown()
func (*MaxRatesRequest) XXX_Marshal ¶
func (m *MaxRatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MaxRatesRequest) XXX_Merge ¶
func (m *MaxRatesRequest) XXX_Merge(src proto.Message)
func (*MaxRatesRequest) XXX_Size ¶
func (m *MaxRatesRequest) XXX_Size() int
func (*MaxRatesRequest) XXX_Unmarshal ¶
func (m *MaxRatesRequest) XXX_Unmarshal(b []byte) error
type MaxRatesResponse ¶
type MaxRatesResponse struct { // max_rates returns the max rate for each throttler. It's keyed by the // throttler name. Rates map[string]int64 `` /* 152-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
MaxRatesResponse is returned by the MaxRates RPC.
func (*MaxRatesResponse) Descriptor ¶
func (*MaxRatesResponse) Descriptor() ([]byte, []int)
func (*MaxRatesResponse) GetRates ¶
func (m *MaxRatesResponse) GetRates() map[string]int64
func (*MaxRatesResponse) ProtoMessage ¶
func (*MaxRatesResponse) ProtoMessage()
func (*MaxRatesResponse) Reset ¶
func (m *MaxRatesResponse) Reset()
func (*MaxRatesResponse) String ¶
func (m *MaxRatesResponse) String() string
func (*MaxRatesResponse) XXX_DiscardUnknown ¶
func (m *MaxRatesResponse) XXX_DiscardUnknown()
func (*MaxRatesResponse) XXX_Marshal ¶
func (m *MaxRatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MaxRatesResponse) XXX_Merge ¶
func (m *MaxRatesResponse) XXX_Merge(src proto.Message)
func (*MaxRatesResponse) XXX_Size ¶
func (m *MaxRatesResponse) XXX_Size() int
func (*MaxRatesResponse) XXX_Unmarshal ¶
func (m *MaxRatesResponse) XXX_Unmarshal(b []byte) error
type ResetConfigurationRequest ¶
type ResetConfigurationRequest struct { // throttler_name specifies which throttler to reset. If empty, all active // throttlers will be reset. ThrottlerName string `protobuf:"bytes,1,opt,name=throttler_name,json=throttlerName,proto3" json:"throttler_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ResetConfigurationRequest is the payload for the ResetConfiguration RPC.
func (*ResetConfigurationRequest) Descriptor ¶
func (*ResetConfigurationRequest) Descriptor() ([]byte, []int)
func (*ResetConfigurationRequest) GetThrottlerName ¶
func (m *ResetConfigurationRequest) GetThrottlerName() string
func (*ResetConfigurationRequest) ProtoMessage ¶
func (*ResetConfigurationRequest) ProtoMessage()
func (*ResetConfigurationRequest) Reset ¶
func (m *ResetConfigurationRequest) Reset()
func (*ResetConfigurationRequest) String ¶
func (m *ResetConfigurationRequest) String() string
func (*ResetConfigurationRequest) XXX_DiscardUnknown ¶
func (m *ResetConfigurationRequest) XXX_DiscardUnknown()
func (*ResetConfigurationRequest) XXX_Marshal ¶
func (m *ResetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResetConfigurationRequest) XXX_Merge ¶
func (m *ResetConfigurationRequest) XXX_Merge(src proto.Message)
func (*ResetConfigurationRequest) XXX_Size ¶
func (m *ResetConfigurationRequest) XXX_Size() int
func (*ResetConfigurationRequest) XXX_Unmarshal ¶
func (m *ResetConfigurationRequest) XXX_Unmarshal(b []byte) error
type ResetConfigurationResponse ¶
type ResetConfigurationResponse struct { // names is the list of throttler names which were updated. Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ResetConfigurationResponse is returned by the ResetConfiguration RPC.
func (*ResetConfigurationResponse) Descriptor ¶
func (*ResetConfigurationResponse) Descriptor() ([]byte, []int)
func (*ResetConfigurationResponse) GetNames ¶
func (m *ResetConfigurationResponse) GetNames() []string
func (*ResetConfigurationResponse) ProtoMessage ¶
func (*ResetConfigurationResponse) ProtoMessage()
func (*ResetConfigurationResponse) Reset ¶
func (m *ResetConfigurationResponse) Reset()
func (*ResetConfigurationResponse) String ¶
func (m *ResetConfigurationResponse) String() string
func (*ResetConfigurationResponse) XXX_DiscardUnknown ¶
func (m *ResetConfigurationResponse) XXX_DiscardUnknown()
func (*ResetConfigurationResponse) XXX_Marshal ¶
func (m *ResetConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResetConfigurationResponse) XXX_Merge ¶
func (m *ResetConfigurationResponse) XXX_Merge(src proto.Message)
func (*ResetConfigurationResponse) XXX_Size ¶
func (m *ResetConfigurationResponse) XXX_Size() int
func (*ResetConfigurationResponse) XXX_Unmarshal ¶
func (m *ResetConfigurationResponse) XXX_Unmarshal(b []byte) error
type SetMaxRateRequest ¶
type SetMaxRateRequest struct { Rate int64 `protobuf:"varint,1,opt,name=rate,proto3" json:"rate,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SetMaxRateRequest is the payload for the SetMaxRate RPC.
func (*SetMaxRateRequest) Descriptor ¶
func (*SetMaxRateRequest) Descriptor() ([]byte, []int)
func (*SetMaxRateRequest) GetRate ¶
func (m *SetMaxRateRequest) GetRate() int64
func (*SetMaxRateRequest) ProtoMessage ¶
func (*SetMaxRateRequest) ProtoMessage()
func (*SetMaxRateRequest) Reset ¶
func (m *SetMaxRateRequest) Reset()
func (*SetMaxRateRequest) String ¶
func (m *SetMaxRateRequest) String() string
func (*SetMaxRateRequest) XXX_DiscardUnknown ¶
func (m *SetMaxRateRequest) XXX_DiscardUnknown()
func (*SetMaxRateRequest) XXX_Marshal ¶
func (m *SetMaxRateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetMaxRateRequest) XXX_Merge ¶
func (m *SetMaxRateRequest) XXX_Merge(src proto.Message)
func (*SetMaxRateRequest) XXX_Size ¶
func (m *SetMaxRateRequest) XXX_Size() int
func (*SetMaxRateRequest) XXX_Unmarshal ¶
func (m *SetMaxRateRequest) XXX_Unmarshal(b []byte) error
type SetMaxRateResponse ¶
type SetMaxRateResponse struct { // names is the list of throttler names which were updated. Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SetMaxRateResponse is returned by the SetMaxRate RPC.
func (*SetMaxRateResponse) Descriptor ¶
func (*SetMaxRateResponse) Descriptor() ([]byte, []int)
func (*SetMaxRateResponse) GetNames ¶
func (m *SetMaxRateResponse) GetNames() []string
func (*SetMaxRateResponse) ProtoMessage ¶
func (*SetMaxRateResponse) ProtoMessage()
func (*SetMaxRateResponse) Reset ¶
func (m *SetMaxRateResponse) Reset()
func (*SetMaxRateResponse) String ¶
func (m *SetMaxRateResponse) String() string
func (*SetMaxRateResponse) XXX_DiscardUnknown ¶
func (m *SetMaxRateResponse) XXX_DiscardUnknown()
func (*SetMaxRateResponse) XXX_Marshal ¶
func (m *SetMaxRateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetMaxRateResponse) XXX_Merge ¶
func (m *SetMaxRateResponse) XXX_Merge(src proto.Message)
func (*SetMaxRateResponse) XXX_Size ¶
func (m *SetMaxRateResponse) XXX_Size() int
func (*SetMaxRateResponse) XXX_Unmarshal ¶
func (m *SetMaxRateResponse) XXX_Unmarshal(b []byte) error
type UpdateConfigurationRequest ¶
type UpdateConfigurationRequest struct { // throttler_name specifies which throttler to update. If empty, all active // throttlers will be updated. ThrottlerName string `protobuf:"bytes,1,opt,name=throttler_name,json=throttlerName,proto3" json:"throttler_name,omitempty"` // configuration is the new (partial) configuration. Configuration *Configuration `protobuf:"bytes,2,opt,name=configuration,proto3" json:"configuration,omitempty"` // copy_zero_values specifies whether fields with zero values should be copied // as well. CopyZeroValues bool `protobuf:"varint,3,opt,name=copy_zero_values,json=copyZeroValues,proto3" json:"copy_zero_values,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
UpdateConfigurationRequest is the payload for the UpdateConfiguration RPC.
func (*UpdateConfigurationRequest) Descriptor ¶
func (*UpdateConfigurationRequest) Descriptor() ([]byte, []int)
func (*UpdateConfigurationRequest) GetConfiguration ¶
func (m *UpdateConfigurationRequest) GetConfiguration() *Configuration
func (*UpdateConfigurationRequest) GetCopyZeroValues ¶
func (m *UpdateConfigurationRequest) GetCopyZeroValues() bool
func (*UpdateConfigurationRequest) GetThrottlerName ¶
func (m *UpdateConfigurationRequest) GetThrottlerName() string
func (*UpdateConfigurationRequest) ProtoMessage ¶
func (*UpdateConfigurationRequest) ProtoMessage()
func (*UpdateConfigurationRequest) Reset ¶
func (m *UpdateConfigurationRequest) Reset()
func (*UpdateConfigurationRequest) String ¶
func (m *UpdateConfigurationRequest) String() string
func (*UpdateConfigurationRequest) XXX_DiscardUnknown ¶
func (m *UpdateConfigurationRequest) XXX_DiscardUnknown()
func (*UpdateConfigurationRequest) XXX_Marshal ¶
func (m *UpdateConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateConfigurationRequest) XXX_Merge ¶
func (m *UpdateConfigurationRequest) XXX_Merge(src proto.Message)
func (*UpdateConfigurationRequest) XXX_Size ¶
func (m *UpdateConfigurationRequest) XXX_Size() int
func (*UpdateConfigurationRequest) XXX_Unmarshal ¶
func (m *UpdateConfigurationRequest) XXX_Unmarshal(b []byte) error
type UpdateConfigurationResponse ¶
type UpdateConfigurationResponse struct { // names is the list of throttler names which were updated. Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
UpdateConfigurationResponse is returned by the UpdateConfiguration RPC.
func (*UpdateConfigurationResponse) Descriptor ¶
func (*UpdateConfigurationResponse) Descriptor() ([]byte, []int)
func (*UpdateConfigurationResponse) GetNames ¶
func (m *UpdateConfigurationResponse) GetNames() []string
func (*UpdateConfigurationResponse) ProtoMessage ¶
func (*UpdateConfigurationResponse) ProtoMessage()
func (*UpdateConfigurationResponse) Reset ¶
func (m *UpdateConfigurationResponse) Reset()
func (*UpdateConfigurationResponse) String ¶
func (m *UpdateConfigurationResponse) String() string
func (*UpdateConfigurationResponse) XXX_DiscardUnknown ¶
func (m *UpdateConfigurationResponse) XXX_DiscardUnknown()
func (*UpdateConfigurationResponse) XXX_Marshal ¶
func (m *UpdateConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateConfigurationResponse) XXX_Merge ¶
func (m *UpdateConfigurationResponse) XXX_Merge(src proto.Message)
func (*UpdateConfigurationResponse) XXX_Size ¶
func (m *UpdateConfigurationResponse) XXX_Size() int
func (*UpdateConfigurationResponse) XXX_Unmarshal ¶
func (m *UpdateConfigurationResponse) XXX_Unmarshal(b []byte) error