providercacher

Documentation

Index

• 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 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 {
	Provider model.ProviderResult
	Index    blobindex.ShardedDagIndexView
}