Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

config

package

Go to main page

Versions in this module

v1

v1.6.65

Sep 23, 2024

Changes in this version

+ const DefaultByconityLocalDiskPrefix

+ const DefaultBycontiyS3DiskPrefix

+ const MaxClickHouseEndpointsPerServer

+ func AddClickHouseEndpointsOnChange(onChange EndpointsOnChange)

type CKDiskMonitor

+ func (m *CKDiskMonitor) Validate()

type Endpoint

+ func (e Endpoint) String() string

+ type EndpointsOnChange interface

+ EndpointsChange func([]string)

v1.6.64

Sep 13, 2024

v1.6.4

Sep 13, 2024

Changes in this version

+ const DefaultByconityService

+ const DefaultByconityStoragePolicy

+ const DefaultCKDBEndpointTCPPortName

+ const DefaultCKDBService

+ const DefaultCKDBServicePort

+ const DefaultCheckInterval

+ const DefaultControllerPort

+ const DefaultDFDiskPrefix

+ const DefaultDiskFreeSpace

+ const DefaultDiskUsedPercent

+ const DefaultFlowTagCacheFlushTimeout

+ const DefaultFlowTagCacheMaxSize

+ const DefaultGrpcBufferSize

+ const DefaultListenPort

+ const DefaultLocalIP

+ const DefaultServiceLabelerLruCap

+ const DefaultStatsInterval

+ const DefaultSystemDiskPrefix

+ const EnvK8sNamespace

+ const EnvK8sNodeIP

+ const EnvK8sNodeName

+ const EnvK8sPodName

+ const EnvRunningMode

+ const FormatDecimal

+ const FormatHex

+ const IndexTypeHash

+ const IndexTypeIncremetalIdLocation

+ const RunningModeStandalone

+ const SYNC_INTERVAL_FAST

+ const TIMEOUT

+ func CheckCluster(conns common.DBs, clusterName string) error

+ func CheckStoragePolicy(conns common.DBs, storagePolicy string) error

+ type Auth struct

+ Password string

+ Username string

+ type BaseConfig struct

+ Base Config

+ LogFile string

+ LogLevel string

+ TraceIdWithIndex TraceIdWithIndex

+ type CKDB struct

+ ActualAddrs []string

+ ClusterName string

+ EndpointTCPPortName string

+ External bool

+ Host string

+ Port int

+ StoragePolicy string

+ TimeZone string

+ Type string

+ Watcher *Watcher

+ type CKDBColdStorage struct

+ ColdDisk Disk

+ Enabled bool

+ Settings []StorageSetting

+ type CKDiskMonitor struct

+ CheckInterval int

+ DiskCleanups []DiskCleanup

+ PriorityDrops []DatabaseTable

+ TTLCheckDisabled bool

+ type CKWriterConfig struct

+ BatchSize int

+ FlushTimeout int

+ QueueCount int

+ QueueSize int

+ type Config struct

+ CKDB CKDB

+ CKDBAuth Auth

+ CKDiskMonitor CKDiskMonitor

+ ColdStorage CKDBColdStorage

+ ControllerIPs []string

+ ControllerPort uint16

+ FlowTagCacheFlushTimeout uint32

+ FlowTagCacheMaxSize uint32

+ GrpcBufferSize int

+ IngesterEnabled bool

+ IsRunningModeStandalone bool

+ ListenPort uint16

+ LogFile string

+ LogLevel string

+ MyNodeName string

+ NodeIP string

+ ServiceLabelerLruCap int

+ StatsInterval int

+ StorageDisabled bool

+ TCPReadBuffer int

+ TCPReaderBuffer int

+ TraceIdWithIndex TraceIdWithIndex

+ UDPReadBuffer int

+ func Load(path string) *Config

+ func (c *Config) GetCKDBColdStorages() map[string]*ckdb.ColdStorage

+ func (c *Config) Validate() error

+ func (c *Config) ValidateAndSetckdbColdStorages() error

+ type DatabaseTable struct

+ Database string

+ TablesContain string

+ type Disk struct

+ Name string

+ Type string

+ type DiskCleanup struct

+ DiskNamePrefix string

+ FreeSpace int

+ UsedPercent int

+ UsedSpace int

+ type Endpoint struct

+ Host string

+ Port uint16

+ type HostPort struct

+ Host string

+ Port string

+ type InstanceInfo struct

+ NodeName string

+ PodName string

+ type Location struct

+ Format string

+ Length int

+ Start int

+ type ServerInstanceInfo struct

+ GrpcSession *grpc.GrpcSession

+ func NewServerInstranceInfo(ips []net.IP, port, rpcMaxMsgSize int) *ServerInstanceInfo

+ func (p *ServerInstanceInfo) Close()

+ func (p *ServerInstanceInfo) GetNodePodNames() map[string][]string

+ func (p *ServerInstanceInfo) GetServerPodNames() []string

+ func (p *ServerInstanceInfo) Reload() error

+ func (p *ServerInstanceInfo) Start()

+ type StorageSetting struct

+ Db string

+ TTLToMove int

+ Tables []string

+ type TraceIdWithIndex struct

+ Disabled bool

+ FormatIsHex bool

+ IncrementalIdLocation Location

+ Type string

+ TypeIsIncrementalId bool

+ type Watcher struct

+ EndpointWatch libs.Watcher

+ NodePodNamesWatch *ServerInstanceInfo

+ func NewWatcher(myNodeName, myPodName, myPodNamespace, clickhouseEndpointKey, ... string, ...) (*Watcher, error)

+ func (w *Watcher) GetClickhouseEndpointsWithoutMyself() ([]Endpoint, error)

+ func (w *Watcher) GetMyClickhouseEndpoints() ([]Endpoint, error)

+ func (w *Watcher) Run()