config

Apr 23, 2021

Changes in this version

type Config

+ LogPaths []string

Feb 24, 2021

Changes in this version

+ func GetSinkerInfo() string

Dec 22, 2020

Changes in this version

type Config

+ func ParseLocalCfgDir(cfgPath string) (cfg *Config, err error)

Nov 20, 2020

Changes in this version

+ const DataID

+ const ServiceName

type Config

+ func ParseLocalConfig(cfgPath string) (cfg *Config, err error)

+ func (cfg *Config) AssignTasks(instances []Instance)

+ type ConsulConfManager struct

+ func (ccm *ConsulConfManager) Deregister(ip string, port int) (err error)

+ func (ccm *ConsulConfManager) GetConfig() (conf *Config, err error)

+ func (ccm *ConsulConfManager) GetInstances() (instances []Instance, err error)

+ func (ccm *ConsulConfManager) Init(properties map[string]interface{}) (err error)

+ func (ccm *ConsulConfManager) PublishConfig(conf *Config) (err error)

+ func (ccm *ConsulConfManager) Register(ip string, port int) (err error)

+ type Instance struct

+ Addr string

+ Weight int

+ type NacosConfManager struct

+ func (ncm *NacosConfManager) Deregister(ip string, port int) (err error)

+ func (ncm *NacosConfManager) GetConfig() (conf *Config, err error)

+ func (ncm *NacosConfManager) GetInstances() (instances []Instance, err error)

+ func (ncm *NacosConfManager) Init(properties map[string]interface{}) (err error)

+ func (ncm *NacosConfManager) PublishConfig(conf *Config) (err error)

+ func (ncm *NacosConfManager) Register(ip string, port int) (err error)

+ type RemoteConfManager interface

+ Deregister func(ip string, port int) error

+ GetConfig func() (conf *Config, err error)

+ GetInstances func() (instances []Instance, err error)

+ Init func(properties map[string]interface{}) error

+ PublishConfig func(conf *Config) (err error)

+ Register func(ip string, port int) error

type TaskConfig

+ Replicas int

Oct 29, 2020

Changes in this version

+ var SinkerBuildTS = "None"

+ var SinkerEdition = "None"

+ var SinkerGitBranch = "None"

+ var SinkerGitHash = "None"

+ var SinkerReleaseVersion = "None"

+ func PrintSinkerInfo()

+ func SetConfigDir(dir string)

type ClickHouseConfig

+ Host string

type Config

+ Common struct{ ... }

+ Statistics struct{ ... }

+ func GetConfig() *Config

type TaskConfig

+ Clickhouse string

+ ConcurrentParsers int

+ Kafka string

+ LayoutDate string

+ LayoutDateTime string

+ LayoutDateTime64 string

+ MinBufferSize int

+ MsgSizeHint int

+ ShardingPolicy string

Jul 26, 2022

Changes in this version

+ const MaxBufferSize

+ type Assignment struct

+ Map map[string][]string

+ UpdatedAt int64

+ UpdatedBy string

+ Version int

+ type ClickHouseConfig struct

+ Cluster string

+ DB string

+ DsnParams string

+ Hosts [][]string

+ InsecureSkipVerify bool

+ MaxOpenConns int

+ Password string

+ Port int

+ RetryTimes int

+ Secure bool

+ Username string

+ type Config struct

+ Assignment Assignment

+ Clickhouse ClickHouseConfig

+ Kafka KafkaConfig

+ LogLevel string

+ Task *TaskConfig

+ Tasks []*TaskConfig

+ func ParseLocalCfgFile(cfgPath string) (cfg *Config, err error)

+ func (cfg *Config) IsAssigned(instance, task string) (assigned bool)

+ func (cfg *Config) Normallize() (err error)

+ type KafkaConfig struct

+ Brokers string

+ Sasl struct{ ... }

+ Security map[string]string

+ TLS struct{ ... }

+ Version string

+ type TaskConfig struct

+ AutoSchema bool

+ BufferSize int

+ ConsumerGroup string

+ CsvFormat []string

+ Delimiter string

+ Dims []struct{ ... }

+ DynamicSchema struct{ ... }

+ Earliest bool

+ ExcludeColumns []string

+ FlushInterval int

+ KafkaClient string

+ LoadSeriesAtStartup bool

+ Name string

+ Parser string

+ PromLabelsBlackList string

+ PrometheusSchema bool

+ ShardingKey string

+ ShardingStripe uint64

+ TableName string

+ TimeUnit float64

+ TimeZone string

+ Topic string