cronsvc

README

cronsvc

This example illustrates how to generate code for Cron jobs.

Generate the code

$ go generate

Test the code

$ go run cmd/main.go
2022/10/09 11:06:12 Sending an email
2022/10/09 11:06:17 Sending an email
2022/10/09 11:06:22 Sending an email

Documentation

Index

• func MakeEndpointOfSendEmail(s Service) endpoint.Endpoint
• func NewCronJobs(svc Service) []micron.Job
• type Handler
  • func (h *Handler) SendEmail(ctx context.Context) error
• type SendEmailResponse
  • func (r *SendEmailResponse) Body() interface{}
  • func (r *SendEmailResponse) Failed() error
• type Service

Functions

func MakeEndpointOfSendEmail

func MakeEndpointOfSendEmail(s Service) endpoint.Endpoint

MakeEndpointOfSendEmail creates the endpoint for s.SendEmail.

func NewCronJobs

func NewCronJobs(svc Service) []micron.Job

Types

type Handler

type Handler struct{}

func (*Handler) SendEmail

func (h *Handler) SendEmail(ctx context.Context) error

type SendEmailResponse

type SendEmailResponse struct {
	Err error `json:"-"`
}

func (*SendEmailResponse) Body

func (r *SendEmailResponse) Body() interface{}

func (*SendEmailResponse) Failed

func (r *SendEmailResponse) Failed() error

Failed implements endpoint.Failer.

type Service

type Service interface {
	//kun:cron expr='@every 5s'
	SendEmail(ctx context.Context) error
}

Service is used for handling cron jobs.