memory

package

v1.10.0 Latest Latest Go to latest Published: Aug 4, 2026 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Store is an in-memory implementation of logstore.LogStore using a circular buffer and a broadcast pattern for live tailing.

func NewStore(capacity int) *Store

NewStore creates a new in-memory log store with the given capacity.

func (s *Store) LevelCounts() (map[string]int, error)

LevelCounts returns the count of entries by level.

func (s *Store) Query(opts logstore.QueryOpts) ([]logstore.LogEntry, error)

Query returns log entries matching the given options.

func (s *Store) Services() ([]string, error)

Services returns the distinct service names.

func (s *Store) Tail(ctx context.Context, filter logstore.TailFilter) <-chan logstore.LogEntry

Tail returns a channel that streams matching log entries in real time. The channel is closed when ctx is cancelled.

func (s *Store) Write(entry logstore.LogEntry) error

Write persists a single log entry.

func (s *Store) WriteBatch(entries []logstore.LogEntry) error

WriteBatch persists multiple log entries.