Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

adapter

package

Go to main page

Versions in this module

v1

v1.0.0-beta.4

Jan 5, 2026

v1.0.0-beta.3

Oct 15, 2025

v1.0.0-beta.2

Oct 10, 2025

v1.0.0-beta.1

Oct 6, 2025

v0

v0.4.2

Sep 26, 2025

v0.4.1

Sep 22, 2025

v0.4.0

Sep 18, 2025

Changes in this version

+ const MetricsSubsystem

+ func AggregatorNodeSignatureBytesProvider(adapter *Adapter) evtypes.AggregatorNodeSignatureBytesProvider

+ func LoadGenesisDoc(cfg *cmtcfg.Config) (*cmttypes.GenesisDoc, error)

+ func MakeABCIBlock(blockHeight uint64, cmtTxs cmttypes.Txs, currentState *cmtstate.State, ...) (*cmttypes.Block, *cmttypes.BlockID, error)

+ func SyncNodeSignatureBytesProvider(adapter *Adapter) evtypes.SyncNodeSignatureBytesProvider

+ func ToABCIBlock(header cmttypes.Header, lastCommit *cmttypes.Commit, data *rlktypes.Data) (*cmttypes.Block, error)

+ func ToABCIBlockMeta(abciBlock *cmttypes.Block) (*cmttypes.BlockMeta, error)

+ func ToABCIHeader(header rlktypes.Header, lastCommit *cmttypes.Commit) (cmttypes.Header, error)

+ func ValidatorHasherProvider() func(proposerAddress []byte, pubKey crypto.PubKey) (evtypes.Hash, error)

+ type Adapter struct

+ App servertypes.ABCI

+ AppGenesis *genutiltypes.AppGenesis

+ EventBus *cmttypes.EventBus

+ Logger log.Logger

+ Mempool mempool.Mempool

+ MempoolIDs *mempoolIDs

+ P2PClient P2PClientInfo

+ RollkitStore rstore.Store

+ Store *execstore.Store

+ TxGossiper *p2p.Gossiper

+ func NewABCIExecutor(app servertypes.ABCI, store ds.Batching, p2pClient *rollkitp2p.Client, ...) *Adapter

+ func (a *Adapter) ExecuteTxs(ctx context.Context, txs [][]byte, blockHeight uint64, timestamp time.Time, ...) ([]byte, uint64, error)

+ func (a *Adapter) GetLastCommit(ctx context.Context, blockHeight uint64) (*cmttypes.Commit, error)

+ func (a *Adapter) GetTxs(ctx context.Context) ([][]byte, error)

+ func (a *Adapter) InitChain(ctx context.Context, genesisTime time.Time, initialHeight uint64, ...) ([]byte, uint64, error)

+ func (a *Adapter) SetFinal(ctx context.Context, blockHeight uint64) error

+ func (a *Adapter) SetMempool(mempool mempool.Mempool)

+ func (a *Adapter) Start(ctx context.Context) error

+ type BlockFilter interface

+ IsPublishable func(ctx context.Context, height int64) bool

+ type BlockFilterFn func(ctx context.Context, height int64) bool

+ func (b BlockFilterFn) IsPublishable(ctx context.Context, height int64) bool

+ type Metrics struct

+ BlockExecutionDurationSeconds metrics.Histogram

+ BlockExecutionStepDurationSeconds metrics.Histogram

+ CheckTxDurationSeconds metrics.Histogram

+ ConsensusParamUpdatesTotal metrics.Counter

+ GetTxsDurationSeconds metrics.Histogram

+ InitChainDurationSeconds metrics.Histogram

+ MempoolReapDurationSeconds metrics.Histogram

+ PrepareProposalDurationSeconds metrics.Histogram

+ TxValidationResultTotal metrics.Counter

+ TxValidationTotal metrics.Counter

+ TxsExecutedPerBlock metrics.Histogram

+ TxsProposedTotal metrics.Counter

+ ValidatorUpdatesTotal metrics.Counter

+ func NopMetrics() *Metrics

+ func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics

+ type NetworkSoftConfirmationBlockFilter struct

+ func (f *NetworkSoftConfirmationBlockFilter) IsPublishable(ctx context.Context, height int64) bool

+ type Option func(*Adapter)

+ func WithBlockFilter(publisher BlockFilter) Option

+ func WithMetrics(m *Metrics) Option

+ func WithNetworkSoftConfirmationBlockFilter() Option

+ type P2PClientInfo interface

+ Addrs func() []ma.Multiaddr

+ Host func() host.Host

+ Info func() (string, string, string, error)

+ Peers func() []rollkitp2p.PeerConnection

+ PubSub func() *pubsub.PubSub

+ type StackedEvent struct