loki

type AuthConfiguration struct {
	Username string `yaml:"username"`
	Password string `yaml:"password"`
}

type Configuration struct {
	URL                               string            `yaml:"url"`    // Loki url
	Prefix                            string            `yaml:"prefix"` // Loki prefix
	Query                             string            `yaml:"query"`  // LogQL query
	Limit                             int               `yaml:"limit"`  // Limit of logs to read
	DelayFor                          time.Duration     `yaml:"delay_for"`
	Since                             time.Duration     `yaml:"since"`
	Headers                           map[string]string `yaml:"headers"`        // HTTP headers for talking to Loki
	WaitForReady                      time.Duration     `yaml:"wait_for_ready"` // Retry interval, default is 10 seconds
	Auth                              AuthConfiguration `yaml:"auth"`
	MaxFailureDuration                time.Duration     `yaml:"max_failure_duration"` // Max duration of failure before stopping the source
	NoReadyCheck                      bool              `yaml:"no_ready_check"`       // Bypass /ready check before starting
	configuration.DataSourceCommonCfg `yaml:",inline"`
}

type Data struct {
	ResultType string         `json:"resultType"`
	Result     []StreamResult `json:"result"` // Warning, just stream value is handled
	Stats      any            `json:"stats"`  // Stats is boring, just ignore it
}

type DroppedEntry struct {
	Labels    map[string]string `json:"labels"`
	Timestamp time.Time         `json:"timestamp"`
}

type Entry struct {
	Timestamp time.Time
	Line      string
}

type LokiQuery struct {
	Status string `json:"status"`
	Data   Data   `json:"data"`
}

type Source struct {
	Config Configuration

	Client *lokiclient.LokiClient
	// contains filtered or unexported fields
}

type Stream struct {
	Stream  map[string]string `json:"stream"`
	Entries []Entry           `json:"values"`
}

type StreamResult struct {
	Stream map[string]string `json:"stream"`
	Values []Entry           `json:"values"`
}

type Tail struct {
	Streams        []Stream       `json:"streams"`
	DroppedEntries []DroppedEntry `json:"dropped_entries"`
}