Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IndexerConfig ¶
IndexerConfig 索引器配置
type KafkaConfig ¶
type KafkaConfig struct { Brokers []string `json:"brokers"` Topic []string `json:"topic"` Version string `json:"version"` ConsumeGroup string `json:"consume_group"` FromOldest bool `json:"from_oldest"` }
KafkaConfig Kafka连接配置
type MinioConfig ¶
type MinioConfig struct { Endpoint string `json:"endpoint"` AccessKey string `json:"access_key"` SecretKey string `json:"secret_key"` UseSSL bool `json:"use_ssl"` Bucket string `json:"bucket"` Root string `json:"root"` }
MinioConfig Minio连接配置
type MySQLConfig ¶
type MySQLConfig struct { Host string `json:"host"` Port int `json:"port"` User string `json:"user"` Password string `json:"password"` DB string `json:"db"` }
MySQLConfig MySQL连接配置
type PipelineConfig ¶
type PipelineConfig struct { Kafka *KafkaConfig `json:"kafka"` Minio *MinioConfig `json:"minio"` MySQL *MySQLConfig `json:"mysql"` Indexer *IndexerConfig `json:"indexer"` }
PipelineConfig 处理管道配置
type ServiceConfig ¶
type ServiceConfig struct { HTTPEndpoint string `json:"http_endpoint"` GRPCEndpoint string `json:"grpc_endpoint"` Pipeline *PipelineConfig `json:"pipeline"` }
ServiceConfig 服务配置
Click to show internal directories.
Click to hide internal directories.