scheduler

Documentation

Index

• Constants
• func ByteCountIEC(b int64) string
• func NewGCUpdate(logger *zap.SugaredLogger, gc *server.GarbageCollector) schedulable
• func NewStatisticsUpdater(logger *zap.SugaredLogger, store store.BadgerStore) schedulable
• type RunResult
• type Scheduler
  • func NewScheduler(logger *zap.SugaredLogger, gc *server.GarbageCollector, ...) *Scheduler
  • func (s *Scheduler) Start() error
  • func (s *Scheduler) Stop(ctx context.Context)
• type Statistics
  • func (stats *Statistics) Count(ctx context.Context) map[string]any
  • func (stats *Statistics) Stop(ctx context.Context) error

Constants

const (
	// RunResultFailed is the state of a failed run
	RunResultFailed = "failed"
	// RunResultSuccess is the state of a successful run
	RunResultSuccess = "success"

	TaskStateRunning   = "running"
	TaskStateScheduled = "scheduled"
)

const (
	URI_TO_ID_INDEX_ID         uint16 = 0
	ENTITY_ID_TO_JSON_INDEX_ID uint16 = 1
	INCOMING_REF_INDEX         uint16 = 2
	OUTGOING_REF_INDEX         uint16 = 3
	DATASET_ENTITY_CHANGE_LOG  uint16 = 4
	SYS_DATASETS_ID            uint16 = 5
	SYS_JOBS_ID                uint16 = 6
	SYS_DATASETS_SEQUENCES     uint16 = 7
	DATASET_LATEST_ENTITIES    uint16 = 8
	ID_TO_URI_INDEX_ID         uint16 = 9

	STORE_META_INDEX      uint16 = 10
	NAMESPACES_INDEX      uint16 = 11
	JOB_RESULT_INDEX      uint16 = 12
	JOB_DATA_INDEX        uint16 = 13
	JOB_CONFIGS_INDEX     uint16 = 14
	CONTENT_INDEX         uint16 = 15
	STORE_NEXT_DATASET_ID uint16 = 16
	LOGIN_PROVIDER_INDEX  uint16 = 17
)

Functions

func ByteCountIEC

func ByteCountIEC(b int64) string

func NewGCUpdate

func NewGCUpdate(logger *zap.SugaredLogger, gc *server.GarbageCollector) schedulable

func NewStatisticsUpdater

func NewStatisticsUpdater(logger *zap.SugaredLogger, store store.BadgerStore) schedulable

Types

type RunResult

type RunResult struct {
	// contains filtered or unexported fields
}

type Scheduler

type Scheduler struct {
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(logger *zap.SugaredLogger, gc *server.GarbageCollector, store store.BadgerStore) *Scheduler

func (*Scheduler) Start

func (s *Scheduler) Start() error

func (*Scheduler) Stop

func (s *Scheduler) Stop(ctx context.Context)

type Statistics

type Statistics struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func (*Statistics) Count

func (stats *Statistics) Count(ctx context.Context) map[string]any

func (*Statistics) Stop

func (stats *Statistics) Stop(ctx context.Context) error