config

Dec 5, 2024

Changes in this version

+ type IndexDeleter struct

+ AgentDNS string

+ AgentName string

+ AgentNamespace string

+ AgentPort int

+ Concurrency int

+ DeletionPoolSize uint32

+ Discoverer *DiscovererClient

+ IndexID string

+ NodeName string

+ TargetAddrs []string

+ func (ic *IndexDeleter) Bind() *IndexDeleter

type Net

+ Network string

Oct 11, 2024

Changes in this version

type CallOption

+ ContentSubtype string

type DialOption

+ Authority string

+ DisableRetry bool

+ IdleTimeout string

+ MaxCallAttempts int

+ MaxHeaderListSize uint32

+ SharedWriteBuffer bool

+ UserAgent string

type Faiss

+ MethodType string

type GRPC

+ EnableChannelz bool

+ MaxConcurrentStreams uint32

+ NumStreamWorkers uint32

+ SharedWriteBuffer bool

+ WaitForHandlers bool

type HTTP

+ HTTP2 *HTTP2

+ type HTTP2 struct

+ Enabled bool

+ HandlerLimit int

+ MaxConcurrentStreams uint32

+ MaxDecoderHeaderTableSize uint32

+ MaxEncoderHeaderTableSize uint32

+ MaxReadFrameSize uint32

+ MaxUploadBufferPerConnection int32

+ MaxUploadBufferPerStream int32

+ PermitProhibitedCipherSuites bool

Aug 6, 2024

Changes in this version

type BenchmarkJobImageInfo

+ Repository string

+ Tag string

type Corrector

+ Gateway *GRPCClient

+ KVSBackgroundCompactionInterval string

+ KVSBackgroundSyncInterval string

+ type IndexJobTemplates struct

+ Correction *k8s.Job

+ Creation *k8s.Job

+ Rotate *k8s.Job

+ Save *k8s.Job

+ type IndexOperator struct

+ AgentName string

+ AgentNamespace string

+ JobTemplates IndexJobTemplates

+ Namespace string

+ ReadReplicaEnabled bool

+ ReadReplicaLabelKey string

+ RotationJobConcurrency uint

+ RotatorName string

+ TargetReadReplicaIDAnnotationsKey string

+ func (ic *IndexOperator) Bind() *IndexOperator

type NGT

+ EnableStatistics bool

+ type OperatorJobConfig struct

+ Image *BenchmarkJobImageInfo

type ReadReplicaRotate

+ TargetReadReplicaID string

Feb 21, 2024

Changes in this version

type NGT

+ EnableExportIndexInfoToK8s bool

+ ExportIndexInfoDuration string

+ PodName string

+ PodNamespace string

Feb 15, 2024

Changes in this version

+ func Merge[T any](objs ...T) (dst T, err error)

+ type BenchmarkDataset struct

+ Group string

+ Indexes int

+ Name string

+ Range *BenchmarkDatasetRange

+ URL string

+ func (d *BenchmarkDataset) Bind() *BenchmarkDataset

+ type BenchmarkDatasetRange struct

+ End int

+ Start int

+ type BenchmarkJob struct

+ BeforeJobName string

+ BeforeJobNamespace string

+ ClientConfig *GRPCClient

+ ConcurrencyLimit int

+ Dataset *BenchmarkDataset

+ Dimension int

+ InsertConfig *InsertConfig

+ JobType string

+ ObjectConfig *ObjectConfig

+ RPS int

+ RemoveConfig *RemoveConfig

+ Repetition int

+ Replica int

+ Rules []*BenchmarkJobRule

+ SearchConfig *SearchConfig

+ Target *BenchmarkTarget

+ UpdateConfig *UpdateConfig

+ UpsertConfig *UpsertConfig

+ func (b *BenchmarkJob) Bind() *BenchmarkJob

+ type BenchmarkJobImageInfo struct

+ Image string

+ PullPolicy string

+ func (b *BenchmarkJobImageInfo) Bind() *BenchmarkJobImageInfo

+ type BenchmarkJobRule struct

+ Name string

+ Type string

+ func (r *BenchmarkJobRule) Bind() *BenchmarkJobRule

+ type BenchmarkScenario struct

+ Dataset *BenchmarkDataset

