Basic scaffolding for CDK

cmd/main.go

@@ -0,0 +1 @@
+package main

go.mod

@@ -0,0 +1,3 @@
+module github.com/0xPolygon/cdk
+
+go 1.22

syncer/ethprovider/ethprovider.go

@@ -0,0 +1,9 @@
+package ethsyncer
+
+import (
+	"github.com/0xPolygon/cdk/syncer/storage"
+)
+
+type EthSyncer struct {
+	Storage storage.StorageService
+}

syncer/interfaces.go

@@ -0,0 +1,9 @@
+package syncer
+
+type EventSyncer interface {
+	GetData() []byte
+}
+
+type EventProcessor interface {
+	Process(data []byte) error
+}

syncer/provider.go

@@ -0,0 +1 @@
+package syncer

syncer/storage/inmem/inmem.go

@@ -0,0 +1,8 @@
+package inmem
+
+type Inmem struct {
+}
+
+func (inmem *Inmem) GetData() []byte {
+	return []byte("Inmem")
+}

syncer/storage/storage.go

@@ -0,0 +1,7 @@
+package storage
+
+// Storage is an interface for the storage of the syncer
+type StorageService interface {
+	GetData() []byte
+	GetLatestVerifiedBlock() uint64
+}

syncer/syncer.go

@@ -0,0 +1,23 @@
+package syncer
+
+type Syncer interface {
+	// Start starts the syncer
+	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 {
+}

test/e2e.go

@@ -0,0 +1 @@
+package e2e