throttlerdata

package
v0.19.3 Latest Latest
Warning

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

 Go to latest Published: Apr 4, 2024 License: Apache-2.0 Imports: 10 Imported by: 16

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_throttlerdata_proto protoreflect.FileDescriptor

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

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) CloneMessageVT added in v0.18.0 

func (m *Configuration) CloneMessageVT() proto.Message

func (*Configuration) CloneVT added in v0.18.0 

func (m *Configuration) CloneVT() *Configuration

func (*Configuration) Descriptor deprecated 

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

Deprecated: Use Configuration.ProtoReflect.Descriptor instead.

func (*Configuration) GetAgeBadRateAfterSec 

func (x *Configuration) GetAgeBadRateAfterSec() int64

func (*Configuration) GetBadRateIncrease 

func (x *Configuration) GetBadRateIncrease() float64

func (*Configuration) GetEmergencyDecrease 

func (x *Configuration) GetEmergencyDecrease() float64

func (*Configuration) GetIgnoreNSlowestRdonlys 

func (x *Configuration) GetIgnoreNSlowestRdonlys() int32

func (*Configuration) GetIgnoreNSlowestReplicas 

func (x *Configuration) GetIgnoreNSlowestReplicas() int32

func (*Configuration) GetInitialRate 

func (x *Configuration) GetInitialRate() int64

func (*Configuration) GetMaxDurationBetweenIncreasesSec 

func (x *Configuration) GetMaxDurationBetweenIncreasesSec() int64

func (*Configuration) GetMaxIncrease 

func (x *Configuration) GetMaxIncrease() float64

func (*Configuration) GetMaxRateApproachThreshold 

func (x *Configuration) GetMaxRateApproachThreshold() float64

func (*Configuration) GetMaxReplicationLagSec 

func (x *Configuration) GetMaxReplicationLagSec() int64

func (*Configuration) GetMinDurationBetweenDecreasesSec 

func (x *Configuration) GetMinDurationBetweenDecreasesSec() int64

func (*Configuration) GetMinDurationBetweenIncreasesSec 

func (x *Configuration) GetMinDurationBetweenIncreasesSec() int64

func (*Configuration) GetSpreadBacklogAcrossSec 

func (x *Configuration) GetSpreadBacklogAcrossSec() int64

func (*Configuration) GetTargetReplicationLagSec 

func (x *Configuration) GetTargetReplicationLagSec() int64

func (*Configuration) MarshalToSizedBufferVT added in v0.11.0 

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

func (*Configuration) MarshalToVT added in v0.11.0 

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

func (*Configuration) MarshalVT added in v0.11.0 

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

func (*Configuration) ProtoMessage 

func (*Configuration) ProtoMessage()

func (*Configuration) ProtoReflect added in v0.11.0 

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

func (*Configuration) Reset 

func (x *Configuration) Reset()

func (*Configuration) SizeVT added in v0.11.0 

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

func (*Configuration) String 

func (x *Configuration) String() string

func (*Configuration) UnmarshalVT added in v0.11.0 

func (m *Configuration) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

GetConfigurationRequest is the payload for the GetConfiguration RPC.

func (*GetConfigurationRequest) CloneMessageVT added in v0.18.0 

func (m *GetConfigurationRequest) CloneMessageVT() proto.Message

func (*GetConfigurationRequest) CloneVT added in v0.18.0 

func (m *GetConfigurationRequest) CloneVT() *GetConfigurationRequest

func (*GetConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) GetThrottlerName 

func (x *GetConfigurationRequest) GetThrottlerName() string

func (*GetConfigurationRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetConfigurationRequest) MarshalToVT added in v0.11.0 

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

func (*GetConfigurationRequest) MarshalVT added in v0.11.0 

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

func (*GetConfigurationRequest) ProtoMessage 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect added in v0.11.0 

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

func (*GetConfigurationRequest) Reset 

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) SizeVT added in v0.11.0 

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

func (*GetConfigurationRequest) String 

func (x *GetConfigurationRequest) String() string

func (*GetConfigurationRequest) UnmarshalVT added in v0.11.0 

func (m *GetConfigurationRequest) UnmarshalVT(dAtA []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 */
	// contains filtered or unexported fields
}

