error_log_logger

type ClickHouseConfig struct {
	EndpointAddr string `json:"endpoint_addr,omitempty"`
	User         string `json:"user,omitempty"`
	Password     string `json:"password,omitempty"`
	Database     string `json:"database,omitempty"`
	LogTable     string `json:"logtable,omitempty"`
}

type Config struct {
	TCP        *TCPConfig        `json:"tcp,omitempty"`
	Skywalking *SkywalkingConfig `json:"skywalking,omitempty"`
	Clickhouse *ClickHouseConfig `json:"clickhouse,omitempty"`
	Kafka      *KafkaConfig      `json:"kafka,omitempty"`

	Host          string `json:"host,omitempty"`
	Port          int    `json:"port,omitempty"`
	TLS           bool   `json:"tls,omitempty"`
	TLSServerName string `json:"tls_server_name,omitempty"`

	Name              string `json:"name,omitempty"`
	Level             string `json:"level,omitempty"`
	Timeout           int    `json:"timeout,omitempty"`
	Keepalive         int    `json:"keepalive,omitempty"`
	BatchMaxSize      int    `json:"batch_max_size,omitempty"`
	MaxRetryCount     int    `json:"max_retry_count,omitempty"`
	RetryDelay        int    `json:"retry_delay,omitempty"`
	BufferDuration    int    `json:"buffer_duration,omitempty"`
	InactiveTimeout   int    `json:"inactive_timeout,omitempty"`
	MaxPendingEntries int    `json:"max_pending_entries,omitempty"`
}

type KafkaBroker struct {
	Host       string      `json:"host"`
	Port       int         `json:"port"`
	SASLConfig *SASLConfig `json:"sasl_config,omitempty"`
}

type KafkaConfig struct {
	Brokers             []KafkaBroker `json:"brokers,omitempty"`
	KafkaTopic          string        `json:"kafka_topic"`
	ProducerType        string        `json:"producer_type,omitempty"`
	RequiredAcks        int           `json:"required_acks,omitempty"`
	Key                 string        `json:"key,omitempty"`
	ClusterName         int           `json:"cluster_name,omitempty"`
	MetaRefreshInterval int           `json:"meta_refresh_interval,omitempty"`
}

type Plugin struct {
	base.BasePlugin

	BatchProcessor *logger_batch.Processor
	// contains filtered or unexported fields
}

type SASLConfig struct {
	Mechanism string `json:"mechanism,omitempty"`
	User      string `json:"user"`
	Password  string `json:"password"`
}

type SkywalkingConfig struct {
	EndpointAddr        string `json:"endpoint_addr,omitempty"`
	ServiceName         string `json:"service_name,omitempty"`
	ServiceInstanceName string `json:"service_instance_name,omitempty"`
}

type TCPConfig struct {
	Host          string `json:"host"`
	Port          int    `json:"port"`
	TLS           bool   `json:"tls,omitempty"`
	TLSServerName string `json:"tls_server_name,omitempty"`
}