+ Jobs []*BenchmarkJob

+ Target *BenchmarkTarget

+ func (b *BenchmarkScenario) Bind() *BenchmarkScenario

+ type BenchmarkTarget struct

+ Host string

+ Port int

+ func (t *BenchmarkTarget) Bind() *BenchmarkTarget

+ type Faiss struct

+ AutoIndexCheckDuration string

+ AutoIndexDurationLimit string

+ AutoIndexLength int

+ AutoSaveIndexDuration string

+ Dimension int

+ EnableCopyOnWrite bool

+ EnableInMemoryMode bool

+ EnableProactiveGC bool

+ IndexPath string

+ InitialDelayMaxDuration string

+ KVSDB *KVSDB

+ LoadIndexTimeoutFactor string

+ M int

+ MaxLoadIndexTimeout string

+ MetricType string

+ MinLoadIndexTimeout string

+ NbitsPerIdx int

+ Nlist int

+ VQueue *VQueue

+ func (f *Faiss) Bind() *Faiss

+ type FilterConfig struct

+ Targets []*FilterTarget

+ func (cfg *FilterConfig) Bind() *FilterConfig

+ type FilterTarget struct

+ Host string

+ Port int32

+ func (cfg *FilterTarget) Bind() *FilterTarget

type GRPC

+ EnableAdmin bool

+ type InsertConfig struct

+ SkipStrictExistCheck bool

+ Timestamp string

+ func (cfg *InsertConfig) Bind() *InsertConfig

type LB

+ ReadReplicaClient ReadReplicaClient

+ ReadReplicaReplicas uint64

+ type Mirror struct

+ Client *GRPCClient

+ Colocation string

+ DiscoveryDuration string

+ GatewayAddr string

+ Group string

+ Namespace string

+ Net *Net

+ PodName string

+ RegisterDuration string

+ SelfMirrorAddr string

+ func (m *Mirror) Bind() *Mirror

type NGT

+ IsReadReplica bool

+ type ObjectConfig struct

+ FilterConfig FilterConfig

+ func (cfg *ObjectConfig) Bind() *ObjectConfig

+ type ReadReplicaClient struct

+ AgentClientOptions *GRPCClient

+ Client *GRPCClient

+ Duration string

+ func (d *ReadReplicaClient) Bind() *ReadReplicaClient

+ type RemoveConfig struct

+ SkipStrictExistCheck bool

+ Timestamp string

+ func (cfg *RemoveConfig) Bind() *RemoveConfig

+ type SearchConfig struct

+ AggregationAlgorithm string

+ EnableLinearSearch bool

+ Epsilon float32

+ MinNum int32

+ Num int32

+ Radius float32

+ Timeout string

+ func (cfg *SearchConfig) Bind() *SearchConfig

+ type UpdateConfig struct

+ DisableBalancedUpdate bool

+ SkipStrictExistCheck bool

+ Timestamp string

+ func (cfg *UpdateConfig) Bind() *UpdateConfig

+ type UpsertConfig struct

+ DisableBalancedUpdate bool

+ SkipStrictExistCheck bool

+ Timestamp string

+ func (cfg *UpsertConfig) Bind() *UpsertConfig

Dec 20, 2023

Changes in this version

+ type ReadReplica struct

+ Enabled bool

+ IDKey string

+ func (r *ReadReplica) Bind() *ReadReplica

+ func (r *ReadReplica) GetEnabled() bool

+ func (r *ReadReplica) GetIDKey() string

type Selectors

+ Service *Selector

+ func (s *Selectors) GetServiceFields() map[string]string

+ func (s *Selectors) GetServiceLabels() map[string]string

Dec 6, 2023

Changes in this version

+ type Corrector struct

+ AgentDNS string

+ AgentName string

+ AgentNamespace string

+ AgentPort int

+ Discoverer *DiscovererClient

+ IndexReplica int

+ KvsAsyncWriteConcurrency int

+ NodeName string

+ StreamListConcurrency int

+ func (c *Corrector) Bind() *Corrector

+ type IndexCreation struct

+ AgentDNS string

+ AgentName string

+ AgentNamespace string

+ AgentPort int

+ Concurrency int

+ CreationPoolSize uint32