GetConfigurationResponse is returned by the GetConfiguration RPC.

func (*GetConfigurationResponse) CloneMessageVT added in v0.18.0 

func (m *GetConfigurationResponse) CloneMessageVT() proto.Message

func (*GetConfigurationResponse) CloneVT added in v0.18.0 

func (m *GetConfigurationResponse) CloneVT() *GetConfigurationResponse

func (*GetConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetConfigurations 

func (x *GetConfigurationResponse) GetConfigurations() map[string]*Configuration

func (*GetConfigurationResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetConfigurationResponse) MarshalToVT added in v0.11.0 

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

func (*GetConfigurationResponse) MarshalVT added in v0.11.0 

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

func (*GetConfigurationResponse) ProtoMessage 

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect added in v0.11.0 

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

func (*GetConfigurationResponse) Reset 

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) SizeVT added in v0.11.0 

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

func (*GetConfigurationResponse) String 

func (x *GetConfigurationResponse) String() string

func (*GetConfigurationResponse) UnmarshalVT added in v0.11.0 

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

type MaxRatesRequest 

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

MaxRatesRequest is the payload for the MaxRates RPC.

func (*MaxRatesRequest) CloneMessageVT added in v0.18.0 

func (m *MaxRatesRequest) CloneMessageVT() proto.Message

func (*MaxRatesRequest) CloneVT added in v0.18.0 

func (m *MaxRatesRequest) CloneVT() *MaxRatesRequest

func (*MaxRatesRequest) Descriptor deprecated 

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

Deprecated: Use MaxRatesRequest.ProtoReflect.Descriptor instead.

func (*MaxRatesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*MaxRatesRequest) MarshalToVT added in v0.11.0 

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

func (*MaxRatesRequest) MarshalVT added in v0.11.0 

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

func (*MaxRatesRequest) ProtoMessage 

func (*MaxRatesRequest) ProtoMessage()

func (*MaxRatesRequest) ProtoReflect added in v0.11.0 

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

func (*MaxRatesRequest) Reset 

func (x *MaxRatesRequest) Reset()

func (*MaxRatesRequest) SizeVT added in v0.11.0 

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

func (*MaxRatesRequest) String 

func (x *MaxRatesRequest) String() string

func (*MaxRatesRequest) UnmarshalVT added in v0.11.0 

func (m *MaxRatesRequest) UnmarshalVT(dAtA []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 */
	// contains filtered or unexported fields
}

MaxRatesResponse is returned by the MaxRates RPC.

func (*MaxRatesResponse) CloneMessageVT added in v0.18.0 

func (m *MaxRatesResponse) CloneMessageVT() proto.Message

func (*MaxRatesResponse) CloneVT added in v0.18.0 

func (m *MaxRatesResponse) CloneVT() *MaxRatesResponse

func (*MaxRatesResponse) Descriptor deprecated 

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

Deprecated: Use MaxRatesResponse.ProtoReflect.Descriptor instead.

func (*MaxRatesResponse) GetRates 

func (x *MaxRatesResponse) GetRates() map[string]int64

func (*MaxRatesResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*MaxRatesResponse) MarshalToVT added in v0.11.0 

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

func (*MaxRatesResponse) MarshalVT added in v0.11.0 

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

func (*MaxRatesResponse) ProtoMessage 

func (*MaxRatesResponse) ProtoMessage()

func (*MaxRatesResponse) ProtoReflect added in v0.11.0 

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

func (*MaxRatesResponse) Reset 

func (x *MaxRatesResponse) Reset()

func (*MaxRatesResponse) SizeVT added in v0.11.0 

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

func (*MaxRatesResponse) String 

func (x *MaxRatesResponse) String() string

func (*MaxRatesResponse) UnmarshalVT added in v0.11.0 

func (m *MaxRatesResponse) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

ResetConfigurationRequest is the payload for the ResetConfiguration RPC.

func (*ResetConfigurationRequest) CloneMessageVT added in v0.18.0 

func (m *ResetConfigurationRequest) CloneMessageVT() proto.Message

func (*ResetConfigurationRequest) CloneVT added in v0.18.0 

func (m *ResetConfigurationRequest) CloneVT() *ResetConfigurationRequest

