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"`
	QueryIntervalMs int    `mapstructure:"query_interval_ms" comment:"interval between queries select upserts records from clickhouse"`
	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 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"`
	QueryIntervalMs int    `mapstructure:"query_interval_ms" comment:"interval between queries select upserts records from elasticsearch"`
	// 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"`
	QueryIntervalMs int    `mapstructure:"query_interval_ms" comment:"interval between queries select upserts records from influxdb"`
	CreateDb        bool   `mapstructure:"create_db" comment:"if create the database, default is true"`
	// contains filtered or unexported fields
}

type LokiSubscriber struct {
	Address         string            `mapstructure:"address" comment:"the loki address"`
	QueryIntervalMs int               `mapstructure:"query_interval_ms" comment:"interval between queries select upserts records from loki"`
	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 Subscriber interface {
	doc.Doc
	// Name of subscriber
	Name() string
	// Start the subscriber
	Start() error
	// Stop the subscriber
	Stop()
	// SubscribeChan is subscribed by the external component to get telemetry dat.
	SubscribeChan() <-chan *protocol.LogGroup
	// FlusherConfig returns the default flusher config for Ilogtail container to transfer the received or self telemetry data.
	FlusherConfig() string
}