Documentation ¶
Index ¶
- Variables
- 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 NewRouterWithPeers(ctx context.Context, gsynchost host.Host, lsys linking.LinkSystem, ...) gsync.GraphExchange
- func PostTxProcessing(s sdk.Storage, t *state.Transition) error
- func PrintProgress(ctx context.Context, pgChan <-chan gsync.ResponseProgress)
- func PushBlock(ctx context.Context, ipfsurl string, data []byte) (string, error)
- func PushBlockWithExtData(ctx context.Context, exchange graphsync.GraphExchange, ipfspeer *peer.AddrInfo, ...) error
- func StoreDagBlockDoneEvent() abi.Event
- func VerifyHasErrors(ctx context.Context, errChan <-chan error) error
- type ReceivedMessage
- type Receiver
Constants ¶
This section is empty.
Variables ¶
View Source
var SelectAll ipld.Node = func() ipld.Node { ssb := builder.NewSelectorSpecBuilder(basicnode.Prototype.Any) return ssb.ExploreRecursive( ipldselector.RecursionLimitDepth(100), ssb.ExploreAll(ssb.ExploreRecursiveEdge()), ).Node() }()
Functions ¶
func AddOnchainMetadataEvent ¶
func EncodeDagCborEvent ¶
func EncodeDagJsonEvent ¶
func FetchBlock ¶
func NewRouterWithPeers ¶ added in v0.1.4
func NewRouterWithPeers(ctx context.Context, gsynchost host.Host, lsys linking.LinkSystem, peers []*peer.AddrInfo) gsync.GraphExchange
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 PushBlockWithExtData ¶ added in v0.1.4
func PushBlockWithExtData(ctx context.Context, exchange graphsync.GraphExchange, ipfspeer *peer.AddrInfo, c ipld.Link, extensionData gsync.ExtensionData, selector ipld.Node) error
Push block with extension data
func StoreDagBlockDoneEvent ¶
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) Disconnected ¶
func (*Receiver) ReceiveMessage ¶
Click to show internal directories.
Click to hide internal directories.