worker

Documentation

Index

• func ProcessRequests(ctx context.Context)
• func Submit(ctx context.Context, r *entry.Request)
• type Daily
• type Every
• type Job
• type JobFunc
  • func (f JobFunc) Run(ctx context.Context)
• type JobScheduler
  • func GetScheduler(ctx context.Context) *JobScheduler
  • func OpenScheduler(ctx context.Context, g *errgroup.Group) (context.Context, *JobScheduler)
  • func (j *JobScheduler) Close() error
  • func (s *JobScheduler) Schedule(id string, schedule Schedule, job Job)
• type RequestBuffer
  • func GetBuff(ctx context.Context) *RequestBuffer
  • func SetupRequestsBuffer(ctx context.Context) (context.Context, *RequestBuffer)
  • func (r *RequestBuffer) Accept(req *entry.Request)
  • func (r *RequestBuffer) Close() error
• type Schedule

Functions

func ProcessRequests

func ProcessRequests(ctx context.Context)

func Submit

func Submit(ctx context.Context, r *entry.Request)

Types

type Daily

type Daily struct{}

Daily schedules the job to run at midnight

type Every

type Every time.Duration

type Job

type Job interface {
	Run(context.Context)
}

type JobFunc

type JobFunc func(context.Context)

func (JobFunc) Run

func (f JobFunc) Run(ctx context.Context)

type JobScheduler

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

func GetScheduler

func GetScheduler(ctx context.Context) *JobScheduler

func OpenScheduler

func OpenScheduler(ctx context.Context, g *errgroup.Group) (context.Context, *JobScheduler)

func (*JobScheduler) Close

func (j *JobScheduler) Close() error

func (*JobScheduler) Schedule

func (s *JobScheduler) Schedule(id string, schedule Schedule, job Job)

type RequestBuffer

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

func GetBuff

func GetBuff(ctx context.Context) *RequestBuffer

func SetupRequestsBuffer

func SetupRequestsBuffer(ctx context.Context) (context.Context, *RequestBuffer)

func (*RequestBuffer) Accept

func (r *RequestBuffer) Accept(req *entry.Request)

func (*RequestBuffer) Close

func (r *RequestBuffer) Close() error

type Schedule

type Schedule interface {
	// contains filtered or unexported methods
}