diff --git a/downloader/downloader.go b/downloader/downloader.go new file mode 100644 index 00000000..aaf4c941 --- /dev/null +++ b/downloader/downloader.go @@ -0,0 +1,5 @@ +package downloader + +type Downloader interface { + Download() string +} diff --git a/downloader/trustedstate/trustedstate.go b/downloader/trustedstate/trustedstate.go new file mode 100644 index 00000000..4e8f86d1 --- /dev/null +++ b/downloader/trustedstate/trustedstate.go @@ -0,0 +1,5 @@ +package trustedstate + +type TrustedState struct { + Source string +} diff --git a/driver/driver.go b/driver/driver.go new file mode 100644 index 00000000..7f0ac62d --- /dev/null +++ b/driver/driver.go @@ -0,0 +1,7 @@ +// Interface for drivers + +package driver + +type Driver interface { + Drive() string +} diff --git a/driver/l1infotree/l1infotree.go b/driver/l1infotree/l1infotree.go new file mode 100644 index 00000000..30c9a96d --- /dev/null +++ b/driver/l1infotree/l1infotree.go @@ -0,0 +1,10 @@ +// Specific implementation of the dirver interface for L1InfoTree + +package l1infotree + +type L1InfoTree struct { +} + +func (l1it *L1InfoTree) Process() string { + return "L1InfoTree" +} diff --git a/processor/erigon/erigon.go b/processor/erigon/erigon.go new file mode 100644 index 00000000..873b2292 --- /dev/null +++ b/processor/erigon/erigon.go @@ -0,0 +1,10 @@ +// Specific implementation of the processor interface for Erigon + +package erigon + +type Erigon struct { +} + +func (e *Erigon) Process() string { + return "Erigon" +} diff --git a/processor/l1infotree/l1infotree.go b/processor/l1infotree/l1infotree.go new file mode 100644 index 00000000..fda32db8 --- /dev/null +++ b/processor/l1infotree/l1infotree.go @@ -0,0 +1,8 @@ +package l1infotree + +type L1InfoTree struct { +} + +func (l1it *L1InfoTree) Process() string { + return "L1InfoTree" +} diff --git a/processor/processor.go b/processor/processor.go new file mode 100644 index 00000000..547636d1 --- /dev/null +++ b/processor/processor.go @@ -0,0 +1,5 @@ +package processor + +type Processor interface { + Process() string +} diff --git a/sequencermanager/.gitkeep b/sequencermanager/.gitkeep deleted file mode 100644 index e69de29b..00000000 diff --git a/source/datastream/datastream.go b/source/datastream/datastream.go new file mode 100644 index 00000000..4bb8e974 --- /dev/null +++ b/source/datastream/datastream.go @@ -0,0 +1,9 @@ +package datastream + +type Datastream struct { + Source string +} + +func (d *Datastream) Source() string { + return d.Source +} diff --git a/source/source.go b/source/source.go new file mode 100644 index 00000000..603b86a1 --- /dev/null +++ b/source/source.go @@ -0,0 +1,5 @@ +package source + +type Source interface { + Source() string +} diff --git a/sourcemanager/sourcemanager.go b/sourcemanager/sourcemanager.go new file mode 100644 index 00000000..9095dbe0 --- /dev/null +++ b/sourcemanager/sourcemanager.go @@ -0,0 +1,5 @@ +package sourcemanager + +type SourceManager struct { + Source Source +} diff --git a/syncer/ethprovider/ethprovider.go b/syncer/ethprovider/ethprovider.go deleted file mode 100644 index 9bc463d8..00000000 --- a/syncer/ethprovider/ethprovider.go +++ /dev/null @@ -1,9 +0,0 @@ -package ethsyncer - -import ( - "github.com/0xPolygon/cdk/syncer/storage" -) - -type EthSyncer struct { - Storage storage.StorageService -} diff --git a/syncer/interfaces.go b/syncer/interfaces.go deleted file mode 100644 index 2be883fd..00000000 --- a/syncer/interfaces.go +++ /dev/null @@ -1,9 +0,0 @@ -package syncer - -type EventSyncer interface { - GetData() []byte -} - -type EventProcessor interface { - Process(data []byte) error -} \ No newline at end of file diff --git a/syncer/provider.go b/syncer/provider.go deleted file mode 100644 index d62c4fbc..00000000 --- a/syncer/provider.go +++ /dev/null @@ -1 +0,0 @@ -package syncer diff --git a/syncer/storage/storage.go b/syncer/storage/storage.go index c485ecb6..1e7851b5 100644 --- a/syncer/storage/storage.go +++ b/syncer/storage/storage.go @@ -1,7 +1,7 @@ package storage // Storage is an interface for the storage of the syncer -type StorageService interface { +type Storage interface { GetData() []byte GetLatestVerifiedBlock() uint64 } diff --git a/syncer/syncer.go b/syncer/syncer.go index fab1add8..a47a86e5 100644 --- a/syncer/syncer.go +++ b/syncer/syncer.go @@ -5,19 +5,4 @@ type Syncer interface { Start() error // Stop stops the syncer Stop() error - // Synced returns true if the syncer is synced - Synced() bool - // SyncedChan returns a channel that is closed when the syncer is synced - SyncedChan() <-chan struct{} - // LatestVerifiedBlock returns the latest verified block - LatestVerifiedBlock() uint64 - // LatestBlock returns the latest block - LatestBlock() uint64 - // SyncedBlock returns the latest block that is synced - SyncedBlock() uint64 - // SyncedBlockChan returns a channel that is closed when the latest block is synced - SyncedBlockChan() <-chan struct{} -} - -type Sync struct { }