+ Discoverer *DiscovererClient

+ NodeName string

+ TargetAddrs []string

+ func (ic *IndexCreation) Bind() *IndexCreation

+ type IndexSave struct

+ AgentDNS string

+ AgentName string

+ AgentNamespace string

+ AgentPort int

+ Concurrency int

+ Discoverer *DiscovererClient

+ NodeName string

+ TargetAddrs []string

+ func (is *IndexSave) Bind() *IndexSave

type NGT

+ ErrorBufferLimit uint64

+ type ReadReplicaRotate struct

+ AgentNamespace string

+ ReadReplicaID string

+ ReadReplicaLabelKey string

+ VolumeName string

+ func (r *ReadReplicaRotate) Bind() *ReadReplicaRotate

Jun 12, 2023

Changes in this version

type NGT

+ BrokenIndexHistoryLimit int

Mar 3, 2023

Changes in this version

type LB

+ MultiOperationConcurrency int

Jan 23, 2023

Changes in this version

type CompressAlgorithm

+ func AToCompressAlgorithm(ca string) CompressAlgorithm

+ func (ca CompressAlgorithm) String() string

+ type OTLP struct

+ Attribute *OTLPAttribute

+ CollectorEndpoint string

+ MetricsExportInterval string

+ MetricsExportTimeout string

+ TraceBatchTimeout string

+ TraceExportTimeout string

+ TraceMaxExportBatchSize int

+ TraceMaxQueueSize int

+ type OTLPAttribute struct

+ Namespace string

+ NodeName string

+ PodName string

+ ServiceName string

+ func (o *OTLPAttribute) Bind() *OTLPAttribute

type Observability

+ OTLP *OTLP

Oct 4, 2022

Changes in this version

+ type CircuitBreaker struct

+ ClosedErrorRate float32

+ ClosedRefreshTimeout string

+ HalfOpenErrorRate float32

+ MinSamples int64

+ OpenTimeout string

+ func (cb *CircuitBreaker) Bind() *CircuitBreaker

type DialOption

+ Interceptors []string

type GRPCClient

+ CircuitBreaker *CircuitBreaker

type Jaeger

+ AgentMaxPacketSize int

+ AgentReconnectInterval string

+ BatchTimeout string

+ ExportTimeout string

+ MaxExportBatchSize int

+ MaxQueueSize int

type Observability

+ Metrics *Metrics

type Selector

+ func (s *Selector) GetFields() map[string]string

+ func (s *Selector) GetLabels() map[string]string

type Selectors

+ func (s *Selectors) GetNodeFields() map[string]string

+ func (s *Selectors) GetNodeLabels() map[string]string

+ func (s *Selectors) GetNodeMetricsFields() map[string]string

+ func (s *Selectors) GetNodeMetricsLabels() map[string]string

+ func (s *Selectors) GetPodFields() map[string]string

+ func (s *Selectors) GetPodLabels() map[string]string

+ func (s *Selectors) GetPodMetricsFields() map[string]string

+ func (s *Selectors) GetPodMetricsLabels() map[string]string

Mar 23, 2022

Changes in this version

type NGT

+ EnableCopyOnWrite bool

Oct 22, 2021

Changes in this version

type DialOption

+ Keepalive *GRPCClientKeepalive

type Dialer

+ Keepalive string

type GRPCKeepalive

+ MinTime string

+ PermitWithoutStream bool

Oct 15, 2021

Changes in this version

type Discoverer

+ Selectors *Selectors

+ type Selector struct

+ Fields map[string]string

+ Labels map[string]string

+ func (s *Selector) Bind() *Selector

+ type Selectors struct

+ Node *Selector

+ NodeMetrics *Selector

+ Pod *Selector

+ PodMetrics *Selector

+ func (s *Selectors) Bind() *Selectors

Aug 16, 2021

Changes in this version

+ type KVSDB struct

+ Concurrency int

type NGT

+ KVSDB *KVSDB

Jun 25, 2021

Changes in this version

type Indexer

+ AutoSaveIndexDurationLimit string

+ AutoSaveIndexWaitDuration string

May 19, 2021

Changes in this version

type Blob

+ CloudStorage *CloudStorageConfig

type BlobStorageType

+ const CloudStorage

