contentprovider

Documentation

Index

• func GenerateNewPeer() ([]byte, []byte, peer.ID, error)
• func GetMetadataHandler(c echo.Context, db *gorm.DB) error
• type ContentProviderConfig
• type ContentProviderService
  • func NewContentProviderService(db *gorm.DB, config ContentProviderConfig) (*ContentProviderService, error)
  • func (s *ContentProviderService) FindPiece(ctx context.Context, pieceCid cid.Cid) (io.ReadSeekCloser, time.Time, error)
  • func (s *ContentProviderService) GetMetadataHandler(c echo.Context) error
  • func (s *ContentProviderService) GetPieceMetadata(ctx context.Context, car model.Car) (*PieceMetadata, error)
  • func (s *ContentProviderService) Start(ctx context.Context) error
  • func (s *ContentProviderService) StartBitswap(ctx context.Context) error
• type PieceMetadata
  • func GetPieceMetadata(ctx context.Context, db *gorm.DB, car model.Car) (*PieceMetadata, error)

Functions

func GenerateNewPeer

func GenerateNewPeer() ([]byte, []byte, peer.ID, error)

func GetMetadataHandler

func GetMetadataHandler(c echo.Context, db *gorm.DB) error

Types

type ContentProviderConfig

type ContentProviderConfig struct {
	EnableHTTP        bool
	HTTPBind          string
	EnableBitswap     bool
	Libp2pIdentityKey string
	Libp2pListenAddrs []string
}

type ContentProviderService

type ContentProviderService struct {
	Resolver datasource.HandlerResolver
	DB       *gorm.DB
	// contains filtered or unexported fields
}

func NewContentProviderService

func NewContentProviderService(db *gorm.DB, config ContentProviderConfig) (*ContentProviderService, error)

func (*ContentProviderService) FindPiece

func (s *ContentProviderService) FindPiece(ctx context.Context, pieceCid cid.Cid) (
	io.ReadSeekCloser,
	time.Time,
	error,
)

func (*ContentProviderService) GetMetadataHandler

func (s *ContentProviderService) GetMetadataHandler(c echo.Context) error

func (*ContentProviderService) GetPieceMetadata

func (s *ContentProviderService) GetPieceMetadata(ctx context.Context, car model.Car) (*PieceMetadata, error)

func (*ContentProviderService) Start

func (s *ContentProviderService) Start(ctx context.Context) error

func (*ContentProviderService) StartBitswap

func (s *ContentProviderService) StartBitswap(ctx context.Context) error

type PieceMetadata

type PieceMetadata struct {
	Car       model.Car        `json:"car"`
	Source    model.Source     `json:"source"`
	CarBlocks []model.CarBlock `json:"carBlocks"`
	Items     []model.Item     `json:"items"`
}

func GetPieceMetadata

func GetPieceMetadata(ctx context.Context, db *gorm.DB, car model.Car) (*PieceMetadata, error)