memory

package
v0.0.30 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewHappeningBaseService added in v0.0.15 

func NewHappeningBaseService(data DataStore) storage.HappeningService

NewHappeningBaseService creates a HappeningService using the given DataStore

func NewHappeningService added in v0.0.15 

func NewHappeningService() storage.HappeningService

func NewLogEntryBaseService added in v0.0.12 

func NewLogEntryBaseService(data DataStore) storage.LogEntryService

NewLogEntryBaseService creates a LogEntryService using the given DataStore

func NewLogEntryService 

func NewLogEntryService() storage.LogEntryService

Factory functions using the new base store

func NewLogNoteBaseService added in v0.0.12 

func NewLogNoteBaseService(data DataStore) storage.LogNoteService

NewLogNoteBaseService creates a LogNoteService using the given DataStore

func NewLogNoteService 

func NewLogNoteService() storage.LogNoteService

func NewStateRecordingBaseService added in v0.0.16 

func NewStateRecordingBaseService(data DataStore) storage.StateRecordingService

NewStateRecordingBaseService creates a StateRecordingService using the given DataStore

func NewStateRecordingService added in v0.0.16 

func NewStateRecordingService() storage.StateRecordingService

Types

type BaseStore added in v0.0.12 

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

BaseStore provides common implementation for LogEntry and LogNote services

func NewBaseStore added in v0.0.12 

func NewBaseStore(data DataStore) *BaseStore

NewBaseStore creates a new BaseStore with the given DataStore

type DataStore added in v0.0.12 

type DataStore interface {
	// Entry operations
	GetAllEntries() []models.LogEntry
	GetEntry(id int64) (models.LogEntry, bool)
	AddEntry(entry models.LogEntry) error
	UpdateEntry(id int64, entry models.LogEntry) error
	DeleteEntry(id int64) error

	// Note operations
	GetAllNotes() []models.Note
	GetNote(id int64) (models.Note, bool)
	AddNote(note models.Note) error
	UpdateNote(id int64, note models.Note) error
	DeleteNote(id int64) error

	// Happening operations
	GetAllHappenings() []models.Happening
	GetHappening(id int64) (models.Happening, bool)
	AddHappening(happening models.Happening) error
	UpdateHappening(id int64, happening models.Happening) error
	DeleteHappening(id int64) error

	// State operations
	GetAllStates() []models.State
	GetState(id int64) (models.State, bool)
	GetStateByName(name string) (models.State, bool)
	AddState(state models.State) error
	UpdateState(id int64, state models.State) error
	DeleteState(id int64) error

	// StateEvent operations
	GetAllStateEvents() []models.StateEvent
	GetStateEvent(id int64) (models.StateEvent, bool)
	AddStateEvent(event models.StateEvent) error

	// ID generation
	NextID() int64

	// Persistence (for file-based stores)
	Save() error
}

DataStore defines the interface for the underlying data storage

type HappeningBaseStore added in v0.0.15 

type HappeningBaseStore struct {
	*BaseStore
}

HappeningBaseStore implements storage.HappeningService using BaseStore

func (*HappeningBaseStore) Add added in v0.0.15 

func (hbs *HappeningBaseStore) Add(ctx context.Context, happening *models.Happening) (*models.Happening, error)

func (*HappeningBaseStore) Delete added in v0.0.15 

func (hbs *HappeningBaseStore) Delete(ctx context.Context, id int64) error

func (*HappeningBaseStore) List added in v0.0.15 

func (hbs *HappeningBaseStore) List(options storage.HappeningListOptions) ([]*models.Happening, int64, error)

Happening service methods

func (*HappeningBaseStore) Update added in v0.0.15 

func (hbs *HappeningBaseStore) Update(ctx context.Context, id int64, update *models.HappeningOptional) (*models.Happening, error)

type LogEntryBaseStore added in v0.0.12 

type LogEntryBaseStore struct {
	*BaseStore
}

LogEntryBaseStore implements storage.LogEntryService using BaseStore

func (*LogEntryBaseStore) Add added in v0.0.12 

func (les *LogEntryBaseStore) Add(entry models.LogEntry) (int64, error)

func (*LogEntryBaseStore) Delete added in v0.0.12 

func (les *LogEntryBaseStore) Delete(id int64) error

func (*LogEntryBaseStore) GetTree added in v0.0.12 

