subscriber

type ClickHouseSubscriber struct {
	Address     string `mapstructure:"address" comment:"the clickhouse address"`
	Username    string `mapstructure:"username" comment:"the clickhouse username"`
	Password    string `mapstructure:"password" comment:"the clickhouse password"`
	Database    string `mapstructure:"database" comment:"the clickhouse database name to query from"`
	Table       string `mapstructure:"table" comment:"the clickhouse table name to query from"`
	CreateTable bool   `mapstructure:"create_db" comment:"if create the database, default is true"`
	// contains filtered or unexported fields
}

type Creator func(spec map[string]interface{}) (Subscriber, error)

type DorisSubscriber struct {
	Address     string `mapstructure:"address" comment:"the doris FE address (format: http://host:port)"`
	Username    string `mapstructure:"username" comment:"the doris username"`
	Password    string `mapstructure:"password" comment:"the doris password"`
	Database    string `mapstructure:"database" comment:"the doris database name to query from"`
	Table       string `mapstructure:"table" comment:"the doris table name to query from"`
	CreateTable bool   `mapstructure:"create_table" comment:"if create the table, default is true"`
	// contains filtered or unexported fields
}

type ElasticSearchSubscriber struct {
	Address  string `mapstructure:"address" comment:"the elasticsearch address"`
	Username string `mapstructure:"username" comment:"the elasticsearch username"`
	Password string `mapstructure:"password" comment:"the elasticsearch password"`
	Index    string `mapstructure:"index" comment:"the elasticsearch index name to query from"`
	// contains filtered or unexported fields
}

type GRPCService struct {
	protocol.UnimplementedLogReportServiceServer
	// contains filtered or unexported fields
}

type GrpcSubscriber struct {
	Address    string `mapstructure:"address" comment:"the gRPC server address, default value is :9000"`
	Network    string `mapstructure:"network" comment:"the gRPC server network, default value is tcp"`
	DelayStart string `mapstructure:"delay_start" comment:"the delay start time duration for fault injection, such as 5s"`
	// contains filtered or unexported fields
}

type InfluxdbSubscriber struct {
	DbHost      string `mapstructure:"db_host" comment:"the influxdb host address"`
	DbUsername  string `mapstructure:"db_username" comment:"the influxdb username"`
	DbPassword  string `mapstructure:"db_password" comment:"the influxdb password"`
	DbName      string `mapstructure:"db_name" comment:"the influxdb database name to query from"`
	Measurement string `mapstructure:"measurement" comment:"the measurement to query from"`
	CreateDb    bool   `mapstructure:"create_db" comment:"if create the database, default is true"`
	// contains filtered or unexported fields
}

type KafkaSubscriber struct {
	Brokers []string `mapstructure:"brokers" comment:"list of kafka brokers"`
	Topic   string   `mapstructure:"topic" comment:"kafka topic to consume from"`
	GroupID string   `mapstructure:"group_id" comment:"kafka consumer group id"`
	Version string   `mapstructure:"version" comment:"kafka broker version, e.g. 0.10.2.0 (optional)"`
}

type LokiSubscriber struct {
	Address      string            `mapstructure:"address" comment:"the loki address"`
	TargetLabels map[string]string `mapstructure:"target_labels" comment:"interval between queries select upserts records from loki"`
	TenantID     string            `mapstructure:"tenant_id" comment:"tenant id of loki"`
	// contains filtered or unexported fields
}

type QueryData struct {
	Result []QueryResult
}

type QueryResponse struct {
	Status string
	Data   QueryData
}

type QueryResult struct {
	Stream map[string]string
	Values [][]string
}

type SLSSubscriber struct {
	TelemetryType     string
	Aliuid            string
	Region            string
	Endpoint          string
	QueryEndpoint     string
	Project           string
	Logstore          string
	Scenario          string
	APMProject        string
	APMWorkspace      string
	APMTraceLogstore  string
	APMMetricLogstore string
	// contains filtered or unexported fields
}

type Subscriber interface {
	doc.Doc
	// Name of subscriber
	Name() string
	// Stop
	Stop() error
	// Get data
	GetData(sql string, startTime int32) ([]*protocol.LogGroup, error)
	// FlusherConfig returns the default flusher config for loongcollector container to transfer the received or self telemetry data.
	FlusherConfig() string
}