cache

package
v0.0.17 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_TConfig_RequestCodec  = ECompressionCodec_None
	Default_TConfig_ResponseCodec = ECompressionCodec_None
)

Default values for TConfig fields.

Variables

View Source 
var (
	ECompressionCodec_name = map[int32]string{
		0: "None",
		1: "Lz4",
	}
	ECompressionCodec_value = map[string]int32{
		"None": 0,
		"Lz4":  1,
	}
)

Enum value maps for ECompressionCodec.

View Source 
var File_yt_yt_proto_yt_client_cache_proto_config_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ECompressionCodec 

type ECompressionCodec int32
const (
	ECompressionCodec_None ECompressionCodec = 0
	ECompressionCodec_Lz4  ECompressionCodec = 1
)

func (ECompressionCodec) Descriptor 

func (ECompressionCodec) Descriptor() protoreflect.EnumDescriptor

func (ECompressionCodec) Enum 

func (x ECompressionCodec) Enum() *ECompressionCodec

func (ECompressionCodec) EnumDescriptor deprecated 

func (ECompressionCodec) EnumDescriptor() ([]byte, []int)

Deprecated: Use ECompressionCodec.Descriptor instead.

func (ECompressionCodec) Number 

func (x ECompressionCodec) Number() protoreflect.EnumNumber

func (ECompressionCodec) String 

func (x ECompressionCodec) String() string

func (ECompressionCodec) Type 

func (ECompressionCodec) Type() protoreflect.EnumType

func (*ECompressionCodec) UnmarshalJSON deprecated 

func (x *ECompressionCodec) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TClustersConfig 

