job

Documentation

Index

• Variables
• type Controller
  • func NewController(s Service) Controller
• type EventHandler
  • func NewEventHandler(s Service, h events.Hub, cronJobLister v1.CronJobLister, ...) EventHandler
• type Job
• type Repository
  • func NewRepository(db *sql.DB) Repository
• type Service
  • func NewService(r Repository) Service
• type Status
  • func (s Status) MarshalJSON() ([]byte, error)

Variables

var (
	ErrAlreadyExists    = errors.New("already exists")
	ErrAlreadyCompleted = errors.New("already completed")
)

Types

type Controller

type Controller interface {
	List(c *gin.Context)
}

func NewController

func NewController(s Service) Controller

type EventHandler

type EventHandler interface {
	OnEventAdd(event *corev1.Event)
	OnCronJobDelete(cronJob *batchv1.CronJob)
}

func NewEventHandler

func NewEventHandler(s Service, h events.Hub, cronJobLister v1.CronJobLister, jobLister v1.JobLister) EventHandler

type Job

type Job struct {
	ID          string     `json:"id"`
	CronJobID   string     `json:"cronJobId"`
	Status      Status     `json:"status"`
	CreatedAt   time.Time  `json:"createdAt"`
	UpdatedAt   time.Time  `json:"updatedAt"`
	CompletedAt *time.Time `json:"completedAt"`
}

type Repository

type Repository interface {
	Add(ctx context.Context, j Job) (bool, error)
	List(ctx context.Context) ([]Job, error)
	CompleteByID(ctx context.Context, id string, s Status, t time.Time) (bool, error)
	DeleteByCronJobID(ctx context.Context, cronJobID string) error
	FindByID(ctx context.Context, id string) (*Job, error)
}

func NewRepository

func NewRepository(db *sql.DB) Repository

type Service

type Service interface {
	Create(ctx context.Context, id string, cronJobID string, t time.Time) (*Job, error)
	Succeed(ctx context.Context, id string, t time.Time) (*Job, error)
	Fail(ctx context.Context, id string, t time.Time) (*Job, error)
	List(ctx context.Context) ([]Job, error)
	Delete(ctx context.Context, cronJobID string) error
}

func NewService

func NewService(r Repository) Service

type Status

type Status int

const (
	Running Status = iota + 1
	Succeeded
	Failed
)

func (Status) MarshalJSON

func (s Status) MarshalJSON() ([]byte, error)