auperiodictask

Documentation

Index

• type Config
  • func CreateDefaultConfig() Config
• type Coordinator
• type PeriodicSingleTaskRunner
  • func NewSingleTaskRunner(ctx context.Context, taskKey string, taskFunc func(context.Context) error, ...) PeriodicSingleTaskRunner

Types

type Config

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

func CreateDefaultConfig

func CreateDefaultConfig() Config

type Coordinator

type Coordinator interface {
	aulocker.Locker

	LastRunTimestamp(
		ctx context.Context,
		key string,
	) (*time.Time, error)

	UpdateLastRunTimestamp(
		ctx context.Context,
		key string,
	) error
}

type PeriodicSingleTaskRunner

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

func NewSingleTaskRunner

func NewSingleTaskRunner(
	ctx context.Context,
	taskKey string,
	taskFunc func(context.Context) error,
	coordinator Coordinator,
	config *Config,
) PeriodicSingleTaskRunner