+ type CloudStorageClient struct

+ CredentialsFilePath string

+ CredentialsJSON string

+ type CloudStorageConfig struct

+ Client *CloudStorageClient

+ URL string

+ WriteBufferSize int

+ WriteCacheControl string

+ WriteContentDisposition string

+ WriteContentEncoding string

+ WriteContentLanguage string

+ WriteContentType string

+ func (c *CloudStorageConfig) Bind() *CloudStorageConfig

+ type OutputSpec struct

+ OperationName string

+ OutputIndex int

+ func (o *OutputSpec) Bind() *OutputSpec

+ type SessionOption struct

+ Base64Config string

+ Config []byte

+ Target string

+ func (s *SessionOption) Bind() *SessionOption

+ type Tensorflow struct

+ ExportPath string

+ Feeds []*OutputSpec

+ FeedsMap map[string]int

+ Fetches []*OutputSpec

+ FetchesMap map[string]int

+ ResultNestedDimension uint8

+ SessionOption *SessionOption

+ Tags []string

+ WarmupInputs []string

+ func (tf *Tensorflow) Bind() *Tensorflow

Mar 17, 2021

Changes in this version

type GRPC

+ EnableReflection bool

type NGT

+ VQueue *VQueue

+ type VQueue struct

+ DeleteBufferPoolSize int

+ DeleteBufferSize int

+ InsertBufferPoolSize int

+ InsertBufferSize int

Feb 19, 2021

Changes in this version

type Cassandra

+ Net *Net

type Client

+ Net *Net

type DialOption

+ Net *Net

type Discoverer

+ Net *Net

type MySQL

+ Net *Net

+ Network string

+ SocketPath string

+ type Net struct

+ DNS *DNS

+ Dialer *Dialer

+ SocketOption *SocketOption

+ TLS *TLS

+ func (t *Net) Bind() *Net

+ func (t *Net) Opts() []net.DialerOption

type Redis

+ Net *Net

type Server

+ Network string

+ SocketOption *SocketOption

+ SocketPath string

+ type SocketOption struct

+ IPRecoverDestinationAddr bool

+ IPTransparent bool

+ ReuseAddr bool

+ ReusePort bool

+ TCPCork bool

+ TCPDeferAccept bool

+ TCPFastOpen bool

+ TCPNoDelay bool

+ TCPQuickAck bool

+ func (s *SocketOption) Bind() *SocketOption

+ func (s *SocketOption) ToSocketFlag() control.SocketFlag

Feb 9, 2021

Changes in this version

type Dialer

+ FallbackDelay string

type Discoverer

+ TCP *TCP

type TLS

+ InsecureSkipVerify bool

Feb 2, 2021

Changes in this version

type Cassandra

+ VectorBackupTable string

type DialOption

+ BackoffBaseDelay string

+ BackoffJitter float64

+ BackoffMaxDelay string

+ BackoffMultiplier float64

+ MinimumConnectionTimeout string

type DiscovererClient

+ AgentClientOptions *GRPCClient

type EgressFilter

+ DistanceFilters []string

+ ObjectFilters []string

+ type IngressFilter struct

+ Client *GRPCClient

+ InsertFilters []string

+ SearchFilters []string

+ UpdateFilters []string

+ UpsertFilters []string

+ Vectorizer string

+ func (i *IngressFilter) Bind() *IngressFilter

+ type LB struct

+ AgentDNS string

+ AgentName string

+ AgentNamespace string

+ AgentPort int

+ Discoverer *DiscovererClient

+ IndexReplica int

+ NodeName string

+ func (g *LB) Bind() *LB

type Redis

+ Network string

+ SentinelMasterName string

+ SentinelPassword string

+ Username string

Sep 17, 2020

Changes in this version

type NGT

+ EnableProactiveGC bool

Sep 2, 2020

Changes in this version

type MySQL

+ func (m *MySQL) Opts() ([]mysql.Option, error)

type Redis

+ func (r *Redis) Opts() (opts []redis.Option, err error)

Jul 22, 2020

Changes in this version

type AgentSidecar

+ AutoBackupEnabled bool

+ WatchEnabled bool

type NGT

+ DefaultEpsilon float32

+ DefaultPoolSize uint32

+ DefaultRadius float32

+ LoadIndexTimeoutFactor string

+ MaxLoadIndexTimeout string

+ MinLoadIndexTimeout string

Jul 10, 2020

Changes in this version

type ConnectionPool

+ ResolveDNS bool

Jun 25, 2020

Changes in this version

type AgentSidecar

+ RestoreBackoffEnabled bool

type S3Config

+ MaxChunkSize string

Jun 18, 2020

Changes in this version

type Collector

+ func (c *Collector) Bind() *Collector

type Metrics

+ VersionInfoLabels []string

type Observability

+ Stackdriver *Stackdriver

+ type Stackdriver struct

+ Client *StackdriverClient

+ Exporter *StackdriverExporter

+ Profiler *StackdriverProfiler

+ ProjectID string

+ func (sd *Stackdriver) Bind() *Stackdriver

+ type StackdriverClient struct

+ APIKey string

+ Audiences []string

+ AuthenticationEnabled bool

+ CredentialsFile string

+ CredentialsJSON string

+ Endpoint string

+ QuotaProject string

+ RequestReason string

+ Scopes []string

+ TelemetryEnabled bool

+ UserAgent string

+ type StackdriverExporter struct

+ BundleCountThreshold int

+ BundleDelayThreshold string

+ Location string

+ MetricPrefix string

+ MonitoringEnabled bool

+ NumberOfWorkers int

+ ReportingInterval string

+ SkipCMD bool

+ Timeout string

+ TraceSpansBufferMaxBytes int

+ TracingEnabled bool

+ type StackdriverProfiler struct

+ APIAddr string

+ AllocForceGC bool

+ AllocProfiling bool

+ CPUProfiling bool

+ DebugLogging bool

+ Enabled bool

+ GoroutineProfiling bool

+ HeapProfiling bool

+ Instance string

+ MutexProfiling bool

+ Service string

+ ServiceVersion string

+ Zone string

Jun 12, 2020

Changes in this version

type AgentSidecar

+ Client *Client

+ RestoreBackoff *Backoff

type S3Config

+ Enable100Continue bool

+ EnableContentMD5Validation bool

+ EnableEndpointDiscovery bool

+ EnableEndpointHostPrefix bool

+ EnableParamValidation bool

+ EnableSSL bool

+ ForcePathStyle bool

+ MaxPartSize string

+ MaxRetries int

+ UseARNRegion bool

+ UseAccelerate bool

+ UseDualStack bool

Jun 3, 2020

Changes in this version

+ type AgentSidecar struct

+ AutoBackupDuration string

+ BlobStorage *Blob

+ Compress *CompressCore

+ Filename string

+ FilenameSuffix string

+ Mode string

+ PostStopTimeout string

+ WatchDir string

+ func (s *AgentSidecar) Bind() *AgentSidecar

+ type Blob struct

+ Bucket string

+ S3 *S3Config

+ StorageType string

+ func (b *Blob) Bind() *Blob

+ type BlobStorageType uint8

+ const S3

+ func AtoBST(bst string) BlobStorageType

+ func (bst BlobStorageType) String() string

+ type CompressCore struct

+ CompressAlgorithm string

+ CompressionLevel int

+ func (c *CompressCore) Bind() *CompressCore

type NGT

+ InitialDelayMaxDuration string

+ type S3Config struct

+ AccessKey string

+ Endpoint string

+ MaxPartSizeMB int

+ Region string

+ SecretAccessKey string

+ Token string

+ func (s *S3Config) Bind() *S3Config

May 18, 2020

Changes in this version

type NGT

+ AutoSaveIndexDuration string

May 15, 2020

Changes in this version

type CompressorRegisterer

+ QueueCheckDuration string

Apr 30, 2020

Changes in this version

type Cassandra

+ HostFilter *HostFilter

+ SerialConsistency string

+ type HostFilter struct

+ DataCenter string

+ Enabled bool

+ WhiteList []string

type PoolConfig

+ TokenAwareHostPolicy bool

Apr 17, 2020

Changes in this version

type Compressor

+ QueueCheckDuration string

Apr 16, 2020

Changes in this version

type ConnectionPool

+ OldConnCloseDuration string

Apr 14, 2020

