lib

Aug 15, 2023

Changes in this version

+ var ErrFetcherUnexpectedEOF = fmt.Errorf("failed to fetch IPLD data")

+ var ErrNilBlock = caboose.ErrInvalidResponse

+ func GatewayError(err error) error

+ type AwaitCloser interface

+ AwaitClose func() <-chan error

+ type ErrPartialResponse = caboose.ErrPartialResponse

type GraphGatewayOption

+ func WithPrometheusRegistry(reg prometheus.Registerer) GraphGatewayOption

May 24, 2023

Changes in this version

+ const GetBlockTimeout

Apr 6, 2023

Changes in this version

+ const DefaultCacheBlockStoreSize

+ func NewCacheBlockStore(size int) (blockstore.Blockstore, error)

+ type BlockPubSub interface

+ Publish func(blocks ...blocks.Block)

+ Shutdown func()

+ Subscribe func(ctx context.Context, keys ...multihash.Multihash) <-chan blocks.Block

+ func NewBlockPubSub() BlockPubSub

+ type CarFetcher interface

+ Fetch func(ctx context.Context, path string, cb DataCallback) error

+ type DataCallback = caboose.DataCallback

+ type GraphGateway struct

+ func NewGraphGatewayBackend(f CarFetcher, blockFetcher exchange.Fetcher, opts ...GraphGatewayOption) (*GraphGateway, error)

+ func (api *GraphGateway) Get(ctx context.Context, path gateway.ImmutablePath, ...) (gateway.ContentPathMetadata, *gateway.GetResponse, error)

+ func (api *GraphGateway) GetAll(ctx context.Context, path gateway.ImmutablePath) (gateway.ContentPathMetadata, files.Node, error)

+ func (api *GraphGateway) GetBlock(ctx context.Context, path gateway.ImmutablePath) (gateway.ContentPathMetadata, files.File, error)

+ func (api *GraphGateway) GetCAR(ctx context.Context, path gateway.ImmutablePath) (gateway.ContentPathMetadata, io.ReadCloser, <-chan error, error)

+ func (api *GraphGateway) GetDNSLinkRecord(ctx context.Context, hostname string) (ifacepath.Path, error)

+ func (api *GraphGateway) GetIPNSRecord(ctx context.Context, c cid.Cid) ([]byte, error)

+ func (api *GraphGateway) Head(ctx context.Context, path gateway.ImmutablePath) (gateway.ContentPathMetadata, files.Node, error)

+ func (api *GraphGateway) IsCached(ctx context.Context, path ifacepath.Path) bool

+ func (api *GraphGateway) ResolveMutable(ctx context.Context, p ifacepath.Path) (gateway.ImmutablePath, error)

+ func (api *GraphGateway) ResolvePath(ctx context.Context, path gateway.ImmutablePath) (gateway.ContentPathMetadata, error)

+ type GraphGatewayMetrics struct

+ type GraphGatewayOption func(gwOptions *gwOptions) error

+ func WithBlockstore(bs blockstore.Blockstore) GraphGatewayOption

+ func WithNameSystem(ns namesys.NameSystem) GraphGatewayOption

+ func WithValueStore(vs routing.ValueStore) GraphGatewayOption

+ type Notifier interface

+ NotifyNewBlocks func(ctx context.Context, blocks ...blocks.Block) error