diff --git a/mocks/router.go b/mocks/router.go index 97c171f..f1ca67c 100644 --- a/mocks/router.go +++ b/mocks/router.go @@ -80,10 +80,10 @@ func (mr *MockIRouterMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Cal } // GetEigenDAStore mocks base method. -func (m *MockIRouter) GetEigenDAStore() store.KeyGeneratedStore { +func (m *MockIRouter) GetEigenDAStore() store.GeneratedKeyStore { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetEigenDAStore") - ret0, _ := ret[0].(store.KeyGeneratedStore) + ret0, _ := ret[0].(store.GeneratedKeyStore) return ret0 } diff --git a/server/load_store.go b/server/load_store.go index f8de732..0c042b1 100644 --- a/server/load_store.go +++ b/server/load_store.go @@ -82,7 +82,7 @@ func LoadStoreRouter(ctx context.Context, cfg CLIConfig, log log.Logger) (store. } // create EigenDA backend store - var eigenDA store.KeyGeneratedStore + var eigenDA store.GeneratedKeyStore if cfg.EigenDAConfig.MemstoreEnabled { log.Info("Using mem-store backend for EigenDA") eigenDA, err = memstore.New(ctx, verifier, log, cfg.EigenDAConfig.MemstoreConfig) diff --git a/store/generated_key/eigenda/eigenda.go b/store/generated_key/eigenda/eigenda.go index 177fce5..05e8a4f 100644 --- a/store/generated_key/eigenda/eigenda.go +++ b/store/generated_key/eigenda/eigenda.go @@ -31,7 +31,7 @@ type Store struct { log log.Logger } -var _ store.KeyGeneratedStore = (*Store)(nil) +var _ store.GeneratedKeyStore = (*Store)(nil) func NewStore(client *clients.EigenDAClient, v *verify.Verifier, log log.Logger, cfg *StoreConfig) (*Store, error) { diff --git a/store/generated_key/memstore/memstore.go b/store/generated_key/memstore/memstore.go index aeb1e78..a25eac6 100644 --- a/store/generated_key/memstore/memstore.go +++ b/store/generated_key/memstore/memstore.go @@ -49,7 +49,7 @@ type MemStore struct { reads int } -var _ store.KeyGeneratedStore = (*MemStore)(nil) +var _ store.GeneratedKeyStore = (*MemStore)(nil) // New ... constructor func New( diff --git a/store/router.go b/store/router.go index ad2805c..6ee35aa 100644 --- a/store/router.go +++ b/store/router.go @@ -17,7 +17,7 @@ type IRouter interface { Get(ctx context.Context, key []byte, cm commitments.CommitmentMode) ([]byte, error) Put(ctx context.Context, cm commitments.CommitmentMode, key, value []byte) ([]byte, error) - GetEigenDAStore() KeyGeneratedStore + GetEigenDAStore() GeneratedKeyStore GetS3Store() PrecomputedKeyStore Caches() []PrecomputedKeyStore Fallbacks() []PrecomputedKeyStore @@ -26,7 +26,7 @@ type IRouter interface { // Router ... storage backend routing layer type Router struct { log log.Logger - eigenda KeyGeneratedStore + eigenda GeneratedKeyStore s3 PrecomputedKeyStore caches []PrecomputedKeyStore @@ -36,7 +36,7 @@ type Router struct { fallbackLock sync.RWMutex } -func NewRouter(eigenda KeyGeneratedStore, s3 PrecomputedKeyStore, l log.Logger, +func NewRouter(eigenda GeneratedKeyStore, s3 PrecomputedKeyStore, l log.Logger, caches []PrecomputedKeyStore, fallbacks []PrecomputedKeyStore) (IRouter, error) { return &Router{ log: l, @@ -252,7 +252,7 @@ func (r *Router) cacheEnabled() bool { } // GetEigenDAStore ... -func (r *Router) GetEigenDAStore() KeyGeneratedStore { +func (r *Router) GetEigenDAStore() GeneratedKeyStore { return r.eigenda } diff --git a/store/store.go b/store/store.go index 050fbd2..0b75789 100644 --- a/store/store.go +++ b/store/store.go @@ -73,7 +73,7 @@ type Store interface { Verify(key []byte, value []byte) error } -type KeyGeneratedStore interface { +type GeneratedKeyStore interface { Store // Get retrieves the given key if it's present in the key-value data store. Get(ctx context.Context, key []byte) ([]byte, error)