repositories

Documentation

Index

• type JobRepository
  • func NewJobRepository(logger *zap.Logger, client *clientv3.Client) JobRepository

Types

type JobRepository

type JobRepository interface {
	List(ctx context.Context) ([]*model.Job, error)
	Save(ctx context.Context, job *model.Job) (*model.Job, error)
	Delete(ctx context.Context, name string) (*model.Job, error)
	Kill(ctx context.Context, name string) error
}

func NewJobRepository

func NewJobRepository(logger *zap.Logger, client *clientv3.Client) JobRepository