blockfetch

type BatchDoneFunc func(CallbackContext) error

type BlockFetch struct {
	Client *Client // Block Fetch client
	Server *Server // Block Fetch server
}

type BlockFetchOptionFunc func(*Config)

type BlockFunc func(CallbackContext, uint, ledger.Block) error

type BlockRawFunc func(CallbackContext, uint, []byte) error

type CallbackContext struct {
	ConnectionId connection.ConnectionId // Connection ID
	Client       *Client                 // Client instance (if applicable)
	Server       *Server                 // Server instance (if applicable)
}

type Client struct {
	*protocol.Protocol
	// contains filtered or unexported fields
}

type Config struct {
	BlockFunc         BlockFunc        // Callback for decoded blocks
	BlockRawFunc      BlockRawFunc     // Callback for raw block data
	BatchDoneFunc     BatchDoneFunc    // Callback when a batch is done
	RequestRangeFunc  RequestRangeFunc // Callback for range requests
	BatchStartTimeout time.Duration    // Timeout for starting a batch
	BlockTimeout      time.Duration    // Timeout for receiving a block
	RecvQueueSize     int              // Size of the receive queue
}

type MsgBatchDone struct {
	protocol.MessageBase
}

type MsgBlock struct {
	protocol.MessageBase
	WrappedBlock []byte // CBOR-encoded wrapped block
}

type MsgClientDone struct {
	protocol.MessageBase
}

type MsgNoBlocks struct {
	protocol.MessageBase
}

type MsgRequestRange struct {
	protocol.MessageBase
	Start common.Point // Start point of the range
	End   common.Point // End point of the range
}

type MsgStartBatch struct {
	protocol.MessageBase
}

type RequestRangeFunc func(CallbackContext, common.Point, common.Point) error

type Server struct {
	*protocol.Protocol
	// contains filtered or unexported fields
}

type WrappedBlock struct {
	cbor.StructAsArray
	Type     uint            // Block type identifier
	RawBlock cbor.RawMessage // Raw block data
}