cronworker

README

Example

Create delivery handler

package workerhandler

import (
	"context"
	"fmt"
	"time"

	"pkg.agungdwiprasetyo.com/candi/codebase/factory/types"
	"pkg.agungdwiprasetyo.com/candi/candihelper"
	"pkg.agungdwiprasetyo.com/candi/logger"
	"pkg.agungdwiprasetyo.com/candi/tracer"
)

// CronHandler struct
type CronHandler struct {
}

// NewCronHandler constructor
func NewCronHandler() *CronHandler {
	return &CronHandler{}
}

// MountHandlers return group map topic key to handler func
func (h *CronHandler) MountHandlers(group *types.WorkerHandlerGroup) {

	group.Add(candihelper.CronJobKeyToString("push-notif", "30s"), h.handlePushNotif)
	group.Add(candihelper.CronJobKeyToString("heavy-push-notif", "22:43:07"), h.handleHeavyPush)
}

func (h *CronHandler) handlePushNotif(ctx context.Context, message []byte) error {
	trace := tracer.StartTrace(ctx, "CronDelivery-HandlePushNotif")
	defer trace.Finish()

	logger.LogI("processing")
	logger.LogI("done")
	return nil
}

func (h *CronHandler) handleHeavyPush(ctx context.Context, message []byte) error {
	trace := tracer.StartTrace(ctx, "CronDelivery-HandleHeavyPush")
	defer trace.Finish()

	fmt.Println("processing")
	time.Sleep(30 * time.Second)
	fmt.Println("done")
	return nil
}

Register in module

package examplemodule

import (

	"example.service/internal/modules/examplemodule/delivery/workerhandler"

	"pkg.agungdwiprasetyo.com/candi/codebase/factory/dependency"
	"pkg.agungdwiprasetyo.com/candi/codebase/factory/types"
	"pkg.agungdwiprasetyo.com/candi/codebase/interfaces"
)

type Module struct {
	// ...another delivery handler
	workerHandlers map[types.Worker]interfaces.WorkerHandler
}

func NewModules(deps dependency.Dependency) *Module {
	return &Module{
		workerHandlers: map[types.Worker]interfaces.WorkerHandler{
			// ...another worker handler
			// ...
			types.Scheduler: workerhandler.NewCronHandler(),
		},
	}
}

// ...another method

Documentation

Index

• func AddJob(job Job) error
• func NewWorker(service factory.ServiceFactory) factory.AppServerFactory
• func UpdateIntervalActiveJob(jobNumber int, newInterval string) (err error)
• type Job
  • func GetActiveJobs() []*Job

Functions

func AddJob

func AddJob(job Job) error

AddJob to cron worker

func NewWorker

func NewWorker(service factory.ServiceFactory) factory.AppServerFactory

NewWorker create new cron worker

func UpdateIntervalActiveJob

func UpdateIntervalActiveJob(jobNumber int, newInterval string) (err error)

UpdateIntervalActiveJob update active job

Types

type Job

type Job struct {
	HandlerName string                  `json:"handler_name"`
	Interval    string                  `json:"interval"`
	HandlerFunc types.WorkerHandlerFunc `json:"-"`
	Params      string                  `json:"params"`
	WorkerIndex int                     `json:"worker_index"`
	// contains filtered or unexported fields
}

Job model

func GetActiveJobs

func GetActiveJobs() []*Job

GetActiveJobs get registered jobs