mleku/eventstore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rename Storage interface to Store.

Browse Source
This commit is contained in:
fiatjaf
2023-10-31 16:13:21 -03:00
parent 28fc5b0571
commit 7b4b759d29
8 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
badgern/lib.go
View File

@@ -19,7 +19,7 @@ const (
indexTagPrefix byte = 6 indexTagPrefix byte = 6
) )
var _ eventstore.Storage = (*BadgerBackend)(nil) var _ eventstore.Store = (*BadgerBackend)(nil)
type BadgerBackend struct { type BadgerBackend struct {
Path string Path string

2
elasticsearch/elasticsearch.go
View File

@@ -15,7 +15,7 @@ import (
"github.com/nbd-wtf/go-nostr" "github.com/nbd-wtf/go-nostr"
) )
var _ eventstore.Storage = (*ElasticsearchStorage)(nil) var _ eventstore.Store = (*ElasticsearchStorage)(nil)
type IndexedEvent struct { type IndexedEvent struct {
Event nostr.Event `json:"event"` Event nostr.Event `json:"event"`

4
interface.go
View File

@@ -6,8 +6,8 @@ import (
"github.com/nbd-wtf/go-nostr" "github.com/nbd-wtf/go-nostr"
) )
// Storage is a persistence layer for nostr events handled by a relay. // Store is a persistence layer for nostr events handled by a relay.
type Storage interface { type Store interface {
// Init is called at the very beginning by [Server.Start], after [Relay.Init], // Init is called at the very beginning by [Server.Start], after [Relay.Init],
// allowing a storage to initialize its internal resources. // allowing a storage to initialize its internal resources.
Init() error Init() error

2
lmdbn/lib.go
View File

@@ -15,7 +15,7 @@ const (
maxuint32 = 4294967295 maxuint32 = 4294967295
) )
var _ eventstore.Storage = (*LMDBBackend)(nil) var _ eventstore.Store = (*LMDBBackend)(nil)
type LMDBBackend struct { type LMDBBackend struct {
Path string Path string

2
mysql/init.go
View File

@@ -17,7 +17,7 @@ const (
queryTagsLimit = 10 queryTagsLimit = 10
) )
var _ eventstore.Storage = (*MySQLBackend)(nil) var _ eventstore.Store = (*MySQLBackend)(nil)
var ddls = []string{ var ddls = []string{
`CREATE TABLE IF NOT EXISTS event ( `CREATE TABLE IF NOT EXISTS event (

2
postgresql/init.go
View File

@@ -15,7 +15,7 @@ const (
queryTagsLimit = 10 queryTagsLimit = 10
) )
var _ eventstore.Storage = (*PostgresBackend)(nil) var _ eventstore.Store = (*PostgresBackend)(nil)
func (b *PostgresBackend) Init() error { func (b *PostgresBackend) Init() error {
db, err := sqlx.Connect("postgres", b.DatabaseURL) db, err := sqlx.Connect("postgres", b.DatabaseURL)

2
sqlite3/init.go
View File

@@ -7,7 +7,7 @@ import (
_ "github.com/mattn/go-sqlite3" _ "github.com/mattn/go-sqlite3"
) )
var _ eventstore.Storage = (*SQLite3Backend)(nil) var _ eventstore.Store = (*SQLite3Backend)(nil)
var ddls = []string{ var ddls = []string{
`CREATE TABLE IF NOT EXISTS event ( `CREATE TABLE IF NOT EXISTS event (

2
wrapper.go
View File

@@ -7,7 +7,7 @@ import (
) )
type Wrapper struct { type Wrapper struct {
Storage Store
} }
func (w Wrapper) InjectEvent(ctx context.Context, evt *nostr.Event) error { func (w Wrapper) InjectEvent(ctx context.Context, evt *nostr.Event) error {