crontab

README

Crontab

Example

package main

import (
	"context"

	"github.com/flc1125/go-cron/v4"
	"github.com/go-kratos-ecosystem/components/v2/crontab"
	"github.com/go-kratos/kratos/v2"
)

func main() {
	c := cron.New(
		cron.WithSeconds(),
		cron.WithMiddleware( /*...*/ ),
	)

	_, _ = c.AddFunc("* * * * * *", func(context.Context) error {
		// do something
		return nil
	})

	// kratos app start
	app := kratos.New(
		kratos.Server(
			crontab.NewServer(c),
		),
	)

	err := app.Run()
	if err != nil {
		panic(err)
	}
}

Documentation

Overview

Example

c := cron.New(
	cron.WithSeconds(),
	cron.WithMiddleware( /*...*/ ),
)

_, _ = c.AddFunc("* * * * * *", func(context.Context) error {
	// do something
	return nil
})

// kratos app start
app := kratos.New(
	kratos.Server(
		crontab.NewServer(c),
	),
)

err := app.Run()
if err != nil {
	panic(err)
}

Index

• type Logger
  • func NewLogger(logger log.Logger) *Logger
  • func (l *Logger) Printf(format string, v ...any)
• type Server
  • func NewServer(c *cron.Cron) *Server
  • func (s *Server) Start(context.Context) error
  • func (s *Server) Stop(ctx context.Context) error

Examples

• Package

Types

type Logger

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

func NewLogger

func NewLogger(logger log.Logger) *Logger

func (*Logger) Printf

func (l *Logger) Printf(format string, v ...any)

type Server

type Server struct {
	*cron.Cron
}

func NewServer

func NewServer(c *cron.Cron) *Server

func (*Server) Start

func (s *Server) Start(context.Context) error

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) error