handlers

Documentation

Index

• type DocumentProcessor
  • func NewDocumentProcessor(store Store, s3 S3) *DocumentProcessor
  • func (d *DocumentProcessor) ProcessTask(ctx context.Context, t *asynq.Task) error
• type S3
• type Store

Types

type DocumentProcessor

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

func NewDocumentProcessor

func NewDocumentProcessor(store Store, s3 S3) *DocumentProcessor

func (*DocumentProcessor) ProcessTask

func (d *DocumentProcessor) ProcessTask(ctx context.Context, t *asynq.Task) error

type S3

type S3 interface {
	GetObject(ctx context.Context, bucketName, filename string) (io.ReadCloser, error)
}

type Store

type Store interface {
	GetDocument(ctx context.Context, id int) (*ent.Document, error)
	SetDocumentContent(ctx context.Context, id int, content *string) (*ent.Document, error)
}