func (*ResetConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use ResetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*ResetConfigurationRequest) GetThrottlerName 

func (x *ResetConfigurationRequest) GetThrottlerName() string

func (*ResetConfigurationRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ResetConfigurationRequest) MarshalToVT added in v0.11.0 

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

func (*ResetConfigurationRequest) MarshalVT added in v0.11.0 

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

func (*ResetConfigurationRequest) ProtoMessage 

func (*ResetConfigurationRequest) ProtoMessage()

func (*ResetConfigurationRequest) ProtoReflect added in v0.11.0 

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

func (*ResetConfigurationRequest) Reset 

func (x *ResetConfigurationRequest) Reset()

func (*ResetConfigurationRequest) SizeVT added in v0.11.0 

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

func (*ResetConfigurationRequest) String 

func (x *ResetConfigurationRequest) String() string

func (*ResetConfigurationRequest) UnmarshalVT added in v0.11.0 

func (m *ResetConfigurationRequest) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

ResetConfigurationResponse is returned by the ResetConfiguration RPC.

func (*ResetConfigurationResponse) CloneMessageVT added in v0.18.0 

func (m *ResetConfigurationResponse) CloneMessageVT() proto.Message

func (*ResetConfigurationResponse) CloneVT added in v0.18.0 

func (m *ResetConfigurationResponse) CloneVT() *ResetConfigurationResponse

func (*ResetConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use ResetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*ResetConfigurationResponse) GetNames 

func (x *ResetConfigurationResponse) GetNames() []string

func (*ResetConfigurationResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ResetConfigurationResponse) MarshalToVT added in v0.11.0 

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

func (*ResetConfigurationResponse) MarshalVT added in v0.11.0 

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

func (*ResetConfigurationResponse) ProtoMessage 

func (*ResetConfigurationResponse) ProtoMessage()

func (*ResetConfigurationResponse) ProtoReflect added in v0.11.0 

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

func (*ResetConfigurationResponse) Reset 

func (x *ResetConfigurationResponse) Reset()

func (*ResetConfigurationResponse) SizeVT added in v0.11.0 

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

func (*ResetConfigurationResponse) String 

func (x *ResetConfigurationResponse) String() string

func (*ResetConfigurationResponse) UnmarshalVT added in v0.11.0 

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

type SetMaxRateRequest 

type SetMaxRateRequest struct {
	Rate int64 `protobuf:"varint,1,opt,name=rate,proto3" json:"rate,omitempty"`
	// contains filtered or unexported fields
}

SetMaxRateRequest is the payload for the SetMaxRate RPC.

func (*SetMaxRateRequest) CloneMessageVT added in v0.18.0 

func (m *SetMaxRateRequest) CloneMessageVT() proto.Message

func (*SetMaxRateRequest) CloneVT added in v0.18.0 

func (m *SetMaxRateRequest) CloneVT() *SetMaxRateRequest

func (*SetMaxRateRequest) Descriptor deprecated 

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

Deprecated: Use SetMaxRateRequest.ProtoReflect.Descriptor instead.

func (*SetMaxRateRequest) GetRate 

func (x *SetMaxRateRequest) GetRate() int64

func (*SetMaxRateRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*SetMaxRateRequest) MarshalToVT added in v0.11.0 

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

func (*SetMaxRateRequest) MarshalVT added in v0.11.0 

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

func (*SetMaxRateRequest) ProtoMessage 

func (*SetMaxRateRequest) ProtoMessage()

func (*SetMaxRateRequest) ProtoReflect added in v0.11.0 

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

func (*SetMaxRateRequest) Reset 

func (x *SetMaxRateRequest) Reset()

func (*SetMaxRateRequest) SizeVT added in v0.11.0 

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

func (*SetMaxRateRequest) String 

func (x *SetMaxRateRequest) String() string

func (*SetMaxRateRequest) UnmarshalVT added in v0.11.0 

func (m *SetMaxRateRequest) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

SetMaxRateResponse is returned by the SetMaxRate RPC.

func (*SetMaxRateResponse) CloneMessageVT added in v0.18.0 

func (m *SetMaxRateResponse) CloneMessageVT() proto.Message

func (*SetMaxRateResponse) CloneVT added in v0.18.0 

