Versions in this module Expand all Collapse all v0 v0.1.0 Mar 19, 2022 Changes in this version + type Body string + func (b Body) IsEmpty() bool + type Delay time.Duration + func (d Delay) IsEmpty() bool + type Empty interface + IsEmpty func() bool + type ID string + func (id ID) IsEmpty() bool + type Job struct + Body Body + Delay Delay + ID ID + Mutex lock.Locker + TTR TTR + Topic Topic + Version Version + func Get(topic Topic, id ID, lockerFunc lock.LockerFunc) (*Job, error) + func New(topic Topic, id ID, delay Delay, ttr TTR, body Body, ...) (*Job, error) + func (j *Job) GetDelayTimeFromNow() time.Time + func (j *Job) GetName() string + func (j *Job) GetNameWithVersion() NameVersion + func (j *Job) GetTTRTimeFromNow() time.Time + func (j *Job) IsValid() error + func (j *Job) IsVersionSame(v Version) bool + func (j *Job) Lock() error + func (j *Job) SetVersion(ts int64) + func (j *Job) Unlock() (bool, error) + type NameVersion string + func NewNameVersion(topic Topic, id ID, version Version) NameVersion + func NewNameVersionString(str string) NameVersion + func (nv NameVersion) MarshalBinary() ([]byte, error) + func (nv NameVersion) Parse() (Topic, ID, Version, error) + type TTR time.Duration + func (t TTR) IsEmpty() bool + type Topic string + func (t Topic) IsEmpty() bool + type Version struct + func LoadVersion(vs string) (Version, error) + func NewVersion() Version + func (v *Version) UnmarshalJSON(b []byte) error + func (v Version) Equal(v2 Version) bool + func (v Version) MarshalJSON() ([]byte, error) + func (v Version) String() string + func (v Version) UInt64() uint64 v0.1.0-beta Jul 14, 2021
Go to main page