sqlite

package

v0.5.4 Latest Latest Go to latest Published: Jul 23, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/benngarcia/mercator

Links

Open Source Insights

Documentation ¶

Index ¶

type ConnectionRepository
- func (r *ConnectionRepository) CreateCredential(ctx context.Context, request eventlog.AppendRequest, ...) (eventlog.AppendResult, error)
- func (r *ConnectionRepository) DeleteCredential(ctx context.Context, request eventlog.AppendRequest, ...) (eventlog.AppendResult, error)
type RentalScheduleStore
- func (store *RentalScheduleStore) Commit(ctx context.Context, event eventlog.AppendRequest, expectedVersion uint64, ...) (eventlog.AppendResult, error)
- func (store *RentalScheduleStore) List(ctx context.Context, workspaceID string) (map[string]domain.RentalSchedule, error)
type Storage
- func New(ctx context.Context, db *sql.DB) (*Storage, error)
- func Open(ctx context.Context, dsn string) (*Storage, error)
type WorkspaceEventLog
- func (l *WorkspaceEventLog) AppendIfWorkspaceActive(ctx context.Context, request eventlog.AppendRequest) (eventlog.AppendResult, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ConnectionRepository ¶

type ConnectionRepository struct {
	*WorkspaceEventLog
	// contains filtered or unexported fields
}

func (*ConnectionRepository) CreateCredential ¶

func (r *ConnectionRepository) CreateCredential(ctx context.Context, request eventlog.AppendRequest, write connection.CredentialWrite) (eventlog.AppendResult, error)

func (*ConnectionRepository) DeleteCredential ¶

func (r *ConnectionRepository) DeleteCredential(ctx context.Context, request eventlog.AppendRequest, ref connection.CredentialRef) (eventlog.AppendResult, error)

type RentalScheduleStore ¶ added in v0.5.0

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

func (*RentalScheduleStore) Commit ¶ added in v0.5.0

func (store *RentalScheduleStore) Commit(ctx context.Context, event eventlog.AppendRequest, expectedVersion uint64, next domain.RentalSchedule) (eventlog.AppendResult, error)

func (*RentalScheduleStore) List ¶ added in v0.5.0

func (store *RentalScheduleStore) List(ctx context.Context, workspaceID string) (map[string]domain.RentalSchedule, error)

type Storage ¶

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

func New ¶

func New(ctx context.Context, db *sql.DB) (*Storage, error)

New takes ownership of db.

func Open ¶

func Open(ctx context.Context, dsn string) (*Storage, error)

func (*Storage) Close ¶

func (s *Storage) Close() error

func (*Storage) Connections ¶

func (s *Storage) Connections(sealer credentialSealer) (*ConnectionRepository, error)

func (*Storage) CredentialStore ¶

func (s *Storage) CredentialStore() *credential.SQLiteStore

func (*Storage) EventLog ¶

func (s *Storage) EventLog() *WorkspaceEventLog

func (*Storage) RentalSchedules ¶ added in v0.5.0

func (s *Storage) RentalSchedules() *RentalScheduleStore

func (*Storage) Workspaces ¶ added in v0.4.5

func (s *Storage) Workspaces() *workspace.SQLiteCatalog

type WorkspaceEventLog ¶ added in v0.4.5

type WorkspaceEventLog struct {
	*eventlog.SQLiteEventLog
}

func (*WorkspaceEventLog) AppendIfWorkspaceActive ¶ added in v0.4.5

func (l *WorkspaceEventLog) AppendIfWorkspaceActive(ctx context.Context, request eventlog.AppendRequest) (eventlog.AppendResult, error)

Source Files ¶

View all Source files

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