sync

type EnvelopeSink ¶ added in v0.5.0

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

func (s *EnvelopeSink) Start()

type MigrationConfig ¶ added in v0.5.1

type MigrationConfig struct {
	Enable     bool
	FromNodeID uint32
}

type NodeRegistration ¶ added in v0.1.1

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

type NodeRegistryWatcher ¶ added in v0.5.0

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

NodeRegistryWatcher monitors registry updates for a specific node and invokes a user-provided cancel function when a change is detected.

The cancel function is intended to trigger teardown or reinitialization of any state associated with that node (e.g., gRPC connections, sync loops).

📌 Usage:

watcher := NewNodeRegistryWatcher(ctx, log, nodeID, registry)
watcher.RegisterCancelFunction(func() {
    teardownOrRestart()
})
watcher.Watch()

When the registry signals a change, the cancel function is invoked **exactly once**. If the caller wishes to handle **subsequent changes**, they must call `RegisterCancelFunction` again after each invocation.

If no cancel function is registered when a change occurs, the update is silently ignored.

func NewNodeRegistryWatcher(
	ctx context.Context,
	logger *zap.Logger,
	nodeID uint32,
	nodeRegistry registry.NodeRegistry,
) *NodeRegistryWatcher

func (w *NodeRegistryWatcher) RegisterCancelFunction(fn func())

func (w *NodeRegistryWatcher) Watch()

type SyncServer ¶

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

func NewSyncServer(opts ...SyncServerOption) (*SyncServer, error)

func (s *SyncServer) Close()

type SyncServerConfig ¶ added in v0.4.0

type SyncServerConfig struct {
	Ctx                        context.Context
	Logger                     *zap.Logger
	NodeRegistry               registry.NodeRegistry
	Registrant                 *registrant.Registrant
	DB                         *sql.DB
	FeeCalculator              fees.IFeeCalculator
	PayerReportStore           payerreport.IPayerReportStore
	PayerReportDomainSeparator common.Hash
	Migration                  MigrationConfig
}

type SyncServerOption ¶ added in v0.4.0

type SyncServerOption func(*SyncServerConfig)

func WithContext(ctx context.Context) SyncServerOption

func WithDB(db *sql.DB) SyncServerOption

func WithFeeCalculator(calc fees.IFeeCalculator) SyncServerOption

func WithLogger(logger *zap.Logger) SyncServerOption

func WithMigration(migration MigrationConfig) SyncServerOption

func WithNodeRegistry(reg registry.NodeRegistry) SyncServerOption

func WithPayerReportDomainSeparator(domainSeparator common.Hash) SyncServerOption

func WithPayerReportStore(store payerreport.IPayerReportStore) SyncServerOption

func WithRegistrant(r *registrant.Registrant) SyncServerOption