tokenprocessing

Documentation

Index

• Variables
• func CoreInitServer(ctx context.Context, clients *server.Clients, mc *multichain.Provider) *gin.Engine
• func InitSentry()
• func InitServer()
• func NewTokenProcessor(queries *db.Queries, httpClient *http.Client, metadataFinder *MetadataFinder, ...) *tokenProcessor
• type ErrImageResultRequired
  • func (e ErrImageResultRequired) Error() string
  • func (e ErrImageResultRequired) Unwrap() error
• type MetadataFinder
  • func (m *MetadataFinder) GetMetadata(ctx context.Context, t persist.TokenIdentifiers) (persist.TokenMetadata, error)
• type PipelineOption
• type ProcessMediaForTokenInput

Variables

var ErrRequiredSignedToken = errors.New("token isn't signed")

ErrRequiredSignedToken indicates that the token isn't signed

var PipelineOpts pOpts

Functions

func CoreInitServer

func CoreInitServer(ctx context.Context, clients *server.Clients, mc *multichain.Provider) *gin.Engine

func InitSentry

func InitSentry()

func InitServer

func InitServer()

InitServer initializes the mediaprocessing server

func NewTokenProcessor

func NewTokenProcessor(queries *db.Queries, httpClient *http.Client, metadataFinder *MetadataFinder, ipfsClient *shell.Shell, arweaveClient *goar.Client, stg *storage.Client, tokenBucket string) *tokenProcessor

Types

type ErrImageResultRequired

type ErrImageResultRequired struct{ Err error }

func (ErrImageResultRequired) Error

func (e ErrImageResultRequired) Error() string

func (ErrImageResultRequired) Unwrap

func (e ErrImageResultRequired) Unwrap() error

type MetadataFinder

type MetadataFinder struct {
	// contains filtered or unexported fields
}

MetadataFinder is a service for fetching metadata for a token Batching pattern adapted from dataloaden (https://github.com/vektah/dataloaden)

func (*MetadataFinder) GetMetadata

func (m *MetadataFinder) GetMetadata(ctx context.Context, t persist.TokenIdentifiers) (persist.TokenMetadata, error)

type PipelineOption

type PipelineOption func(*tokenProcessingJob)

type ProcessMediaForTokenInput

type ProcessMediaForTokenInput struct {
	TokenID         persist.HexTokenID `json:"token_id" binding:"required"`
	ContractAddress persist.Address    `json:"contract_address" binding:"required"`
	Chain           persist.Chain      `json:"chain"`
}