worker

Documentation

Index

• type Message
• type MessageIter
• type Worker
  • func NewDripWorker(conf config.Config, backend backend.DelphisBackend, sess *session.Session) *Worker
  • func (w *Worker) ReadMessages(ctx context.Context) MessageIter
  • func (w *Worker) Start(ctx context.Context) error

Types

type Message

type Message struct {
	Content model.ImportedContentInput
	Done    func() error
}

type MessageIter

type MessageIter interface {
	Next(*Message) bool
	Close() error
}

type Worker

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

func NewDripWorker

func NewDripWorker(conf config.Config, backend backend.DelphisBackend, sess *session.Session) *Worker

func (*Worker) ReadMessages

func (w *Worker) ReadMessages(ctx context.Context) MessageIter

func (*Worker) Start

func (w *Worker) Start(ctx context.Context) error