cron

Documentation

Index

• Variables

Variables

var (
	Cmd = &cobra.Command{
		Use:           "cron",
		Short:         "Delete subscription cron job",
		SilenceUsage:  true,
		SilenceErrors: true,
		Run: func(_ *cobra.Command, _ []string) {
			var (
				c         func()
				e         error
				ctxAll    context.Context
				ctxCancel context.CancelFunc
				cron      *cron.Cron
			)
			defer func() {
				if c != nil {
					c()
				}
			}()
			cmd.Slave.Executor(func(ctx context.Context) error {
				initial, _ := entrypoint.CtxExtractInitial(ctx)
				ctxAll, ctxCancel = context.WithCancel(ctx)

				cron, c, e = daemon.BuildCron(ctxAll, initial, cmd.Observer)
				if e != nil {
					return e
				}
				return nil
			}, func(ctx context.Context) error {
				if err := cron.DeleteSubscriptions(ctxAll); err != nil {
					e = err
					ctxCancel()
				}
				return e
			})
		},
	}
)