v2

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2019 License: Apache-2.0 Imports: 16 Imported by: 14

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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) MarshalTo 

func (m *RedisProxy) MarshalTo(dAtA []byte) (int, 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.

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.