Changes in this version

+ type CompressorRegisterer struct

+ Compressor *BackupManager

+ ConcurrentLimit int

+ func (cr *CompressorRegisterer) Bind() *CompressorRegisterer

Apr 2, 2020

Changes in this version

+ type ConnectionPool struct

+ EnableRebalance bool

+ RebalanceDuration string

+ Size int

type Discoverer

+ DiscoveryDuration string

type Indexer

+ CreationPoolSize uint32

type NGT

+ AutoIndexDurationLimit string

Mar 3, 2020

Changes in this version

+ type Collector struct

+ Duration string

+ Metrics *Metrics

+ type Jaeger struct

+ AgentEndpoint string

+ BufferMaxCount int

+ CollectorEndpoint string

+ Enabled bool

+ Password string

+ ServiceName string

+ Username string

+ type Metrics struct

+ EnableCGO bool

+ EnableCPU bool

+ EnableGoroutine bool

+ EnableMemory bool

+ EnableVersionInfo bool

+ type Observability struct

+ Collector *Collector

+ Enabled bool

+ Jaeger *Jaeger

+ Prometheus *Prometheus

+ Trace *Trace

+ func (o *Observability) Bind() *Observability

+ type Prometheus struct

+ Enabled bool

+ Endpoint string

+ Namespace string

+ type Trace struct

+ Enabled bool

+ SamplingRate float64

Feb 21, 2020

Changes in this version

type Gateway

+ NodeName string

type Indexer

+ AgentNamespace string

+ NodeName string

Feb 20, 2020

Changes in this version

type DialOption

+ TCP *TCP

type Discoverer

+ CacheSyncDuration string

+ Name string

+ Namespace string

+ type DiscovererClient struct

+ AgentClient *GRPCClient

+ Client *GRPCClient

+ Duration string

+ Host string

+ Port int

+ func (d *DiscovererClient) Bind() *DiscovererClient

type GRPCClient

+ ConnectionPool int

type Gateway

+ AgentNamespace string

+ type Indexer struct

+ AgentDNS string

+ AgentName string

+ AgentPort int

+ AutoIndexCheckDuration string

+ AutoIndexDurationLimit string

+ AutoIndexLength int

+ Concurrency int

+ Discoverer *DiscovererClient

+ func (im *Indexer) Bind() *Indexer

type Servers

+ func (s *Servers) GetGRPCStreamConcurrency() (c int)

Feb 11, 2020

Changes in this version

type Cassandra

+ TCP *TCP

+ type GlobalConfig struct

+ Logging *Logging

+ TZ string

+ Version string

+ func (c *GlobalConfig) Bind() *GlobalConfig

+ func (c *GlobalConfig) UnmarshalJSON(data []byte) (err error)

+ type Logging struct

+ Format string

+ Level string

+ Logger string

+ func (l *Logging) Bind() *Logging

type Meta

+ CacheExpiration string

+ EnableCache bool

+ ExpiredCacheCheckDuration string

Jan 30, 2020

Changes in this version

+ const GOB

+ const GZIP

+ const LZ4

+ const ZSTD

+ func CompressAlgorithm(ca string) compressAlgorithm

+ func GetActualValue(val string) (res string)

+ func GetActualValues(vals []string) []string

+ func Read(path string, cfg interface{}) error

+ func ToRawYaml(data interface{}) string

+ type Backoff struct

+ BackoffFactor float64

+ BackoffTimeLimit string

+ EnableErrorLog bool

+ InitialDuration string

+ JitterLimit string

+ MaximumDuration string

+ RetryCount int

+ func (b *Backoff) Bind() *Backoff

+ func (b *Backoff) Opts() []backoff.Option

+ type BackupManager struct

+ Client *GRPCClient

+ Host string

+ Port int

+ func (b *BackupManager) Bind() *BackupManager

+ type CallOption struct

+ MaxRecvMsgSize int

+ MaxRetryRPCBufferSize int

+ MaxSendMsgSize int

+ WaitForReady bool

+ func (c *CallOption) Bind() *CallOption

+ type Cassandra struct

+ CQLVersion string

+ ConnectTimeout string

+ Consistency string

+ DefaultIdempotence bool

+ DefaultTimestamp bool

