go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/proto/throttlerdata Index | Files

package throttlerdata

import "gopkg.in/src-d/go-vitess.v1/vt/proto/throttlerdata"

Index

Package Files

throttlerdata.pb.go

type Configuration Uses

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
    // slave throughput.
    TargetReplicationLagSec int64 `protobuf:"varint,1,opt,name=target_replication_lag_sec,json=targetReplicationLagSec,proto3" json:"target_replication_lag_sec,omitempty"`
    // 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 `protobuf:"varint,2,opt,name=max_replication_lag_sec,json=maxReplicationLagSec,proto3" json:"max_replication_lag_sec,omitempty"`
    // 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 `protobuf:"varint,6,opt,name=min_duration_between_increases_sec,json=minDurationBetweenIncreasesSec,proto3" json:"min_duration_between_increases_sec,omitempty"`
    // 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 `protobuf:"varint,7,opt,name=max_duration_between_increases_sec,json=maxDurationBetweenIncreasesSec,proto3" json:"max_duration_between_increases_sec,omitempty"`
    // 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 `protobuf:"varint,8,opt,name=min_duration_between_decreases_sec,json=minDurationBetweenDecreasesSec,proto3" json:"min_duration_between_decreases_sec,omitempty"`
    // spread_backlog_across_sec is used when we set the throttler rate after
    // we guessed the rate of a slave 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 slave 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 `protobuf:"varint,9,opt,name=spread_backlog_across_sec,json=spreadBacklogAcrossSec,proto3" json:"spread_backlog_across_sec,omitempty"`
    // 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 `protobuf:"varint,10,opt,name=ignore_n_slowest_replicas,json=ignoreNSlowestReplicas,proto3" json:"ignore_n_slowest_replicas,omitempty"`
    // 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 `protobuf:"varint,11,opt,name=ignore_n_slowest_rdonlys,json=ignoreNSlowestRdonlys,proto3" json:"ignore_n_slowest_rdonlys,omitempty"`
    // 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  `protobuf:"fixed64,14,opt,name=max_rate_approach_threshold,json=maxRateApproachThreshold,proto3" json:"max_rate_approach_threshold,omitempty"`
    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 Uses

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

func (*Configuration) GetAgeBadRateAfterSec Uses

func (m *Configuration) GetAgeBadRateAfterSec() int64

func (*Configuration) GetBadRateIncrease Uses

func (m *Configuration) GetBadRateIncrease() float64

func (*Configuration) GetEmergencyDecrease Uses

func (m *Configuration) GetEmergencyDecrease() float64

func (*Configuration) GetIgnoreNSlowestRdonlys Uses

func (m *Configuration) GetIgnoreNSlowestRdonlys() int32

func (*Configuration) GetIgnoreNSlowestReplicas Uses

func (m *Configuration) GetIgnoreNSlowestReplicas() int32

func (*Configuration) GetInitialRate Uses

func (m *Configuration) GetInitialRate() int64

func (*Configuration) GetMaxDurationBetweenIncreasesSec Uses

func (m *Configuration) GetMaxDurationBetweenIncreasesSec() int64

func (*Configuration) GetMaxIncrease Uses

func (m *Configuration) GetMaxIncrease() float64

func (*Configuration) GetMaxRateApproachThreshold Uses

func (m *Configuration) GetMaxRateApproachThreshold() float64

func (*Configuration) GetMaxReplicationLagSec Uses

func (m *Configuration) GetMaxReplicationLagSec() int64

func (*Configuration) GetMinDurationBetweenDecreasesSec Uses

func (m *Configuration) GetMinDurationBetweenDecreasesSec() int64

func (*Configuration) GetMinDurationBetweenIncreasesSec Uses

func (m *Configuration) GetMinDurationBetweenIncreasesSec() int64

func (*Configuration) GetSpreadBacklogAcrossSec Uses

func (m *Configuration) GetSpreadBacklogAcrossSec() int64

func (*Configuration) GetTargetReplicationLagSec Uses

func (m *Configuration) GetTargetReplicationLagSec() int64

func (*Configuration) ProtoMessage Uses

func (*Configuration) ProtoMessage()

func (*Configuration) Reset Uses

func (m *Configuration) Reset()

func (*Configuration) String Uses

func (m *Configuration) String() string

func (*Configuration) XXX_DiscardUnknown Uses

func (m *Configuration) XXX_DiscardUnknown()

func (*Configuration) XXX_Marshal Uses

func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Configuration) XXX_Merge Uses

func (dst *Configuration) XXX_Merge(src proto.Message)

func (*Configuration) XXX_Size Uses

func (m *Configuration) XXX_Size() int

func (*Configuration) XXX_Unmarshal Uses

func (m *Configuration) XXX_Unmarshal(b []byte) error

type GetConfigurationRequest Uses

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 Uses

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

func (*GetConfigurationRequest) GetThrottlerName Uses

func (m *GetConfigurationRequest) GetThrottlerName() string

func (*GetConfigurationRequest) ProtoMessage Uses

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) Reset Uses

func (m *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String Uses

func (m *GetConfigurationRequest) String() string

func (*GetConfigurationRequest) XXX_DiscardUnknown Uses

func (m *GetConfigurationRequest) XXX_DiscardUnknown()

func (*GetConfigurationRequest) XXX_Marshal Uses

func (m *GetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetConfigurationRequest) XXX_Merge Uses

func (dst *GetConfigurationRequest) XXX_Merge(src proto.Message)

func (*GetConfigurationRequest) XXX_Size Uses

func (m *GetConfigurationRequest) XXX_Size() int

func (*GetConfigurationRequest) XXX_Unmarshal Uses

func (m *GetConfigurationRequest) XXX_Unmarshal(b []byte) error

type GetConfigurationResponse Uses

type GetConfigurationResponse struct {
    // max_rates returns the configurations for each throttler.
    // It's keyed by the throttler name.
    Configurations       map[string]*Configuration `protobuf:"bytes,1,rep,name=configurations,proto3" json:"configurations,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
    XXX_unrecognized     []byte                    `json:"-"`
    XXX_sizecache        int32                     `json:"-"`
}

GetConfigurationResponse is returned by the GetConfiguration RPC.

func (*GetConfigurationResponse) Descriptor Uses

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

func (*GetConfigurationResponse) GetConfigurations Uses

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

func (*GetConfigurationResponse) ProtoMessage Uses

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) Reset Uses

func (m *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String Uses

func (m *GetConfigurationResponse) String() string

func (*GetConfigurationResponse) XXX_DiscardUnknown Uses

func (m *GetConfigurationResponse) XXX_DiscardUnknown()

func (*GetConfigurationResponse) XXX_Marshal Uses

func (m *GetConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetConfigurationResponse) XXX_Merge Uses

func (dst *GetConfigurationResponse) XXX_Merge(src proto.Message)

func (*GetConfigurationResponse) XXX_Size Uses

func (m *GetConfigurationResponse) XXX_Size() int

func (*GetConfigurationResponse) XXX_Unmarshal Uses

func (m *GetConfigurationResponse) XXX_Unmarshal(b []byte) error

type MaxRatesRequest Uses

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 Uses

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

func (*MaxRatesRequest) ProtoMessage Uses

func (*MaxRatesRequest) ProtoMessage()

func (*MaxRatesRequest) Reset Uses

func (m *MaxRatesRequest) Reset()

func (*MaxRatesRequest) String Uses

func (m *MaxRatesRequest) String() string

func (*MaxRatesRequest) XXX_DiscardUnknown Uses

func (m *MaxRatesRequest) XXX_DiscardUnknown()

func (*MaxRatesRequest) XXX_Marshal Uses

func (m *MaxRatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MaxRatesRequest) XXX_Merge Uses

func (dst *MaxRatesRequest) XXX_Merge(src proto.Message)

func (*MaxRatesRequest) XXX_Size Uses

func (m *MaxRatesRequest) XXX_Size() int

func (*MaxRatesRequest) XXX_Unmarshal Uses

func (m *MaxRatesRequest) XXX_Unmarshal(b []byte) error

type MaxRatesResponse Uses

type MaxRatesResponse struct {
    // max_rates returns the max rate for each throttler. It's keyed by the
    // throttler name.
    Rates                map[string]int64 `protobuf:"bytes,1,rep,name=rates,proto3" json:"rates,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

MaxRatesResponse is returned by the MaxRates RPC.

func (*MaxRatesResponse) Descriptor Uses

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

func (*MaxRatesResponse) GetRates Uses

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

func (*MaxRatesResponse) ProtoMessage Uses

func (*MaxRatesResponse) ProtoMessage()

func (*MaxRatesResponse) Reset Uses

func (m *MaxRatesResponse) Reset()

func (*MaxRatesResponse) String Uses

func (m *MaxRatesResponse) String() string

func (*MaxRatesResponse) XXX_DiscardUnknown Uses

func (m *MaxRatesResponse) XXX_DiscardUnknown()

func (*MaxRatesResponse) XXX_Marshal Uses

func (m *MaxRatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MaxRatesResponse) XXX_Merge Uses

func (dst *MaxRatesResponse) XXX_Merge(src proto.Message)

func (*MaxRatesResponse) XXX_Size Uses

func (m *MaxRatesResponse) XXX_Size() int

func (*MaxRatesResponse) XXX_Unmarshal Uses

func (m *MaxRatesResponse) XXX_Unmarshal(b []byte) error

type ResetConfigurationRequest Uses

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 Uses

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

func (*ResetConfigurationRequest) GetThrottlerName Uses

func (m *ResetConfigurationRequest) GetThrottlerName() string

func (*ResetConfigurationRequest) ProtoMessage Uses

func (*ResetConfigurationRequest) ProtoMessage()

func (*ResetConfigurationRequest) Reset Uses

func (m *ResetConfigurationRequest) Reset()

func (*ResetConfigurationRequest) String Uses

func (m *ResetConfigurationRequest) String() string

func (*ResetConfigurationRequest) XXX_DiscardUnknown Uses

func (m *ResetConfigurationRequest) XXX_DiscardUnknown()

func (*ResetConfigurationRequest) XXX_Marshal Uses

func (m *ResetConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetConfigurationRequest) XXX_Merge Uses

func (dst *ResetConfigurationRequest) XXX_Merge(src proto.Message)

func (*ResetConfigurationRequest) XXX_Size Uses

func (m *ResetConfigurationRequest) XXX_Size() int

func (*ResetConfigurationRequest) XXX_Unmarshal Uses

func (m *ResetConfigurationRequest) XXX_Unmarshal(b []byte) error

type ResetConfigurationResponse Uses

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 Uses

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

func (*ResetConfigurationResponse) GetNames Uses

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

func (*ResetConfigurationResponse) ProtoMessage Uses

func (*ResetConfigurationResponse) ProtoMessage()

func (*ResetConfigurationResponse) Reset Uses

func (m *ResetConfigurationResponse) Reset()

func (*ResetConfigurationResponse) String Uses

func (m *ResetConfigurationResponse) String() string

func (*ResetConfigurationResponse) XXX_DiscardUnknown Uses

func (m *ResetConfigurationResponse) XXX_DiscardUnknown()

func (*ResetConfigurationResponse) XXX_Marshal Uses

func (m *ResetConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetConfigurationResponse) XXX_Merge Uses

func (dst *ResetConfigurationResponse) XXX_Merge(src proto.Message)

func (*ResetConfigurationResponse) XXX_Size Uses

func (m *ResetConfigurationResponse) XXX_Size() int

func (*ResetConfigurationResponse) XXX_Unmarshal Uses

func (m *ResetConfigurationResponse) XXX_Unmarshal(b []byte) error

type SetMaxRateRequest Uses

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 Uses

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

func (*SetMaxRateRequest) GetRate Uses

func (m *SetMaxRateRequest) GetRate() int64

func (*SetMaxRateRequest) ProtoMessage Uses

func (*SetMaxRateRequest) ProtoMessage()

func (*SetMaxRateRequest) Reset Uses

func (m *SetMaxRateRequest) Reset()

func (*SetMaxRateRequest) String Uses

func (m *SetMaxRateRequest) String() string

func (*SetMaxRateRequest) XXX_DiscardUnknown Uses

func (m *SetMaxRateRequest) XXX_DiscardUnknown()

func (*SetMaxRateRequest) XXX_Marshal Uses

func (m *SetMaxRateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetMaxRateRequest) XXX_Merge Uses

func (dst *SetMaxRateRequest) XXX_Merge(src proto.Message)

func (*SetMaxRateRequest) XXX_Size Uses

func (m *SetMaxRateRequest) XXX_Size() int

func (*SetMaxRateRequest) XXX_Unmarshal Uses

func (m *SetMaxRateRequest) XXX_Unmarshal(b []byte) error

type SetMaxRateResponse Uses

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 Uses

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

func (*SetMaxRateResponse) GetNames Uses

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

func (*SetMaxRateResponse) ProtoMessage Uses

func (*SetMaxRateResponse) ProtoMessage()

func (*SetMaxRateResponse) Reset Uses

func (m *SetMaxRateResponse) Reset()

func (*SetMaxRateResponse) String Uses

func (m *SetMaxRateResponse) String() string

func (*SetMaxRateResponse) XXX_DiscardUnknown Uses

func (m *SetMaxRateResponse) XXX_DiscardUnknown()

func (*SetMaxRateResponse) XXX_Marshal Uses

func (m *SetMaxRateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetMaxRateResponse) XXX_Merge Uses

func (dst *SetMaxRateResponse) XXX_Merge(src proto.Message)

func (*SetMaxRateResponse) XXX_Size Uses

func (m *SetMaxRateResponse) XXX_Size() int

func (*SetMaxRateResponse) XXX_Unmarshal Uses

func (m *SetMaxRateResponse) XXX_Unmarshal(b []byte) error

type UpdateConfigurationRequest Uses

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 Uses

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

func (*UpdateConfigurationRequest) GetConfiguration Uses

func (m *UpdateConfigurationRequest) GetConfiguration() *Configuration

func (*UpdateConfigurationRequest) GetCopyZeroValues Uses

func (m *UpdateConfigurationRequest) GetCopyZeroValues() bool

func (*UpdateConfigurationRequest) GetThrottlerName Uses

func (m *UpdateConfigurationRequest) GetThrottlerName() string

func (*UpdateConfigurationRequest) ProtoMessage Uses

func (*UpdateConfigurationRequest) ProtoMessage()

func (*UpdateConfigurationRequest) Reset Uses

func (m *UpdateConfigurationRequest) Reset()

func (*UpdateConfigurationRequest) String Uses

func (m *UpdateConfigurationRequest) String() string

func (*UpdateConfigurationRequest) XXX_DiscardUnknown Uses

func (m *UpdateConfigurationRequest) XXX_DiscardUnknown()

func (*UpdateConfigurationRequest) XXX_Marshal Uses

func (m *UpdateConfigurationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateConfigurationRequest) XXX_Merge Uses

func (dst *UpdateConfigurationRequest) XXX_Merge(src proto.Message)

func (*UpdateConfigurationRequest) XXX_Size Uses

func (m *UpdateConfigurationRequest) XXX_Size() int

func (*UpdateConfigurationRequest) XXX_Unmarshal Uses

func (m *UpdateConfigurationRequest) XXX_Unmarshal(b []byte) error

type UpdateConfigurationResponse Uses

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 Uses

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

func (*UpdateConfigurationResponse) GetNames Uses

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

func (*UpdateConfigurationResponse) ProtoMessage Uses

func (*UpdateConfigurationResponse) ProtoMessage()

func (*UpdateConfigurationResponse) Reset Uses

func (m *UpdateConfigurationResponse) Reset()

func (*UpdateConfigurationResponse) String Uses

func (m *UpdateConfigurationResponse) String() string

func (*UpdateConfigurationResponse) XXX_DiscardUnknown Uses

func (m *UpdateConfigurationResponse) XXX_DiscardUnknown()

func (*UpdateConfigurationResponse) XXX_Marshal Uses

func (m *UpdateConfigurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateConfigurationResponse) XXX_Merge Uses

func (dst *UpdateConfigurationResponse) XXX_Merge(src proto.Message)

func (*UpdateConfigurationResponse) XXX_Size Uses

func (m *UpdateConfigurationResponse) XXX_Size() int

func (*UpdateConfigurationResponse) XXX_Unmarshal Uses

func (m *UpdateConfigurationResponse) XXX_Unmarshal(b []byte) error

Package throttlerdata imports 3 packages (graph) and is imported by 14 packages. Updated 2019-06-13. Refresh now. Tools for package owners.