logstore

package
v0.13.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 20, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AttemptRecord added in v0.13.0

type AttemptRecord = driver.AttemptRecord

type Config

type Config struct {
	ClickHouse   *clickhouse.ClickHouseConfig
	Postgres     *string
	DeploymentID string
}

type DriverOpts

type DriverOpts struct {
	CH           clickhouse.DB
	PG           *pgxpool.Pool
	DeploymentID string
}

func MakeDriverOpts

func MakeDriverOpts(cfg Config) (DriverOpts, error)

func (*DriverOpts) Close

func (d *DriverOpts) Close() error

type ListAttemptRequest added in v0.13.0

type ListAttemptRequest = driver.ListAttemptRequest

type ListAttemptResponse added in v0.13.0

type ListAttemptResponse = driver.ListAttemptResponse

type ListEventRequest

type ListEventRequest = driver.ListEventRequest

type ListEventResponse

type ListEventResponse = driver.ListEventResponse

type LogEntry added in v0.13.0

type LogEntry = models.LogEntry

type LogStore

type LogStore interface {
	ListEvent(context.Context, ListEventRequest) (ListEventResponse, error)
	ListAttempt(context.Context, ListAttemptRequest) (ListAttemptResponse, error)
	RetrieveEvent(ctx context.Context, request RetrieveEventRequest) (*models.Event, error)
	RetrieveAttempt(ctx context.Context, request RetrieveAttemptRequest) (*AttemptRecord, error)
	InsertMany(context.Context, []*models.LogEntry) error
}

func NewLogStore

func NewLogStore(ctx context.Context, driverOpts DriverOpts) (LogStore, error)

func NewMemLogStore added in v0.13.0

func NewMemLogStore() LogStore

NewMemLogStore returns an in-memory log store for testing.

type RetrieveAttemptRequest added in v0.13.0

type RetrieveAttemptRequest = driver.RetrieveAttemptRequest

type RetrieveEventRequest added in v0.13.0

type RetrieveEventRequest = driver.RetrieveEventRequest

type TimeFilter added in v0.13.0

type TimeFilter = driver.TimeFilter

Directories

Path Synopsis
Package drivertest provides a conformance test suite for logstore drivers.
Package drivertest provides a conformance test suite for logstore drivers.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL