chains

Documentation

Index

• type ChainRegistry
  • func NewChainRegistry(dbManager *db.ChainDBManager, logger zerolog.Logger) *ChainRegistry
  • func (r *ChainRegistry) AddOrUpdateChain(ctx context.Context, config *uregistrytypes.ChainConfig) error
  • func (r *ChainRegistry) CreateChainClient(config *uregistrytypes.ChainConfig) (common.ChainClient, error)
  • func (r *ChainRegistry) GetAllChains() map[string]common.ChainClient
  • func (r *ChainRegistry) GetChain(chainID string) common.ChainClient
  • func (r *ChainRegistry) GetDatabaseStats() map[string]interface{}
  • func (r *ChainRegistry) GetHealthStatus() map[string]bool
  • func (r *ChainRegistry) RemoveChain(chainID string)
  • func (r *ChainRegistry) SetAppConfig(cfg *config.Config)
  • func (r *ChainRegistry) SetObserver(observer ChainRegistryObserver)
  • func (r *ChainRegistry) SetVoteHandler(handler common.VoteHandler)
  • func (r *ChainRegistry) SetVoteHandlers(handlers map[string]common.VoteHandler)
  • func (r *ChainRegistry) StopAll()
• type ChainRegistryObserver

Types

type ChainRegistry

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

ChainRegistry manages chain clients based on their configurations

func NewChainRegistry

func NewChainRegistry(dbManager *db.ChainDBManager, logger zerolog.Logger) *ChainRegistry

NewChainRegistry creates a new chain registry

func (*ChainRegistry) AddOrUpdateChain

func (r *ChainRegistry) AddOrUpdateChain(ctx context.Context, config *uregistrytypes.ChainConfig) error

AddOrUpdateChain adds a new chain or updates an existing one

func (*ChainRegistry) CreateChainClient

func (r *ChainRegistry) CreateChainClient(config *uregistrytypes.ChainConfig) (common.ChainClient, error)

CreateChainClient creates a chain client based on VM type

func (*ChainRegistry) GetAllChains

func (r *ChainRegistry) GetAllChains() map[string]common.ChainClient

GetAllChains returns all registered chain clients

func (*ChainRegistry) GetChain

func (r *ChainRegistry) GetChain(chainID string) common.ChainClient

GetChain retrieves a chain client by ID

func (*ChainRegistry) GetDatabaseStats

func (r *ChainRegistry) GetDatabaseStats() map[string]interface{}

GetDatabaseStats returns statistics about all managed databases

func (*ChainRegistry) GetHealthStatus

func (r *ChainRegistry) GetHealthStatus() map[string]bool

GetHealthStatus returns the health status of all chains

func (*ChainRegistry) RemoveChain

func (r *ChainRegistry) RemoveChain(chainID string)

RemoveChain removes a chain from the registry

func (*ChainRegistry) SetAppConfig

func (r *ChainRegistry) SetAppConfig(cfg *config.Config)

SetAppConfig sets the application config for the registry

func (*ChainRegistry) SetObserver

func (r *ChainRegistry) SetObserver(observer ChainRegistryObserver)

SetObserver sets the observer for chain events

func (*ChainRegistry) SetVoteHandler

func (r *ChainRegistry) SetVoteHandler(handler common.VoteHandler)

SetVoteHandler sets the vote handler for all chains (backward compatibility)

func (*ChainRegistry) SetVoteHandlers

func (r *ChainRegistry) SetVoteHandlers(handlers map[string]common.VoteHandler)

SetVoteHandlers sets per-chain vote handlers

func (*ChainRegistry) StopAll

func (r *ChainRegistry) StopAll()

StopAll stops all chain clients

type ChainRegistryObserver

type ChainRegistryObserver interface {
	OnChainAdded(chainID string)
}

ChainRegistryObserver is an interface for observing chain addition events