aggregator

package

v0.0.0-...-f02749d Latest Latest Go to latest Published: Sep 15, 2025 License: MIT Imports: 46 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/FIL-Builders/xchainClient

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewAggregator(ctx context.Context, cfg *config.Config, srcCfg *config.SourceChainConfig) (*aggregator, error)
func StartAggregationService(ctx context.Context, cfg *config.Config, srcCfg *config.SourceChainConfig) error
type AggregateTransfer
type DataReadyEvent
type LotusBeaconEntry
type LotusDaemonAPIClientV0
- func NewLotusDaemonAPIClientV0(ctx context.Context, url string, timeoutSecs int, bearerToken string) (LotusDaemonAPIClientV0, jsonrpc.ClientCloser, error)
type LotusMinerAPIClientV0
type LotusTS
type LotusTSK
type Offer
- func (o *Offer) Piece() (filabi.PieceInfo, error)

Constants ¶

View Source

const (
	// libp2p identifier for latest deal protocol
	DealProtocolv120 = "/fil/storage/mk/1.2.0"
)

Variables ¶

This section is empty.

Functions ¶

func NewAggregator ¶

func NewAggregator(ctx context.Context, cfg *config.Config, srcCfg *config.SourceChainConfig) (*aggregator, error)

func StartAggregationService ¶

func StartAggregationService(ctx context.Context, cfg *config.Config, srcCfg *config.SourceChainConfig) error

Function to start the aggregation service

Types ¶

type AggregateTransfer ¶

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

type DataReadyEvent ¶

type DataReadyEvent struct {
	Offer   Offer
	OfferID uint64
}

Define a Go struct to match the DataReady event from the OnRamp contract

type LotusBeaconEntry ¶

type LotusBeaconEntry = lotustypes.BeaconEntry

type LotusDaemonAPIClientV0 ¶

type LotusDaemonAPIClientV0 = v0api.FullNode

func NewLotusDaemonAPIClientV0 ¶

func NewLotusDaemonAPIClientV0(ctx context.Context, url string, timeoutSecs int, bearerToken string) (LotusDaemonAPIClientV0, jsonrpc.ClientCloser, error)

type LotusMinerAPIClientV0 ¶

type LotusMinerAPIClientV0 = v0api.StorageMiner

type LotusTS ¶

type LotusTS = lotustypes.TipSet

type LotusTSK ¶

type LotusTSK = lotustypes.TipSetKey

type Offer ¶

type Offer struct {
	CommP    []uint8        `json:"commP"`
	Size     uint64         `json:"size"`
	Cid      string         `json:"cid"`
	Location string         `json:"location"`
	Amount   *big.Int       `json:"amount"`
	Token    common.Address `json:"token"`
}

Mirror OnRamp.sol's `Offer` struct

func (*Offer) Piece ¶

func (o *Offer) Piece() (filabi.PieceInfo, error)

Source Files ¶

View all Source files

aggregator.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL