eventstore

package

v0.1.0 Latest Latest Go to latest Published: Jun 3, 2022 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewSQLEventStore(ctx context.Context, db *sql.DB) (SQLEventStore, error)

func (s SQLEventStore) FetchAll(ctx context.Context) ([]app.Event, error)

func (s SQLEventStore) LatestByName(ctx context.Context, taskName string) (event app.Event, err error)

func (s SQLEventStore) Store(ctx context.Context, e app.Event) error