loge

type BucketOption func(*Buckets)

type Buckets struct {
	// contains filtered or unexported fields
}

type CLI struct {
	Serve  ServeCmd  `cmd:"" default:"withargs"                                             help:"run the loge ingest+query HTTP server (default)"`
	Search SearchCmd `cmd:"" help:"query a running loge server with a LogQL-style selector"`
}

type Checkpointer struct {
	// contains filtered or unexported fields
}

type Compactor struct {
	// contains filtered or unexported fields
}

type CompactorOption func(*Compactor)

type DefaultJSONSerializer struct{}

type Entry struct {
	Stream Stream `json:"stream" msg:"stream"`
	Values Values `json:"values" msg:"values"`
}

type LabelResponse struct {
	Status string   `json:"status" msg:"status"`
	Data   []string `json:"data"   msg:"data"`
}

type ObjectStore interface {
	// Put uploads the file at localPath under key and returns the public URL it
	// can be read back from over HTTP.
	Put(ctx context.Context, key, localPath string) (readURL string, err error)
	// Size returns the size of the stored object, for upload verification.
	Size(ctx context.Context, key string) (int64, error)
	// List returns the object keys stored under prefix.
	List(ctx context.Context, prefix string) ([]string, error)
	// ReadURL returns the public HTTP URL a key is read back from.
	ReadURL(key string) string
}

type Payload struct {
	Streams Streams `json:"streams" msg:"streams"`
}

type PlanResponse struct {
	Status    string                `json:"status"`
	Hot       []managers.QueryEntry `json:"hot"`
	Segments  []PlanSegment         `json:"segments"`
	ExpiresAt int64                 `json:"expires_at"`
}

type PlanSegment struct {
	ID  string `json:"id"`
	URL string `json:"url"`
}

type QueryResponse struct {
	Status string                `json:"status"`
	Data   []managers.QueryEntry `json:"data"`
}

type S3Config struct {
	Bucket         string
	Prefix         string
	Endpoint       string // custom endpoint for S3-compatible stores (MinIO); empty = AWS
	Region         string
	ForcePathStyle bool
	ReadURLBase    string // public/CDN base for reads; empty = derived
	ACL            string // optional canned ACL, e.g. "public-read"
}

type S3Store struct {
	// contains filtered or unexported fields
}

type SearchCmd struct {
	Selector string `arg:"" help:"LogQL-style selector, e.g. '{app=\"web\"} |= \"timeout\"'"`

	Addr   string        `default:"http://localhost:3000"                                              help:"base URL of the loge server"`
	Since  time.Duration `help:"relative window start, e.g. 1h (from now); ignored if --start is set"`
	Until  time.Duration `help:"relative window end, e.g. 5m ago (from now); ignored if --end is set"`
	Start  string        `help:"absolute window start: RFC3339 or unix nanoseconds; overrides --since"`
	End    string        `help:"absolute window end: RFC3339 or unix nanoseconds; overrides --until"`
	Limit  int           `default:"100"                                                                help:"max results (server caps at 5000)"`
	Output string        `` /* 138-byte string literal not displayed */

	// Client-side ("--local") search: instead of having the server scan
	// everything, fetch a plan and scan the cold (S3) segments on this machine,
	// moving the heavy historical scan off the server.
	Local          bool   `help:"scan the cold (S3) segments on this machine; the server only scans its hot tier"`
	APIKey         string `` /* 171-byte string literal not displayed */
	Concurrency    int    `` /* 175-byte string literal not displayed */
	FrameCacheSize int    `` /* 180-byte string literal not displayed */

	// Out is where results are written; nil defaults to os.Stdout. Excluded from
	// kong flag parsing so tests can capture output.
	Out io.Writer `kong:"-"`
}

type ServeCmd struct {
	Port               int           `` /* 172-byte string literal not displayed */
	Buckets            int           `` /* 172-byte string literal not displayed */
	PayloadSize        int           `` /* 172-byte string literal not displayed */
	OutputPath         string        `` /* 172-byte string literal not displayed */
	DropOnBackpressure bool          `default:"false"  help:"drop data instead of blocking when backpressure occurs"`
	FlushInterval      time.Duration `default:"1s"     help:"how often a bucket flushes a non-empty batch"`
	FlushCompression   string        `` /* 334-byte string literal not displayed */
	FlushWorkers       int           `` /* 153-byte string literal not displayed */
	FlushQueue         int           `` /* 160-byte string literal not displayed */
	CompactInterval    time.Duration `default:"30s"    help:"how often to compact small files into segments (0 disables)"`
	CompactMinFiles    int           `default:"8"      help:"minimum number of flush files before a compaction pass runs"`
	Durable            bool          `default:"true"   help:"write-ahead log each payload (fsync) before acknowledging; disable for faster, lossy-on-crash ingest"`
	CheckpointInterval time.Duration `default:"2s"     help:"how often to fsync new segments and prune the write-ahead log"`
	QueryConcurrency   int           `default:"8"      help:"max segments a query opens in parallel"`

	// Profiling (opt-in). The pprof listener binds to loopback only because
	// heap profiles can expose log contents.
	PprofPort          int `default:"0" help:"serve net/http/pprof on 127.0.0.1:<port> (0 disables)"                            name:"pprof-port"`
	PprofBlockRate     int `default:"0" help:"runtime.SetBlockProfileRate sampling rate in ns (0 disables block profiling)"     name:"pprof-block-rate"`
	PprofMutexFraction int `` /* 127-byte string literal not displayed */

	// S3 tiered storage (rotate old segments to S3, read them back over HTTP).
	// Leave --s3-bucket empty to keep everything local.
	S3Bucket         string        `` /* 197-byte string literal not displayed */
	S3Prefix         string        `default:"loge/" help:"key prefix for uploaded segments"                                                     name:"s3-prefix"`
	S3Endpoint       string        `` /* 199-byte string literal not displayed */
	S3Region         string        `` /* 197-byte string literal not displayed */
	S3ForcePathStyle bool          `` /* 134-byte string literal not displayed */
	S3ReadURLBase    string        `` /* 131-byte string literal not displayed */
	S3ACL            string        `default:""      help:"canned ACL for uploaded objects (e.g. public-read); empty relies on bucket policy"    name:"s3-acl"`
	S3RotateAge      time.Duration `` /* 128-byte string literal not displayed */
	S3RotateInterval time.Duration `` /* 133-byte string literal not displayed */
	S3RotateGrace    time.Duration `` /* 130-byte string literal not displayed */
	S3FrameCacheSize int           `` /* 134-byte string literal not displayed */
	S3PresignExpiry  time.Duration `` /* 132-byte string literal not displayed */

	// APIKey gates the read + search endpoints (/query, /labels, /stats,
	// /search/plan) and the web UI's data calls. When set, callers must present
	// it as a bearer token; when empty everything is unauthenticated (matching
	// the trusted-network posture). Ingest (/push) and the static UI assets stay
	// open regardless, so the login page can load.
	APIKey string `` /* 159-byte string literal not displayed */
}

type StatsResponse struct {
	Status         string `json:"status"`
	SegmentsTotal  int    `json:"segments_total"`
	SegmentsLocal  int    `json:"segments_local"`
	SegmentsRemote int    `json:"segments_remote"`
	RowsTotal      int64  `json:"rows_total"`
	MinTimestamp   int64  `json:"min_timestamp"`
	MaxTimestamp   int64  `json:"max_timestamp"`
}

type Stream map[string]string

type Streams []Entry

type Uploader struct {
	// contains filtered or unexported fields
}

type UploaderOption func(*Uploader)

type Value [2]string

type Values []Value

type WAL struct {
	// contains filtered or unexported fields
}