impl

package

v1.5.7 Latest Latest Go to latest Published: May 1, 2022 License: MIT Imports: 35 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/anconprotocol/sdk

Links

Open Source Insights

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
- 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)

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 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 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 PushBlock ¶

func PushBlock(ctx context.Context, ipfsurl string, data []byte) (string, error)

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 ¶

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)

Source Files ¶

View all Source files

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