localstorage

Aug 2, 2025

Changes in this version

+ type Alertable interface

+ AlertDeleteStateNotInList func(ctx context.Context, stackName, groupName string, keeplist []string) error

+ AlertGetOrCreate func(ctx context.Context, stackName, groupName, alertName string, ...) (*typesv1.AlertState, error)

+ AlertUpdateState func(ctx context.Context, stackName, groupName, alertName string, ...) error

Jul 17, 2025

Changes in this version

+ var ServiceName = "antoine's service"

+ var TestRes = typesv1.NewResource("res_schema_url", []*typesv1.KV{ ... })

+ var TestScope = typesv1.NewScope("scope_schema_url", "test-scope", "v0.0.0-test", []*typesv1.KV{ ... })

May 22, 2025

Changes in this version

type Queryable

+ Format func(ctx context.Context, q *typesv1.Query) (string, error)

+ GetSpanByID func(ctx context.Context, spanID string) (*typesv1.Span, error)

+ GetTraceByID func(ctx context.Context, traceID string) (*typesv1.Trace, error)

+ GetTraceBySpanID func(ctx context.Context, spanID string) (*typesv1.Trace, error)

+ Parse func(ctx context.Context, q string) (*typesv1.Query, error)

+ Stream func(ctx context.Context, q *typesv1.Query, ...) error

type Storage

+ Stats func(ctx context.Context) (*typesv1.Val, error)

+ type StreamOption struct

+ BatchSize int

+ BatchTrigger <-chan time.Time

+ NotifyStreamListening func(ctx context.Context)

Apr 3, 2025

Changes in this version

type AppCtx

+ Config *config.Config

+ State *state.State

+ type OTLPLogger interface

+ ExportLogs func(ctx context.Context, req *otlplogssvcpb.ExportLogsServiceRequest) (*otlplogssvcpb.ExportLogsServiceResponse, error)

+ type OTLPMeter interface

+ ExportMetrics func(ctx context.Context, req *otlpmetricssvcpb.ExportMetricsServiceRequest) (*otlpmetricssvcpb.ExportMetricsServiceResponse, error)

+ type OTLPTracer interface

+ ExportTraces func(ctx context.Context, req *otlptracesvcpb.ExportTraceServiceRequest) (*otlptracesvcpb.ExportTraceServiceResponse, error)

Mar 1, 2025

Changes in this version

+ func RegisterStorage(name string, builder StorageBuilder)

+ func RunTest(t *testing.T, constructor func(t *testing.T) Storage)

+ type AppCtx struct

+ EnsureLoggedIn func(ctx context.Context) error

+ Features featurev1connect.FeatureServiceClient

+ type Cursor interface

+ Close func() error

+ Err func() error

+ Event func(*typesv1.LogEvent) error

+ IDs func() (machineID, sessionID int64)

+ Next func(context.Context) bool

+ type Queryable interface

+ ListSymbols func(ctx context.Context, c *typesv1.Cursor, limit int) ([]*typesv1.Symbol, *typesv1.Cursor, error)

+ Query func(ctx context.Context, q *typesv1.LogQuery, c *typesv1.Cursor, limit int) (*typesv1.Data, *typesv1.Cursor, error)

+ ResolveQueryType func(ctx context.Context, query *typesv1.LogQuery) (*typesv1.DataStreamType, error)

+ WatchLogQuery func(context.Context, *typesv1.LogQuery) (<-chan Cursor, error)

+ type Storage interface

+ Close func() error

+ Heartbeat func(ctx context.Context, machineID, sessionID int64) (time.Duration, error)

+ SinkFor func(ctx context.Context, machineID, sessionID int64) (_ sink.Sink, heartbeatIn time.Duration, _ error)

+ func Open(ctx context.Context, name string, ll *slog.Logger, cfg map[string]interface{}, ...) (Storage, error)

+ type StorageBuilder func(ctx context.Context, ll *slog.Logger, cfg map[string]interface{}, app *AppCtx) (Storage, error)

+ type Symbol struct

+ Name string

+ Type *typesv1.VarType