func (les *LogEntryBaseStore) GetTree(ctx context.Context, id int64, includeHistory bool) ([]models.LogEntry, error)

func (*LogEntryBaseStore) List added in v0.0.12 

func (les *LogEntryBaseStore) List(options storage.LogEntryListOptions) ([]models.LogEntry, int64, error)

LogEntry service methods

func (*LogEntryBaseStore) Move added in v0.0.12 

func (les *LogEntryBaseStore) Move(id int64, newParentID int64) error

func (*LogEntryBaseStore) Update added in v0.0.12 

func (les *LogEntryBaseStore) Update(id int64, update models.LogEntryOptional) error

type LogNoteBaseStore added in v0.0.12 

type LogNoteBaseStore struct {
	*BaseStore
}

LogNoteBaseStore implements storage.LogNoteService using BaseStore

func (*LogNoteBaseStore) Add added in v0.0.12 

func (lns *LogNoteBaseStore) Add(entryID int64, note models.Note) (int64, error)

func (*LogNoteBaseStore) Delete added in v0.0.12 

func (lns *LogNoteBaseStore) Delete(entryID int64, noteID int64) error

func (*LogNoteBaseStore) List added in v0.0.12 

func (lns *LogNoteBaseStore) List(entryID int64, options storage.LogNoteListOptions) ([]models.Note, int64, error)

LogNote service methods

func (*LogNoteBaseStore) ListForEntries added in v0.0.12 

func (lns *LogNoteBaseStore) ListForEntries(entryIDs []int64) (map[int64][]models.Note, error)

func (*LogNoteBaseStore) Update added in v0.0.12 

func (lns *LogNoteBaseStore) Update(entryID int64, noteID int64, update models.NoteOptional) error

type MemoryDataStore added in v0.0.12 

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

MemoryDataStore implements DataStore interface for in-memory storage

func NewMemoryDataStore added in v0.0.12 

func NewMemoryDataStore() *MemoryDataStore

NewMemoryDataStore creates a new in-memory data store

func (*MemoryDataStore) AddEntry added in v0.0.12 

func (mds *MemoryDataStore) AddEntry(entry models.LogEntry) error

func (*MemoryDataStore) AddHappening added in v0.0.15 

func (mds *MemoryDataStore) AddHappening(happening models.Happening) error

func (*MemoryDataStore) AddNote added in v0.0.12 

func (mds *MemoryDataStore) AddNote(note models.Note) error

func (*MemoryDataStore) AddState added in v0.0.16 

func (mds *MemoryDataStore) AddState(state models.State) error

func (*MemoryDataStore) AddStateEvent added in v0.0.16 

func (mds *MemoryDataStore) AddStateEvent(event models.StateEvent) error

func (*MemoryDataStore) DeleteEntry added in v0.0.12 

func (mds *MemoryDataStore) DeleteEntry(id int64) error

func (*MemoryDataStore) DeleteHappening added in v0.0.15 

func (mds *MemoryDataStore) DeleteHappening(id int64) error

func (*MemoryDataStore) DeleteNote added in v0.0.12 

func (mds *MemoryDataStore) DeleteNote(id int64) error

func (*MemoryDataStore) DeleteState added in v0.0.16 

func (mds *MemoryDataStore) DeleteState(id int64) error

func (*MemoryDataStore) GetAllEntries added in v0.0.12 

func (mds *MemoryDataStore) GetAllEntries() []models.LogEntry

Entry operations

func (*MemoryDataStore) GetAllHappenings added in v0.0.15 

func (mds *MemoryDataStore) GetAllHappenings() []models.Happening

Happening operations

func (*MemoryDataStore) GetAllNotes added in v0.0.12 

func (mds *MemoryDataStore) GetAllNotes() []models.Note

Note operations

func (*MemoryDataStore) GetAllStateEvents added in v0.0.16 

func (mds *MemoryDataStore) GetAllStateEvents() []models.StateEvent

StateEvent operations

func (*MemoryDataStore) GetAllStates added in v0.0.16 

func (mds *MemoryDataStore) GetAllStates() []models.State

State operations

func (*MemoryDataStore) GetEntry added in v0.0.12 

func (mds *MemoryDataStore) GetEntry(id int64) (models.LogEntry, bool)

func (*MemoryDataStore) GetHappening added in v0.0.15 

func (mds *MemoryDataStore) GetHappening(id int64) (models.Happening, bool)