+ DisableInitialHostLookup bool

+ DisableNodeStatusEvents bool

+ DisableSchemaEvents bool

+ DisableSkipMetadata bool

+ DisableTopologyEvents bool

+ EnableHostVerification bool

+ Hosts []string

+ IgnorePeerAddr bool

+ KVTable string

+ Keyspace string

+ MaxPreparedStmts int

+ MaxRoutingKeyInfo int

+ MaxWaitSchemaAgreement string

+ MetaTable string

+ NumConns int

+ PageSize int

+ Password string

+ PoolConfig *PoolConfig

+ Port int

+ ProtoVersion int

+ ReconnectInterval string

+ ReconnectionPolicy *ReconnectionPolicy

+ RetryPolicy *RetryPolicy

+ SocketKeepalive string

+ TLS *TLS

+ Timeout string

+ Username string

+ VKTable string

+ WriteCoalesceWaitTime string

+ func (c *Cassandra) Bind() *Cassandra

+ func (cfg *Cassandra) Opts() (opts []cassandra.Option, err error)

+ type Client struct

+ TCP *TCP

+ Transport *Transport

+ func (c *Client) Bind() *Client

+ type Compressor struct

+ Buffer int

+ CompressAlgorithm string

+ CompressionLevel int

+ ConcurrentLimit int

+ func (c *Compressor) Bind() *Compressor

+ type DNS struct

+ CacheEnabled bool

+ CacheExpiration string

+ RefreshDuration string

+ func (d *DNS) Bind() *DNS

+ type Debug struct

+ Log struct{ ... }

+ Profile struct{ ... }

+ func (d *Debug) Bind() *Debug

+ type Default struct

+ TZ string

+ Version string

+ func (c *Default) Bind() *Default

+ func (c *Default) UnmarshalJSON(data []byte) (err error)

+ type DialOption struct

+ Dialer *TCP

+ EnableBackoff bool

+ InitialConnectionWindowSize int

+ InitialWindowSize int

+ Insecure bool

+ KeepAlive *GRPCClientKeepalive

+ MaxBackoffDelay string

+ MaxMsgSize int

+ ReadBufferSize int

+ Timeout string

+ WriteBufferSize int

+ func (d *DialOption) Bind() *DialOption

+ type Dialer struct

+ DualStackEnabled bool

+ KeepAlive string

+ Timeout string

+ func (d *Dialer) Bind() *Dialer

+ type Discoverer struct

+ AgentClient *GRPCClient

+ DiscoverClient *GRPCClient

+ Duration string

+ Host string

+ Port int

+ func (d *Discoverer) Bind() *Discoverer

+ type EgressFilter struct

+ Client *GRPCClient

+ func (e *EgressFilter) Bind() *EgressFilter

+ type GRPC struct

+ BidirectionalStreamConcurrency int

+ ConnectionTimeout string

+ HeaderTableSize int

+ InitialConnWindowSize int

+ InitialWindowSize int

+ Interceptors []string

+ Keepalive *GRPCKeepalive

+ MaxHeaderListSize int

+ MaxReceiveMessageSize int

+ MaxSendMessageSize int

+ ReadBufferSize int

+ WriteBufferSize int

+ func (g *GRPC) Bind() *GRPC

+ type GRPCClient struct

+ Addrs []string

+ Backoff *Backoff

+ CallOption *CallOption

+ DialOption *DialOption

+ HealthCheckDuration string

+ TLS *TLS

+ func (g *GRPCClient) Bind() *GRPCClient

+ func (g *GRPCClient) Opts() []grpc.Option

+ type GRPCClientKeepalive struct

+ PermitWithoutStream bool

+ Time string

+ Timeout string

+ func (g *GRPCClientKeepalive) Bind() *GRPCClientKeepalive

+ type GRPCKeepalive struct

+ MaxConnAge string

+ MaxConnAgeGrace string

+ MaxConnIdle string

+ Time string

+ Timeout string

+ func (k *GRPCKeepalive) Bind() *GRPCKeepalive

+ type Gateway struct

+ AgentDNS string

+ AgentName string

+ AgentPort int

+ BackupManager *BackupManager

+ Discoverer *Discoverer

+ EgressFilter *EgressFilter