func (m *SetMaxRateResponse) CloneVT() *SetMaxRateResponse

func (*SetMaxRateResponse) Descriptor deprecated 

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

Deprecated: Use SetMaxRateResponse.ProtoReflect.Descriptor instead.

func (*SetMaxRateResponse) GetNames 

func (x *SetMaxRateResponse) GetNames() []string

func (*SetMaxRateResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*SetMaxRateResponse) MarshalToVT added in v0.11.0 

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

func (*SetMaxRateResponse) MarshalVT added in v0.11.0 

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

func (*SetMaxRateResponse) ProtoMessage 

func (*SetMaxRateResponse) ProtoMessage()

func (*SetMaxRateResponse) ProtoReflect added in v0.11.0 

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

func (*SetMaxRateResponse) Reset 

func (x *SetMaxRateResponse) Reset()

func (*SetMaxRateResponse) SizeVT added in v0.11.0 

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

func (*SetMaxRateResponse) String 

func (x *SetMaxRateResponse) String() string

func (*SetMaxRateResponse) UnmarshalVT added in v0.11.0 

func (m *SetMaxRateResponse) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

UpdateConfigurationRequest is the payload for the UpdateConfiguration RPC.

func (*UpdateConfigurationRequest) CloneMessageVT added in v0.18.0 

func (m *UpdateConfigurationRequest) CloneMessageVT() proto.Message

func (*UpdateConfigurationRequest) CloneVT added in v0.18.0 

func (m *UpdateConfigurationRequest) CloneVT() *UpdateConfigurationRequest

func (*UpdateConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConfigurationRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigurationRequest) GetConfiguration 

func (x *UpdateConfigurationRequest) GetConfiguration() *Configuration

func (*UpdateConfigurationRequest) GetCopyZeroValues 

func (x *UpdateConfigurationRequest) GetCopyZeroValues() bool

func (*UpdateConfigurationRequest) GetThrottlerName 

func (x *UpdateConfigurationRequest) GetThrottlerName() string

func (*UpdateConfigurationRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*UpdateConfigurationRequest) MarshalToVT added in v0.11.0 

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

func (*UpdateConfigurationRequest) MarshalVT added in v0.11.0 

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

func (*UpdateConfigurationRequest) ProtoMessage 

func (*UpdateConfigurationRequest) ProtoMessage()

func (*UpdateConfigurationRequest) ProtoReflect added in v0.11.0 

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

func (*UpdateConfigurationRequest) Reset 

func (x *UpdateConfigurationRequest) Reset()

func (*UpdateConfigurationRequest) SizeVT added in v0.11.0 

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

func (*UpdateConfigurationRequest) String 

func (x *UpdateConfigurationRequest) String() string

func (*UpdateConfigurationRequest) UnmarshalVT added in v0.11.0 

func (m *UpdateConfigurationRequest) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

UpdateConfigurationResponse is returned by the UpdateConfiguration RPC.

func (*UpdateConfigurationResponse) CloneMessageVT added in v0.18.0 

func (m *UpdateConfigurationResponse) CloneMessageVT() proto.Message

func (*UpdateConfigurationResponse) CloneVT added in v0.18.0 

func (m *UpdateConfigurationResponse) CloneVT() *UpdateConfigurationResponse

func (*UpdateConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use UpdateConfigurationResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigurationResponse) GetNames 

func (x *UpdateConfigurationResponse) GetNames() []string

func (*UpdateConfigurationResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*UpdateConfigurationResponse) MarshalToVT added in v0.11.0 

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

func (*UpdateConfigurationResponse) MarshalVT added in v0.11.0 

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

func (*UpdateConfigurationResponse) ProtoMessage 

func (*UpdateConfigurationResponse) ProtoMessage()

func (*UpdateConfigurationResponse) ProtoReflect added in v0.11.0 

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

func (*UpdateConfigurationResponse) Reset 

func (x *UpdateConfigurationResponse) Reset()

func (*UpdateConfigurationResponse) SizeVT added in v0.11.0 

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

func (*UpdateConfigurationResponse) String 

func (x *UpdateConfigurationResponse) String() string

func (*UpdateConfigurationResponse) UnmarshalVT added in v0.11.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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