impl

Documentation

Index

• func AddOnchainMetadataEvent() abi.Event
• func EncodeDagCborEvent() abi.Event
• func EncodeDagJsonEvent() abi.Event
• func FetchBlock(ctx context.Context, exchange graphsync.GraphExchange, ipfspeer *peer.AddrInfo, ...) error
• func GetHooks(s sdk.Storage) func(t *state.Transition)
• func NewAgent(ctx context.Context, gsynchost host.Host, router string) gsync.GraphExchange
• func NewEdge(ctx context.Context, gsynchost host.Host, router string) string
• func NewPeer(ctx context.Context, addr string) host.Host
• func NewRouter(ctx context.Context, gsynchost host.Host, lsys linking.LinkSystem, ...) (gsync.GraphExchange, *peer.AddrInfo)
• func PostTxProcessing(s sdk.Storage, t *state.Transition) error
• func PrintProgress(ctx context.Context, pgChan <-chan gsync.ResponseProgress)
• func PushBlock(ctx context.Context, exchange graphsync.GraphExchange, ipfspeer *peer.AddrInfo, ...) error
• func ReadCAR() ([]cid.Cid, blocks.Block, datamodel.Node, error)
• func StoreDagBlockDoneEvent() abi.Event
• func VerifyHasErrors(ctx context.Context, errChan <-chan error) error
• type ReceivedMessage
• type Receiver
  • func (r *Receiver) Connected(p peer.ID)
  • func (r *Receiver) Disconnected(p peer.ID)
  • func (r *Receiver) ReceiveError(_ peer.ID, err error)
  • func (r *Receiver) ReceiveMessage(ctx context.Context, sender peer.ID, incoming gsmsg.GraphSyncMessage)

Functions

func AddOnchainMetadataEvent

func AddOnchainMetadataEvent() abi.Event

func EncodeDagCborEvent

func EncodeDagCborEvent() abi.Event

func EncodeDagJsonEvent

func EncodeDagJsonEvent() abi.Event

func FetchBlock

func FetchBlock(ctx context.Context, exchange graphsync.GraphExchange, ipfspeer *peer.AddrInfo, c ipld.Link) error

func GetHooks

func GetHooks(s sdk.Storage) func(t *state.Transition)

func NewAgent

func NewAgent(ctx context.Context, gsynchost host.Host, router string) gsync.GraphExchange

func NewEdge

func NewEdge(ctx context.Context, gsynchost host.Host, router string) string

func NewPeer

func NewPeer(ctx context.Context, addr string) host.Host

func NewRouter

func NewRouter(ctx context.Context, gsynchost host.Host, lsys linking.LinkSystem, peerhost string) (gsync.GraphExchange, *peer.AddrInfo)

func PostTxProcessing

func PostTxProcessing(s sdk.Storage, t *state.Transition) error

func PrintProgress

func PrintProgress(ctx context.Context, pgChan <-chan gsync.ResponseProgress)

VerifyHasErrors verifies that at least one error was sent over a channel

func PushBlock

func PushBlock(ctx context.Context, exchange graphsync.GraphExchange, ipfspeer *peer.AddrInfo, c ipld.Link) error

func ReadCAR

func ReadCAR() ([]cid.Cid, blocks.Block, datamodel.Node, error)

WriteCAR

func StoreDagBlockDoneEvent

func StoreDagBlockDoneEvent() abi.Event

func VerifyHasErrors

func VerifyHasErrors(ctx context.Context, errChan <-chan error) error

VerifyHasErrors verifies that at least one error was sent over a channel

Types

type ReceivedMessage

type ReceivedMessage struct {
	Message gsmsg.GraphSyncMessage
	Sender  peer.ID
}

type Receiver

type Receiver struct {
	MessageReceived chan ReceivedMessage
}

Receiver is an interface for receiving messages from the GraphSyncNetwork.

func (*Receiver) Connected

func (r *Receiver) Connected(p peer.ID)

func (*Receiver) Disconnected

func (r *Receiver) Disconnected(p peer.ID)

func (*Receiver) ReceiveError

func (r *Receiver) ReceiveError(_ peer.ID, err error)

func (*Receiver) ReceiveMessage

func (r *Receiver) ReceiveMessage(
	ctx context.Context,
	sender peer.ID,
	incoming gsmsg.GraphSyncMessage)