+ IndexReplica int

+ Meta *Meta

+ func (g *Gateway) Bind() *Gateway

+ type HTTP struct

+ HandlerTimeout string

+ IdleTimeout string

+ ReadHeaderTimeout string

+ ReadTimeout string

+ ShutdownDuration string

+ WriteTimeout string

+ func (h *HTTP) Bind() *HTTP

+ type IndexManager struct

+ func (im *IndexManager) Bind() *IndexManager

+ type Meta struct

+ Client *GRPCClient

+ Host string

+ Port int

+ func (m *Meta) Bind() *Meta

+ type MySQL struct

+ Charset string

+ ConnMaxLifeTime string

+ DB string

+ Host string

+ InitialPingDuration string

+ InitialPingTimeLimit string

+ MaxIdleConns int

+ MaxOpenConns int

+ Name string

+ Pass string

+ Port int

+ TCP *TCP

+ TLS *TLS

+ Timezone string

+ User string

+ func (m *MySQL) Bind() *MySQL

+ type NGT struct

+ AutoIndexCheckDuration string

+ AutoIndexLength int

+ AutoIndexLimit string

+ BulkInsertChunkSize int

+ CreationEdgeSize int

+ Dimension int

+ DistanceType string

+ EnableInMemoryMode bool

+ IndexPath string

+ ObjectType string

+ SearchEdgeSize int

+ func (n *NGT) Bind() *NGT

+ type PoolConfig struct

+ DCAwareRouting bool

+ DataCenter string

+ NonLocalReplicasFallback bool

+ ShuffleReplicas bool

+ type ReconnectionPolicy struct

+ InitialInterval string

+ MaxRetries int

+ type Redis struct

+ Addrs []string

+ DB int

+ DialTimeout string

+ IdleCheckFrequency string

+ IdleTimeout string

+ InitialPingDuration string

+ InitialPingTimeLimit string

+ KVPrefix string

+ KeyPref string

+ MaxConnAge string

+ MaxRedirects int

+ MaxRetries int

+ MaxRetryBackoff string

+ MinIdleConns int

+ MinRetryBackoff string

+ Password string

+ PoolSize int

+ PoolTimeout string

+ PrefixDelimiter string

+ ReadOnly bool

+ ReadTimeout string

+ RouteByLatency bool

+ RouteRandomly bool

+ TCP *TCP

+ TLS *TLS

+ VKPrefix string

+ WriteTimeout string

+ func (r *Redis) Bind() *Redis

+ type RetryPolicy struct

+ MaxDuration string

+ MinDuration string

+ NumRetries int

+ type RoundTripper struct

+ ExpectContinueTimeout string

+ ForceAttemptHTTP2 bool

+ IdleConnTimeout string

+ MaxConnsPerHost int

+ MaxIdleConns int

+ MaxIdleConnsPerHost int

+ MaxResponseHeaderSize int64

+ ReadBufferSize int64

+ ResponseHeaderTimeout string

+ TLSHandshakeTimeout string

+ WriteBufferSize int64

+ func (r *RoundTripper) Bind() *RoundTripper

+ type Server struct

+ GRPC *GRPC

+ HTTP *HTTP

+ Host string

+ Mode string

+ Name string

+ Port uint

+ ProbeWaitTime string

+ Restart bool

+ func (s *Server) Bind() *Server

+ func (s *Server) Opts() []server.Option

+ type Servers struct

+ FullShutdownDuration string

+ HealthCheckServers []*Server

+ MetricsServers []*Server

+ Servers []*Server

+ ShutdownStrategy []string

+ StartUpStrategy []string

+ TLS *TLS

+ func (s *Servers) Bind() *Servers

+ type TCP struct

+ DNS *DNS

+ Dialer *Dialer

+ TLS *TLS

+ func (t *TCP) Bind() *TCP

+ func (t *TCP) Opts() []tcp.DialerOption

+ type TLS struct

+ CA string

+ Cert string

+ Enabled bool

+ Key string

+ func (t *TLS) Bind() *TLS

+ func (t *TLS) Opts() []tls.Option

+ type Transport struct

+ Backoff *Backoff

+ RoundTripper *RoundTripper

+ func (t *Transport) Bind() *Transport