Documentation ¶
Index ¶
- Variables
- type RedisProxy
- func (*RedisProxy) Descriptor() ([]byte, []int)
- func (m *RedisProxy) GetCluster() string
- func (m *RedisProxy) GetLatencyInMicros() bool
- func (m *RedisProxy) GetSettings() *RedisProxy_ConnPoolSettings
- func (m *RedisProxy) GetStatPrefix() string
- func (m *RedisProxy) Marshal() (dAtA []byte, err error)
- func (m *RedisProxy) MarshalTo(dAtA []byte) (int, error)
- func (*RedisProxy) ProtoMessage()
- func (m *RedisProxy) Reset()
- func (m *RedisProxy) Size() (n int)
- func (m *RedisProxy) String() string
- func (m *RedisProxy) Unmarshal(dAtA []byte) error
- func (m *RedisProxy) Validate() error
- func (m *RedisProxy) XXX_DiscardUnknown()
- func (m *RedisProxy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RedisProxy) XXX_Merge(src proto.Message)
- func (m *RedisProxy) XXX_Size() int
- func (m *RedisProxy) XXX_Unmarshal(b []byte) error
- type RedisProxyValidationError
- type RedisProxy_ConnPoolSettings
- func (*RedisProxy_ConnPoolSettings) Descriptor() ([]byte, []int)
- func (m *RedisProxy_ConnPoolSettings) GetEnableHashtagging() bool
- func (m *RedisProxy_ConnPoolSettings) GetOpTimeout() *time.Duration
- func (m *RedisProxy_ConnPoolSettings) Marshal() (dAtA []byte, err error)
- func (m *RedisProxy_ConnPoolSettings) MarshalTo(dAtA []byte) (int, error)
- func (*RedisProxy_ConnPoolSettings) ProtoMessage()
- func (m *RedisProxy_ConnPoolSettings) Reset()
- func (m *RedisProxy_ConnPoolSettings) Size() (n int)
- func (m *RedisProxy_ConnPoolSettings) String() string
- func (m *RedisProxy_ConnPoolSettings) Unmarshal(dAtA []byte) error
- func (m *RedisProxy_ConnPoolSettings) Validate() error
- func (m *RedisProxy_ConnPoolSettings) XXX_DiscardUnknown()
- func (m *RedisProxy_ConnPoolSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RedisProxy_ConnPoolSettings) XXX_Merge(src proto.Message)
- func (m *RedisProxy_ConnPoolSettings) XXX_Size() int
- func (m *RedisProxy_ConnPoolSettings) XXX_Unmarshal(b []byte) error
- type RedisProxy_ConnPoolSettingsValidationError
- func (e RedisProxy_ConnPoolSettingsValidationError) Cause() error
- func (e RedisProxy_ConnPoolSettingsValidationError) Error() string
- func (e RedisProxy_ConnPoolSettingsValidationError) ErrorName() string
- func (e RedisProxy_ConnPoolSettingsValidationError) Field() string
- func (e RedisProxy_ConnPoolSettingsValidationError) Key() bool
- func (e RedisProxy_ConnPoolSettingsValidationError) Reason() string
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthRedisProxy = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRedisProxy = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type RedisProxy ¶
type RedisProxy struct { // The prefix to use when emitting :ref:`statistics <config_network_filters_redis_proxy_stats>`. StatPrefix string `protobuf:"bytes,1,opt,name=stat_prefix,json=statPrefix,proto3" json:"stat_prefix,omitempty"` // Name of cluster from cluster manager. See the :ref:`configuration section // <arch_overview_redis_configuration>` of the architecture overview for recommendations on // configuring the backing cluster. Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` // Network settings for the connection pool to the upstream cluster. Settings *RedisProxy_ConnPoolSettings `protobuf:"bytes,3,opt,name=settings,proto3" json:"settings,omitempty"` // Indicates that latency stat should be computed in microseconds. By default it is computed in // milliseconds. LatencyInMicros bool `protobuf:"varint,4,opt,name=latency_in_micros,json=latencyInMicros,proto3" json:"latency_in_micros,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RedisProxy) Descriptor ¶
func (*RedisProxy) Descriptor() ([]byte, []int)
func (*RedisProxy) GetCluster ¶
func (m *RedisProxy) GetCluster() string
func (*RedisProxy) GetLatencyInMicros ¶ added in v0.7.0
func (m *RedisProxy) GetLatencyInMicros() bool
func (*RedisProxy) GetSettings ¶
func (m *RedisProxy) GetSettings() *RedisProxy_ConnPoolSettings
func (*RedisProxy) GetStatPrefix ¶
func (m *RedisProxy) GetStatPrefix() string
func (*RedisProxy) Marshal ¶
func (m *RedisProxy) Marshal() (dAtA []byte, err error)
func (*RedisProxy) ProtoMessage ¶
func (*RedisProxy) ProtoMessage()
func (*RedisProxy) Reset ¶
func (m *RedisProxy) Reset()
func (*RedisProxy) Size ¶
func (m *RedisProxy) Size() (n int)
func (*RedisProxy) String ¶
func (m *RedisProxy) String() string
func (*RedisProxy) Unmarshal ¶
func (m *RedisProxy) Unmarshal(dAtA []byte) error
func (*RedisProxy) Validate ¶
func (m *RedisProxy) Validate() error
Validate checks the field values on RedisProxy with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*RedisProxy) XXX_DiscardUnknown ¶
func (m *RedisProxy) XXX_DiscardUnknown()
func (*RedisProxy) XXX_Marshal ¶
func (m *RedisProxy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RedisProxy) XXX_Merge ¶
func (m *RedisProxy) XXX_Merge(src proto.Message)
func (*RedisProxy) XXX_Size ¶
func (m *RedisProxy) XXX_Size() int
func (*RedisProxy) XXX_Unmarshal ¶
func (m *RedisProxy) XXX_Unmarshal(b []byte) error
type RedisProxyValidationError ¶
type RedisProxyValidationError struct {
// contains filtered or unexported fields
}
RedisProxyValidationError is the validation error returned by RedisProxy.Validate if the designated constraints aren't met.
func (RedisProxyValidationError) Cause ¶
func (e RedisProxyValidationError) Cause() error
Cause function returns cause value.
func (RedisProxyValidationError) Error ¶
func (e RedisProxyValidationError) Error() string
Error satisfies the builtin error interface
func (RedisProxyValidationError) ErrorName ¶ added in v0.7.0
func (e RedisProxyValidationError) ErrorName() string
ErrorName returns error name.
func (RedisProxyValidationError) Field ¶
func (e RedisProxyValidationError) Field() string
Field function returns field value.
func (RedisProxyValidationError) Key ¶
func (e RedisProxyValidationError) Key() bool
Key function returns key value.
func (RedisProxyValidationError) Reason ¶
func (e RedisProxyValidationError) Reason() string
Reason function returns reason value.
type RedisProxy_ConnPoolSettings ¶
type RedisProxy_ConnPoolSettings struct { // Per-operation timeout in milliseconds. The timer starts when the first // command of a pipeline is written to the backend connection. Each response received from Redis // resets the timer since it signifies that the next command is being processed by the backend. // The only exception to this behavior is when a connection to a backend is not yet established. // In that case, the connect timeout on the cluster will govern the timeout until the connection // is ready. OpTimeout *time.Duration `protobuf:"bytes,1,opt,name=op_timeout,json=opTimeout,proto3,stdduration" json:"op_timeout,omitempty"` // Use hash tagging on every redis key to guarantee that keys with the same hash tag will be // forwarded to the same upstream. The hash key used for determining the upstream in a // consistent hash ring configuration will be computed from the hash tagged key instead of the // whole key. The algorithm used to compute the hash tag is identical to the `redis-cluster // implementation <https://redis.io/topics/cluster-spec#keys-hash-tags>`_. // // Examples: // // * '{user1000}.following' and '{user1000}.followers' **will** be sent to the same upstream // * '{user1000}.following' and '{user1001}.following' **might** be sent to the same upstream EnableHashtagging bool `protobuf:"varint,2,opt,name=enable_hashtagging,json=enableHashtagging,proto3" json:"enable_hashtagging,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Redis connection pool settings.
func (*RedisProxy_ConnPoolSettings) Descriptor ¶
func (*RedisProxy_ConnPoolSettings) Descriptor() ([]byte, []int)
func (*RedisProxy_ConnPoolSettings) GetEnableHashtagging ¶ added in v0.6.8
func (m *RedisProxy_ConnPoolSettings) GetEnableHashtagging() bool
func (*RedisProxy_ConnPoolSettings) GetOpTimeout ¶
func (m *RedisProxy_ConnPoolSettings) GetOpTimeout() *time.Duration
func (*RedisProxy_ConnPoolSettings) Marshal ¶
func (m *RedisProxy_ConnPoolSettings) Marshal() (dAtA []byte, err error)
func (*RedisProxy_ConnPoolSettings) MarshalTo ¶
func (m *RedisProxy_ConnPoolSettings) MarshalTo(dAtA []byte) (int, error)
func (*RedisProxy_ConnPoolSettings) ProtoMessage ¶
func (*RedisProxy_ConnPoolSettings) ProtoMessage()
func (*RedisProxy_ConnPoolSettings) Reset ¶
func (m *RedisProxy_ConnPoolSettings) Reset()
func (*RedisProxy_ConnPoolSettings) Size ¶
func (m *RedisProxy_ConnPoolSettings) Size() (n int)
func (*RedisProxy_ConnPoolSettings) String ¶
func (m *RedisProxy_ConnPoolSettings) String() string
func (*RedisProxy_ConnPoolSettings) Unmarshal ¶
func (m *RedisProxy_ConnPoolSettings) Unmarshal(dAtA []byte) error
func (*RedisProxy_ConnPoolSettings) Validate ¶
func (m *RedisProxy_ConnPoolSettings) Validate() error
Validate checks the field values on RedisProxy_ConnPoolSettings with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*RedisProxy_ConnPoolSettings) XXX_DiscardUnknown ¶
func (m *RedisProxy_ConnPoolSettings) XXX_DiscardUnknown()
func (*RedisProxy_ConnPoolSettings) XXX_Marshal ¶
func (m *RedisProxy_ConnPoolSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RedisProxy_ConnPoolSettings) XXX_Merge ¶
func (m *RedisProxy_ConnPoolSettings) XXX_Merge(src proto.Message)
func (*RedisProxy_ConnPoolSettings) XXX_Size ¶
func (m *RedisProxy_ConnPoolSettings) XXX_Size() int
func (*RedisProxy_ConnPoolSettings) XXX_Unmarshal ¶
func (m *RedisProxy_ConnPoolSettings) XXX_Unmarshal(b []byte) error
type RedisProxy_ConnPoolSettingsValidationError ¶
type RedisProxy_ConnPoolSettingsValidationError struct {
// contains filtered or unexported fields
}
RedisProxy_ConnPoolSettingsValidationError is the validation error returned by RedisProxy_ConnPoolSettings.Validate if the designated constraints aren't met.
func (RedisProxy_ConnPoolSettingsValidationError) Cause ¶
func (e RedisProxy_ConnPoolSettingsValidationError) Cause() error
Cause function returns cause value.
func (RedisProxy_ConnPoolSettingsValidationError) Error ¶
func (e RedisProxy_ConnPoolSettingsValidationError) Error() string
Error satisfies the builtin error interface
func (RedisProxy_ConnPoolSettingsValidationError) ErrorName ¶ added in v0.7.0
func (e RedisProxy_ConnPoolSettingsValidationError) ErrorName() string
ErrorName returns error name.
func (RedisProxy_ConnPoolSettingsValidationError) Field ¶
func (e RedisProxy_ConnPoolSettingsValidationError) Field() string
Field function returns field value.
func (RedisProxy_ConnPoolSettingsValidationError) Key ¶
func (e RedisProxy_ConnPoolSettingsValidationError) Key() bool
Key function returns key value.
func (RedisProxy_ConnPoolSettingsValidationError) Reason ¶
func (e RedisProxy_ConnPoolSettingsValidationError) Reason() string
Reason function returns reason value.