adapter

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 14, 2025 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SuperblockPublisher 

type SuperblockPublisher struct {
	publisher.Publisher
	// contains filtered or unexported fields
}

SuperblockPublisher wraps the base publisher with SBCP capabilities

func WrapPublisher 

func WrapPublisher(
	pub publisher.Publisher,
	config superblock.Config,
	log zerolog.Logger,
	consensusCoord consensus.Coordinator,
	transport transport.Server,
	collector collector.Service,
	prover proofs.ProverClient,
	regSvc sreg.Service,
) (*SuperblockPublisher, error)

WrapPublisher creates a new SuperblockPublisher by wrapping an existing publisher

func (*SuperblockPublisher) GetStats 

func (sp *SuperblockPublisher) GetStats() map[string]interface{}

GetStats combines stats from both components

func (*SuperblockPublisher) Start 

func (sp *SuperblockPublisher) Start(ctx context.Context) error

Start starts both the base publisher and superblock coordinator

func (*SuperblockPublisher) Stop 

func (sp *SuperblockPublisher) Stop(ctx context.Context) error

Stop stops both components

func (*SuperblockPublisher) SubmitXTRequest 

func (sp *SuperblockPublisher) SubmitXTRequest(ctx context.Context, from string, request *pb.XTRequest) error

SubmitXTRequest queues a cross-chain transaction request

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.