timestamp

Oct 7, 2024

Changes in this version

type Scheduler

+ func (s *Scheduler) Metrics() map[string]*SchedulerMetrics

+ type SchedulerMetrics struct

+ TotalJobsFinished atomic.Uint64

+ TotalJobsStarted atomic.Uint64

+ TotalTaskLatencyInNanoseconds atomic.Int64

+ TotalTasksFinished atomic.Uint64

+ TotalTasksPanic atomic.Uint64

+ TotalTasksStarted atomic.Uint64

May 30, 2024

Changes in this version

+ func Find(timestamps []int64, target int64) int

May 9, 2024

Changes in this version

+ func FindRange(timestamps []int64, min, max int64) (int, int, bool)

type TimeRange

+ func (t TimeRange) Before(other time.Time) bool

Feb 6, 2023

Changes in this version

+ var ErrSchedulerClosed = errors.New("the scheduler is closed")

+ var ErrTaskDuplicated = errors.New("the task is duplicated")

+ type Scheduler struct

+ func NewScheduler(parent *logger.Logger, clock Clock) *Scheduler

+ func (s *Scheduler) Close()

+ func (s *Scheduler) Closed() bool

+ func (s *Scheduler) Register(name string, options cron.ParseOption, expr string, action SchedulerAction) error

+ func (s *Scheduler) Trigger(name string) bool

+ type SchedulerAction func(now time.Time, logger *logger.Logger) bool

Nov 5, 2022

Changes in this version

type MockClock

+ TriggerTimer func() bool

type TimeRange

+ func NewSectionTimeRange(start, end time.Time) TimeRange

Jun 2, 2022

Changes in this version

+ const MaxNanoTime

+ const MinNanoTime

+ var DefaultBeginPbTime = timestamppb.New(time.Unix(0, 0))

+ var DefaultTimeRange = &modelv1.TimeRange

+ var ErrTimeEmpty = errors.Errorf("time is empty")

+ var ErrTimeNotMillisecond = errors.Errorf("time is not millisecond precision")

+ var ErrTimeOutOfRange = errors.Errorf("time is out of range %d - %d", MinNanoTime, MaxNanoTime)

+ var MaxMilliPbTime = timestamppb.New(MaxMilliTime)

+ var MaxMilliTime = time.UnixMilli(maxNanoTime.UnixMilli())

+ func Check(t time.Time) error

+ func CheckPb(t *timestamppb.Timestamp) error

+ func CheckTimeRange(timeRange *modelv1.TimeRange) error

+ func MToN(ms time.Time) time.Time

+ func NowMilli() time.Time

+ func ParseDuration(s string) (time.Duration, error)

+ func SetClock(ctx context.Context, clock Clock) context.Context

+ type Clock interface

+ func GetClock(ctx context.Context) (Clock, context.Context)

+ func NewClock() Clock

+ type MockClock interface

+ Add func(d time.Duration)

+ Set func(t time.Time)

+ func NewMockClock() MockClock

+ type TimeRange struct

+ End time.Time

+ IncludeEnd bool

+ IncludeStart bool

+ Start time.Time

+ func NewInclusiveTimeRange(start, end time.Time) TimeRange

+ func NewInclusiveTimeRangeDuration(start time.Time, duration time.Duration) TimeRange

+ func NewTimeRange(start, end time.Time, includeStart, includeEnd bool) TimeRange

+ func NewTimeRangeDuration(start time.Time, duration time.Duration, includeStart, includeEnd bool) TimeRange

+ func (t TimeRange) Contains(unixNano uint64) bool

+ func (t TimeRange) Duration() time.Duration

+ func (t TimeRange) Overlapping(other TimeRange) bool

+ func (t TimeRange) String() string