Documentation ¶
Index ¶
- Constants
- type Spanner
- func (s *Spanner) BatchAddJobs(ctx context.Context, poolName string, jobs []engine.Job) (err error)
- func (s *Spanner) BatchGetJobsByID(ctx context.Context, IDs []string) (jobs []engine.Job, err error)
- func (s *Spanner) Close()
- func (s *Spanner) DelJobs(ctx context.Context, jobIDs []string) (count int64, err error)
- func (s *Spanner) GetQueueSize(ctx context.Context, req []*model.DBJobReq) (count map[string]int64, err error)
- func (s *Spanner) GetReadyJobs(ctx context.Context, req *model.DBJobReq) (jobs []engine.Job, err error)
Constants ¶
View Source
const (
MaxJobBatchSize = 1000
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Spanner ¶
type Spanner struct {
// contains filtered or unexported fields
}
func NewSpanner ¶
func NewSpanner(cfg *config.SpannerConfig) (*Spanner, error)
func (*Spanner) BatchAddJobs ¶
BatchAddJobs write jobs data into secondary storage
func (*Spanner) BatchGetJobsByID ¶
func (s *Spanner) BatchGetJobsByID(ctx context.Context, IDs []string) (jobs []engine.Job, err error)
BatchGetJobsByID returns job data by job ID
Click to show internal directories.
Click to hide internal directories.