store

package

v1.2.3 Latest Latest Go to latest Published: Aug 8, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

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

Repository

github.com/open-ships/beacon

Links

Open Source Insights

Documentation ¶

Overview ¶

Package store owns the SQLite database: schema migrations, config entity CRUD, and the connection shared with the queue implementation.

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Store ¶

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

func Open ¶

func Open(path string) (*Store, error)

func (*Store) Close ¶

func (s *Store) Close() error

func (*Store) DB ¶

func (s *Store) DB() *sql.DB

func (*Store) DeleteConnector ¶

func (s *Store) DeleteConnector(ctx context.Context, id string) error

func (*Store) DeleteSink ¶

func (s *Store) DeleteSink(ctx context.Context, id string) error

func (*Store) DeleteSource ¶

func (s *Store) DeleteSource(ctx context.Context, id string) error

func (*Store) GetConnector ¶ added in v1.2.3

func (s *Store) GetConnector(ctx context.Context, id string) (model.Connector, error)

func (*Store) GetSink ¶ added in v1.2.3

func (s *Store) GetSink(ctx context.Context, id string) (model.Sink, error)

func (*Store) GetSource ¶ added in v1.2.3

func (s *Store) GetSource(ctx context.Context, id string) (model.Source, error)

func (*Store) IsEmpty ¶

func (s *Store) IsEmpty(ctx context.Context) (bool, error)

func (*Store) KnownConnectorIDs ¶

func (s *Store) KnownConnectorIDs(ctx context.Context) ([]string, error)

KnownConnectorIDs returns every connector id that has aggregate or checkpoint state. Append maintains the aggregate transactionally, so this lookup never scans the retained-envelope table.

func (*Store) ListConnectors ¶ added in v1.2.3

func (s *Store) ListConnectors(ctx context.Context) ([]model.Connector, error)

func (*Store) ListSinks ¶ added in v1.2.3

func (s *Store) ListSinks(ctx context.Context) ([]model.Sink, error)

func (*Store) ListSources ¶ added in v1.2.3

func (s *Store) ListSources(ctx context.Context) ([]model.Source, error)

func (*Store) LoadConfig ¶

func (s *Store) LoadConfig(ctx context.Context) (model.Config, error)

func (*Store) PutConnector ¶

func (s *Store) PutConnector(ctx context.Context, v model.Connector) error

func (*Store) PutSink ¶

func (s *Store) PutSink(ctx context.Context, v model.Sink) error

func (*Store) PutSource ¶

func (s *Store) PutSource(ctx context.Context, v model.Source) error

func (*Store) ReplaceConfig ¶

func (s *Store) ReplaceConfig(ctx context.Context, cfg model.Config) error

ReplaceConfig transactionally replaces the whole configuration.

Source Files ¶

View all Source files

store.go

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