Versions in this module Expand all Collapse all v1 v1.1.1 Oct 30, 2021 v1.1.0 Oct 25, 2021 Changes in this version + func InitEvent(dis event.Dispatcher) queue.InitFunc + type Event struct + Action string + Cron *Cron + func (ev *Event) Name() string + func (ev *Event) Perform() error type Schedule + func (s *Schedule) UnmarshalJSON(b []byte) error v1.0.0 Apr 20, 2021 Changes in this version + func LoadRelations(loaders *database.Loaders, cc ...*Cron) error + func Model(cc []*Cron) func(int) database.Model + func SelectBuild(col string, opts ...query.Option) query.Query + type Batcher struct + func NewBatcher(db *sqlx.DB, hasher *crypto.Hasher, limit int64, errh func(error)) *Batcher + func (b *Batcher) Batch() []*Cron + func (b *Batcher) Err() error + func (b *Batcher) Invoke(ctx context.Context, producers map[string]*curlyq.Producer) int + func (b *Batcher) Load() bool + type Build struct + Build *build.Build + BuildID int64 + CreatedAt time.Time + Cron *Cron + CronID int64 + ID int64 + func (b *Build) Bind(mm ...database.Model) + func (b *Build) Endpoint(uri ...string) string + func (b *Build) IsZero() bool + func (b *Build) JSON(addr string) map[string]interface{} + func (b *Build) Primary() (string, int64) + func (b *Build) SetPrimary(_ int64) + func (b *Build) Values() map[string]interface{} + type BuildStore struct + Build *build.Build + Cron *Cron + func NewBuildStore(db *sqlx.DB, mm ...database.Model) *BuildStore + func (s *BuildStore) Bind(mm ...database.Model) + type Cron struct + Author *user.User + AuthorID int64 + CreatedAt time.Time + ID int64 + Manifest manifest.Manifest + Name string + Namespace *namespace.Namespace + NamespaceID sql.NullInt64 + NextRun time.Time + PrevRun sql.NullTime + Schedule Schedule + User *user.User + UserID int64 + func FromContext(ctx context.Context) (*Cron, bool) + func (c *Cron) Bind(mm ...database.Model) + func (c *Cron) Endpoint(uri ...string) string + func (c *Cron) IsZero() bool + func (c *Cron) JSON(addr string) map[string]interface{} + func (c *Cron) Primary() (string, int64) + func (c *Cron) SetPrimary(id int64) + func (c *Cron) Values() map[string]interface{} + type Form struct + Cron *Cron + Crons *Store + Manifest manifest.Manifest + Name string + Schedule Schedule + func (f Form) Fields() map[string]string + func (f Form) Validate() error + type Schedule uint + const Daily + const Monthly + const Weekly + func (i Schedule) String() string + func (s *Schedule) Next() time.Time + func (s *Schedule) Scan(val interface{}) error + func (s *Schedule) UnmarshalText(b []byte) error + func (s Schedule) Value() (driver.Value, error) + type Store struct + Namespace *namespace.Namespace + User *user.User + func NewStore(db *sqlx.DB, mm ...database.Model) *Store + func (s *Store) All(opts ...query.Option) ([]*Cron, error) + func (s *Store) Bind(mm ...database.Model) + func (s *Store) Create(authorId int64, name string, sched Schedule, m manifest.Manifest) (*Cron, error) + func (s *Store) Delete(id int64) error + func (s *Store) Get(opts ...query.Option) (*Cron, error) + func (s *Store) Index(vals url.Values, opts ...query.Option) ([]*Cron, database.Paginator, error) + func (s *Store) Invoke(c *Cron) (*build.Build, error) + func (s *Store) Load(key string, vals []interface{}, load database.LoaderFunc) error + func (s *Store) New() *Cron + func (s *Store) Paginate(page, limit int64, opts ...query.Option) (database.Paginator, error) + func (s *Store) Update(id int64, name string, sched Schedule, m manifest.Manifest) error
Go to main page