func (*MemoryDataStore) GetNote added in v0.0.12 

func (mds *MemoryDataStore) GetNote(id int64) (models.Note, bool)

func (*MemoryDataStore) GetState added in v0.0.16 

func (mds *MemoryDataStore) GetState(id int64) (models.State, bool)

func (*MemoryDataStore) GetStateByName added in v0.0.16 

func (mds *MemoryDataStore) GetStateByName(name string) (models.State, bool)

func (*MemoryDataStore) GetStateEvent added in v0.0.16 

func (mds *MemoryDataStore) GetStateEvent(id int64) (models.StateEvent, bool)

func (*MemoryDataStore) NextID added in v0.0.12 

func (mds *MemoryDataStore) NextID() int64

ID generation

func (*MemoryDataStore) Save added in v0.0.12 

func (mds *MemoryDataStore) Save() error

Persistence (no-op for memory store)

func (*MemoryDataStore) UpdateEntry added in v0.0.12 

func (mds *MemoryDataStore) UpdateEntry(id int64, entry models.LogEntry) error

func (*MemoryDataStore) UpdateHappening added in v0.0.15 

func (mds *MemoryDataStore) UpdateHappening(id int64, happening models.Happening) error

func (*MemoryDataStore) UpdateNote added in v0.0.12 

func (mds *MemoryDataStore) UpdateNote(id int64, note models.Note) error

func (*MemoryDataStore) UpdateState added in v0.0.16 

func (mds *MemoryDataStore) UpdateState(id int64, state models.State) error

type MemoryStateRecordingService added in v0.0.16 

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

MemoryStateRecordingService implements StateRecordingService for in-memory storage

func (*MemoryStateRecordingService) CreateState added in v0.0.16 

func (s *MemoryStateRecordingService) CreateState(ctx context.Context, state *models.State) (*models.State, error)

func (*MemoryStateRecordingService) GetState added in v0.0.16 

func (s *MemoryStateRecordingService) GetState(ctx context.Context, name string) (*models.State, error)

func (*MemoryStateRecordingService) GetStateEvents added in v0.0.16 

func (s *MemoryStateRecordingService) GetStateEvents(ctx context.Context, stateID int64, limit int) ([]*models.StateEvent, error)

func (*MemoryStateRecordingService) GetStateHistory added in v0.0.23 

func (s *MemoryStateRecordingService) GetStateHistory(ctx context.Context, options storage.GetStateHistoryOptions) ([]models.StateHistoryPoint, error)

func (*MemoryStateRecordingService) ListStates added in v0.0.16 

func (s *MemoryStateRecordingService) ListStates(ctx context.Context, scope string) ([]*models.State, error)

func (*MemoryStateRecordingService) RecordStateEvent added in v0.0.16 

func (s *MemoryStateRecordingService) RecordStateEvent(ctx context.Context, name string, deltaScore float64) error

type StateRecordingBaseStore added in v0.0.16 

type StateRecordingBaseStore struct {
	*BaseStore
}

StateRecordingBaseStore implements storage.StateRecordingService using BaseStore

func (*StateRecordingBaseStore) CreateState added in v0.0.16 

func (srs *StateRecordingBaseStore) CreateState(ctx context.Context, state *models.State) (*models.State, error)

func (*StateRecordingBaseStore) GetState added in v0.0.16 

func (srs *StateRecordingBaseStore) GetState(ctx context.Context, name string) (*models.State, error)

StateRecordingService methods

func (*StateRecordingBaseStore) GetStateEvents added in v0.0.16 

func (srs *StateRecordingBaseStore) GetStateEvents(ctx context.Context, stateID int64, limit int) ([]*models.StateEvent, error)

func (*StateRecordingBaseStore) GetStateHistory added in v0.0.23 

func (srs *StateRecordingBaseStore) GetStateHistory(ctx context.Context, options storage.GetStateHistoryOptions) ([]models.StateHistoryPoint, error)

func (*StateRecordingBaseStore) ListStates added in v0.0.16 

func (srs *StateRecordingBaseStore) ListStates(ctx context.Context, scope string) ([]*models.State, error)

func (*StateRecordingBaseStore) RecordStateEvent added in v0.0.16 

func (srs *StateRecordingBaseStore) RecordStateEvent(ctx context.Context, name string, deltaScore float64) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.