-
Notifications
You must be signed in to change notification settings - Fork 0
/
unixmsec.go
61 lines (51 loc) · 1.52 KB
/
unixmsec.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
package timehelper
import (
"strconv"
"time"
)
// UnixMsec is a helper type to marshal/unmarshal [time.Time] as a Unix time in milliseconds.
type UnixMsec time.Time
// String returns decimal string representation of 't'.
// String implements the [fmt.Stringer] interface.
func (t UnixMsec) String() string {
return strconv.FormatInt(time.Time(t).UnixMilli(), 10)
}
// MarshalText implements the [encoding.TextMarshaler] interface.
func (t UnixMsec) MarshalText() ([]byte, error) {
return []byte(t.String()), nil
}
// used for testing
func unmarshalMsec(s string) (*UnixMsec, error) {
msec, err := strconv.ParseInt(s, 0, 64)
if err != nil {
return nil, err
}
ut := UnixMsec(time.UnixMilli(msec).In(time.UTC))
return &ut, nil
}
// UnmarshalText implements the [encoding.TextUnmarshaler] interface.
// Time zone of the unmarshaled value is [time.UTC].
func (t *UnixMsec) UnmarshalText(text []byte) error {
ut, err := unmarshalMsec(string(text))
if err != nil {
return err
}
*t = *ut
return nil
}
// used for testing
func parseMsec(msec int64) UnixMsec {
return UnixMsec(time.UnixMilli(msec).In(time.UTC))
}
// ParseMSecs parses milliseconds to UnixMsec.
func (t *UnixMsec) ParseMSecs(msec int64) {
*t = parseMsec(msec)
}
// MarshalJSON implements the [encoding/json.Marshaler] interface.
func (t UnixMsec) MarshalJSON() ([]byte, error) {
return []byte(t.String()), nil
}
// UnmarshalJSON implements the [encoding/json.Unmarshaler] interface.
func (t *UnixMsec) UnmarshalJSON(bb []byte) error {
return t.UnmarshalText(bb)
}