providercacher

Documentation

Index

• type CachingQueue
  • func NewCachingQueue(jobQueue JobQueue) *CachingQueue
  • func (q *CachingQueue) QueueProviderCaching(ctx context.Context, provider model.ProviderResult, ...) error
• type JobHandler
  • func NewJobHandler(providerCacher ProviderCacher) *JobHandler
  • func (j *JobHandler) Handle(ctx context.Context, job ProviderCachingJob) error
• type JobQueue
• type ProviderCacher
  • func NewSimpleProviderCacher(providerStore types.ProviderStore) ProviderCacher
• type ProviderCachingJob

Types

type CachingQueue

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

func NewCachingQueue

func NewCachingQueue(jobQueue JobQueue) *CachingQueue

func (*CachingQueue) QueueProviderCaching

func (q *CachingQueue) QueueProviderCaching(ctx context.Context, provider model.ProviderResult, index blobindex.ShardedDagIndexView) error

type JobHandler

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

func NewJobHandler

func NewJobHandler(providerCacher ProviderCacher) *JobHandler

func (*JobHandler) Handle

func (j *JobHandler) Handle(ctx context.Context, job ProviderCachingJob) error

type JobQueue

type JobQueue interface {
	Queue(ctx context.Context, j ProviderCachingJob) error
}

type ProviderCacher

type ProviderCacher interface {
	CacheProviderForIndexRecords(ctx context.Context, provider model.ProviderResult, index blobindex.ShardedDagIndexView) (written uint64, err error)
}

func NewSimpleProviderCacher

func NewSimpleProviderCacher(providerStore types.ProviderStore) ProviderCacher

type ProviderCachingJob

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