type TClustersConfig struct {

	// DefaultConfig is used for clusters not mentioned in ClusterConfigs.
	DefaultConfig *TConfig `protobuf:"bytes,1,opt,name=DefaultConfig" json:"DefaultConfig,omitempty"`
	// Per-cluster configs.
	ClusterConfigs map[string]*TConfig `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TClustersConfig) Descriptor deprecated 

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

Deprecated: Use TClustersConfig.ProtoReflect.Descriptor instead.

func (*TClustersConfig) GetClusterConfigs 

func (x *TClustersConfig) GetClusterConfigs() map[string]*TConfig

func (*TClustersConfig) GetDefaultConfig 

func (x *TClustersConfig) GetDefaultConfig() *TConfig

func (*TClustersConfig) ProtoMessage 

func (*TClustersConfig) ProtoMessage()

func (*TClustersConfig) ProtoReflect 

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

func (*TClustersConfig) Reset 

func (x *TClustersConfig) Reset()

func (*TClustersConfig) String 

func (x *TClustersConfig) String() string

type TConfig 

type TConfig struct {
	ClusterName                         *string `protobuf:"bytes,1,opt,name=ClusterName" json:"ClusterName,omitempty"`
	ProxyRole                           *string `protobuf:"bytes,2,opt,name=ProxyRole" json:"ProxyRole,omitempty"`
	ChannelPoolSize                     *uint32 `protobuf:"varint,3,opt,name=ChannelPoolSize" json:"ChannelPoolSize,omitempty"`
	ChannelPoolRebalanceIntervalSeconds *uint32 `protobuf:"varint,4,opt,name=ChannelPoolRebalanceIntervalSeconds" json:"ChannelPoolRebalanceIntervalSeconds,omitempty"`
	// All timeouts in milliseconds.
	DefaultTransactionTimeout    *uint32            `protobuf:"varint,5,opt,name=DefaultTransactionTimeout" json:"DefaultTransactionTimeout,omitempty"`
	DefaultSelectRowsTimeout     *uint32            `protobuf:"varint,6,opt,name=DefaultSelectRowsTimeout" json:"DefaultSelectRowsTimeout,omitempty"`
	DefaultLookupRowsTimeout     *uint32            `protobuf:"varint,7,opt,name=DefaultLookupRowsTimeout" json:"DefaultLookupRowsTimeout,omitempty"`
	DefaultTotalStreamingTimeout *uint32            `protobuf:"varint,8,opt,name=DefaultTotalStreamingTimeout" json:"DefaultTotalStreamingTimeout,omitempty"`
	DefaultStreamingStallTimeout *uint32            `protobuf:"varint,9,opt,name=DefaultStreamingStallTimeout" json:"DefaultStreamingStallTimeout,omitempty"`
	DefaultPingPeriod            *uint32            `protobuf:"varint,10,opt,name=DefaultPingPeriod" json:"DefaultPingPeriod,omitempty"`
	ModifyRowsBatchCapacity      *uint32            `protobuf:"varint,11,opt,name=ModifyRowsBatchCapacity" json:"ModifyRowsBatchCapacity,omitempty"`
	RequestCodec                 *ECompressionCodec `protobuf:"varint,17,opt,name=RequestCodec,enum=NYT.NClient.NCache.ECompressionCodec,def=0" json:"RequestCodec,omitempty"`
	ResponseCodec                *ECompressionCodec `protobuf:"varint,12,opt,name=ResponseCodec,enum=NYT.NClient.NCache.ECompressionCodec,def=0" json:"ResponseCodec,omitempty"`
	// Should set EnableLegacyRpcCodecs=False, to enable RequestCodec & ResponseCodec: https://nda.ya.ru/t/iXCfYZjS6yNEwg
	EnableLegacyRpcCodecs           *bool    `protobuf:"varint,20,opt,name=EnableLegacyRpcCodecs" json:"EnableLegacyRpcCodecs,omitempty"`
	EnableRetries                   *bool    `protobuf:"varint,13,opt,name=EnableRetries" json:"EnableRetries,omitempty"`
	RetryBackoffTime                *uint32  `protobuf:"varint,14,opt,name=RetryBackoffTime" json:"RetryBackoffTime,omitempty"`
	RetryAttempts                   *uint32  `protobuf:"varint,15,opt,name=RetryAttempts" json:"RetryAttempts,omitempty"`
	RetryTimeout                    *uint32  `protobuf:"varint,16,opt,name=RetryTimeout" json:"RetryTimeout,omitempty"`
	ProxyAddresses                  []string `protobuf:"bytes,18,rep,name=ProxyAddresses" json:"ProxyAddresses,omitempty"`
	EnableProxyDiscovery            *bool    `protobuf:"varint,19,opt,name=EnableProxyDiscovery" json:"EnableProxyDiscovery,omitempty"`
	EnablePowerOfTwoChoicesStrategy *bool    `protobuf:"varint,21,opt,name=EnablePowerOfTwoChoicesStrategy" json:"EnablePowerOfTwoChoicesStrategy,omitempty"`
	EnableSelectQueryTracingTag     *bool    `protobuf:"varint,22,opt,name=EnableSelectQueryTracingTag" json:"EnableSelectQueryTracingTag,omitempty"`
	ClusterTag                      *uint32  `protobuf:"varint,23,opt,name=ClusterTag" json:"ClusterTag,omitempty"`
	ClockClusterTag                 *uint32  `protobuf:"varint,24,opt,name=ClockClusterTag" json:"ClockClusterTag,omitempty"`
	UdfRegistryPath                 *string  `protobuf:"bytes,25,opt,name=UdfRegistryPath" json:"UdfRegistryPath,omitempty"`
	// contains filtered or unexported fields
}

Connection options.

func (*TConfig) Descriptor deprecated 

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

Deprecated: Use TConfig.ProtoReflect.Descriptor instead.

func (*TConfig) GetChannelPoolRebalanceIntervalSeconds 

func (x *TConfig) GetChannelPoolRebalanceIntervalSeconds() uint32

func (*TConfig) GetChannelPoolSize 

func (x *TConfig) GetChannelPoolSize() uint32

func (*TConfig) GetClockClusterTag 

func (x *TConfig) GetClockClusterTag() uint32

func (*TConfig) GetClusterName 

func (x *TConfig) GetClusterName() string

func (*TConfig) GetClusterTag 

func (x *TConfig) GetClusterTag() uint32

func (*TConfig) GetDefaultLookupRowsTimeout 

func (x *TConfig) GetDefaultLookupRowsTimeout() uint32

func (*TConfig) GetDefaultPingPeriod 

func (x *TConfig) GetDefaultPingPeriod() uint32

func (*TConfig) GetDefaultSelectRowsTimeout 

func (x *TConfig) GetDefaultSelectRowsTimeout() uint32

func (*TConfig) GetDefaultStreamingStallTimeout 

func (x *TConfig) GetDefaultStreamingStallTimeout() uint32

func (*TConfig) GetDefaultTotalStreamingTimeout 

func (x *TConfig) GetDefaultTotalStreamingTimeout() uint32

func (*TConfig) GetDefaultTransactionTimeout 

func (x *TConfig) GetDefaultTransactionTimeout() uint32

func (*TConfig) GetEnableLegacyRpcCodecs 

func (x *TConfig) GetEnableLegacyRpcCodecs() bool

func (*TConfig) GetEnablePowerOfTwoChoicesStrategy 

func (x *TConfig) GetEnablePowerOfTwoChoicesStrategy() bool

func (*TConfig) GetEnableProxyDiscovery 

func (x *TConfig) GetEnableProxyDiscovery() bool

func (*TConfig) GetEnableRetries 

func (x *TConfig) GetEnableRetries() bool

func (*TConfig) GetEnableSelectQueryTracingTag 

func (x *TConfig) GetEnableSelectQueryTracingTag() bool

func (*TConfig) GetModifyRowsBatchCapacity 

func (x *TConfig) GetModifyRowsBatchCapacity() uint32

func (*TConfig) GetProxyAddresses 

func (x *TConfig) GetProxyAddresses() []string

func (*TConfig) GetProxyRole 

func (x *TConfig) GetProxyRole() string

func (*TConfig) GetRequestCodec 

func (x *TConfig) GetRequestCodec() ECompressionCodec

func (*TConfig) GetResponseCodec 

func (x *TConfig) GetResponseCodec() ECompressionCodec

func (*TConfig) GetRetryAttempts 

func (x *TConfig) GetRetryAttempts() uint32

func (*TConfig) GetRetryBackoffTime 

func (x *TConfig) GetRetryBackoffTime() uint32

func (*TConfig) GetRetryTimeout 

func (x *TConfig) GetRetryTimeout() uint32

func (*TConfig) GetUdfRegistryPath 

func (x *TConfig) GetUdfRegistryPath() string

func (*TConfig) ProtoMessage 

func (*TConfig) ProtoMessage()

func (*TConfig) ProtoReflect 

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

func (*TConfig) Reset 

func (x *TConfig) Reset()

func (*TConfig) String 

func (x *TConfig) String() string

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.