processor

Documentation

Index

• type IPFSProcessor
  • func NewIPFSProcessor(q queue.Queue, b backend.Backend, ipfsGateway string, pollTime time.Duration, ...) *IPFSProcessor
  • func (p *IPFSProcessor) FetchCID(cid string) (ipfs.Metadata, error)
  • func (p *IPFSProcessor) Run()
  • func (p *IPFSProcessor) Stop()
  • func (p *IPFSProcessor) Wait()
  • func (p *IPFSProcessor) Work(item queue.QueueItem) error

Types

type IPFSProcessor

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

IPFSProcessor is a struct that implements the Processor interface for IPFS.

func NewIPFSProcessor

func NewIPFSProcessor(q queue.Queue, b backend.Backend, ipfsGateway string, pollTime time.Duration, concurrency int) *IPFSProcessor

NewIPFSProcessor creates a new IPFSProcessor instance with the specified queue, IPFS gateway, and ticker time.

func (*IPFSProcessor) FetchCID

func (p *IPFSProcessor) FetchCID(cid string) (ipfs.Metadata, error)

FetchCID fetches the content of the specified CID from the IPFS gateway and returns it as an ipfs.Metadata struct.

func (*IPFSProcessor) Run

func (p *IPFSProcessor) Run()

Run starts the IPFSProcessor and processes items from the queue.

func (*IPFSProcessor) Stop

func (p *IPFSProcessor) Stop()

Stop stops the IPFSProcessor.

func (*IPFSProcessor) Wait

func (p *IPFSProcessor) Wait()

Wait waits for the IPFSProcessor to stop.

func (*IPFSProcessor) Work

func (p *IPFSProcessor) Work(item queue.QueueItem) error