sqlite

package

v0.0.0-...-ebb33e4 Latest Latest Go to latest Published: May 18, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/sajithsebastian/components-contrib

Links

Open Source Insights

Documentation ¶

Index ¶

func NewSQLiteStateStore(logger logger.Logger) state.Store
type DBAccess
type SQLiteStore

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewSQLiteStateStore ¶

func NewSQLiteStateStore(logger logger.Logger) state.Store

NewSQLiteStateStore creates a new instance of the SQLite state store.

Types ¶

type DBAccess ¶

type DBAccess interface {
	Init(ctx context.Context, metadata state.Metadata) error
	Ping(ctx context.Context) error
	Set(ctx context.Context, req *state.SetRequest) error
	Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)
	Delete(ctx context.Context, req *state.DeleteRequest) error
	BulkGet(ctx context.Context, req []state.GetRequest) ([]state.BulkGetResponse, error)
	ExecuteMulti(ctx context.Context, reqs []state.TransactionalStateOperation) error
	Close() error
}

DBAccess is a private interface which enables unit testing of SQLite.

type SQLiteStore ¶

type SQLiteStore struct {
	state.BulkStore
	// contains filtered or unexported fields
}

SQLite Database state store.

func (*SQLiteStore) BulkGet ¶

func (s *SQLiteStore) BulkGet(ctx context.Context, req []state.GetRequest, _ state.BulkGetOpts) ([]state.BulkGetResponse, error)

BulkGet performs a bulks get operations. Options are ignored because this component requests all values in a single query.

func (*SQLiteStore) Close ¶

func (s *SQLiteStore) Close() error

Close implements io.Closer.

func (*SQLiteStore) Delete ¶

func (s *SQLiteStore) Delete(ctx context.Context, req *state.DeleteRequest) error

Delete removes an entity from the store.

func (*SQLiteStore) Features ¶

func (s *SQLiteStore) Features() []state.Feature

Features returns the features available in this state store.

func (*SQLiteStore) Get ¶

func (s *SQLiteStore) Get(ctx context.Context, req *state.GetRequest) (*state.GetResponse, error)

Get returns an entity from store.

func (SQLiteStore) GetComponentMetadata ¶

func (s SQLiteStore) GetComponentMetadata() map[string]string

func (*SQLiteStore) GetDBAccess ¶

func (s *SQLiteStore) GetDBAccess() *sqliteDBAccess

Returns the dbaccess property. This method is used in tests.

func (*SQLiteStore) Init ¶

func (s *SQLiteStore) Init(ctx context.Context, metadata state.Metadata) error

Init initializes the Sql server state store.

func (*SQLiteStore) Multi ¶

func (s *SQLiteStore) Multi(ctx context.Context, request *state.TransactionalStateRequest) error

Multi handles multiple transactions. Implements TransactionalStore.

func (*SQLiteStore) Ping ¶

func (s *SQLiteStore) Ping(ctx context.Context) error

func (*SQLiteStore) Set ¶

func (s *SQLiteStore) Set(ctx context.Context, req *state.SetRequest) error

Set adds/updates an entity on store.

Source Files ¶

View all Source files

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