Versions in this module Expand all Collapse all v0 v0.0.2 Mar 20, 2022 v0.0.1 Mar 18, 2022 Changes in this version + var ErrIntOverflowLegacyTimestamp = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowTimestamp = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthLegacyTimestamp = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthTimestamp = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupLegacyTimestamp = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupTimestamp = fmt.Errorf("proto: unexpected end of group") + var MaxClockTimestamp = ClockTimestamp + var MaxTimestamp = Timestamp + var MinClockTimestamp = ClockTimestamp + var MinTimestamp = Timestamp + func IsUntrustworthyRemoteWallTimeError(err error) bool + func UnixNano() int64 + type Clock struct + func NewClock(physicalClock func() int64, maxOffset time.Duration) *Clock + func (c *Clock) MaxOffset() time.Duration + func (c *Clock) Now() Timestamp + func (c *Clock) NowAsClockTimestamp() ClockTimestamp + func (c *Clock) PhysicalNow() int64 + func (c *Clock) PhysicalTime() time.Time + func (c *Clock) RefreshHLCUpperBound(persistFn func(int64) error, delta int64) error + func (c *Clock) ResetHLCUpperBound(persistFn func(int64) error) error + func (c *Clock) SleepUntil(ctx context.Context, t Timestamp) error + func (c *Clock) StartMonitoringForwardClockJumps(ctx context.Context, forwardClockJumpCheckEnabledCh <-chan bool, ...) error + func (c *Clock) Update(rt ClockTimestamp) + func (c *Clock) UpdateAndCheckMaxOffset(ctx context.Context, rt ClockTimestamp) error + func (c *Clock) WallTimeUpperBound() int64 + type ClockSource struct + func MakeClockSource(_ context.Context, _ string) (ClockSource, error) + func MakeClockSource(ctx context.Context, clockDevicePath string) (ClockSource, error) + func (p ClockSource) UnixNano() int64 + type ClockTimestamp Timestamp + func NewPopulatedClockTimestamp(r randyTimestamp, easy bool) *ClockTimestamp + func (t *ClockTimestamp) Backward(s ClockTimestamp) + func (t *ClockTimestamp) BackwardWithTimestamp(s Timestamp) + func (t *ClockTimestamp) Equal(that interface{}) bool + func (t *ClockTimestamp) Forward(s ClockTimestamp) bool + func (t *ClockTimestamp) MarshalTo(data []byte) (int, error) + func (t *ClockTimestamp) MarshalToSizedBuffer(data []byte) (int, error) + func (t *ClockTimestamp) ProtoMessage() + func (t *ClockTimestamp) Reset() + func (t *ClockTimestamp) Size() int + func (t *ClockTimestamp) Unmarshal(data []byte) error + func (t ClockTimestamp) IsEmpty() bool + func (t ClockTimestamp) Less(s ClockTimestamp) bool + func (t ClockTimestamp) LessEq(s ClockTimestamp) bool + func (t ClockTimestamp) SafeValue() + func (t ClockTimestamp) String() string + func (t ClockTimestamp) ToTimestamp() Timestamp + type HybridManualClock struct + func NewHybridManualClock() *HybridManualClock + func (m *HybridManualClock) Forward(tsNanos int64) + func (m *HybridManualClock) Increment(nanos int64) + func (m *HybridManualClock) Pause() + func (m *HybridManualClock) Resume() + func (m *HybridManualClock) UnixNano() int64 + type LegacyTimestamp struct + Logical int32 + Synthetic *bool + WallTime int64 + func NewPopulatedLegacyTimestamp(r randyLegacyTimestamp, easy bool) *LegacyTimestamp + func (*LegacyTimestamp) Descriptor() ([]byte, []int) + func (*LegacyTimestamp) ProtoMessage() + func (LegacyTimestamp) SafeValue() + func (m *LegacyTimestamp) Marshal() (dAtA []byte, err error) + func (m *LegacyTimestamp) MarshalTo(dAtA []byte) (int, error) + func (m *LegacyTimestamp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LegacyTimestamp) Reset() + func (m *LegacyTimestamp) Size() (n int) + func (m *LegacyTimestamp) Unmarshal(dAtA []byte) error + func (m *LegacyTimestamp) XXX_DiscardUnknown() + func (m *LegacyTimestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LegacyTimestamp) XXX_Merge(src proto.Message) + func (m *LegacyTimestamp) XXX_Size() int + func (m *LegacyTimestamp) XXX_Unmarshal(b []byte) error + func (t LegacyTimestamp) EqOrdering(s LegacyTimestamp) bool + func (t LegacyTimestamp) Less(s LegacyTimestamp) bool + func (t LegacyTimestamp) String() string + func (t LegacyTimestamp) ToTimestamp() Timestamp + func (this *LegacyTimestamp) Equal(that interface{}) bool + type ManualClock struct + func NewManualClock(nanos int64) *ManualClock + func (m *ManualClock) Increment(incr int64) + func (m *ManualClock) Set(nanos int64) + func (m *ManualClock) UnixNano() int64 + type Timestamp struct + Logical int32 + Synthetic bool + WallTime int64 + func NewPopulatedTimestamp(r randyTimestamp, easy bool) *Timestamp + func ParseTimestamp(str string) (_ Timestamp, err error) + func (*Timestamp) Descriptor() ([]byte, []int) + func (*Timestamp) ProtoMessage() + func (Timestamp) SafeValue() + func (m *Timestamp) Marshal() (dAtA []byte, err error) + func (m *Timestamp) MarshalTo(dAtA []byte) (int, error) + func (m *Timestamp) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Timestamp) Reset() + func (m *Timestamp) Size() (n int) + func (m *Timestamp) Unmarshal(dAtA []byte) error + func (m *Timestamp) XXX_DiscardUnknown() + func (m *Timestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Timestamp) XXX_Merge(src proto.Message) + func (m *Timestamp) XXX_Size() int + func (m *Timestamp) XXX_Unmarshal(b []byte) error + func (t *Timestamp) Backward(s Timestamp) + func (t *Timestamp) Forward(s Timestamp) bool + func (t Timestamp) Add(wallTime int64, logical int32) Timestamp + func (t Timestamp) AsOfSystemTime() string + func (t Timestamp) Clone() *Timestamp + func (t Timestamp) Compare(s Timestamp) int + func (t Timestamp) EqOrdering(s Timestamp) bool + func (t Timestamp) FloorPrev() Timestamp + func (t Timestamp) GoTime() time.Time + func (t Timestamp) IsEmpty() bool + func (t Timestamp) IsSet() bool + func (t Timestamp) Less(s Timestamp) bool + func (t Timestamp) LessEq(s Timestamp) bool + func (t Timestamp) Next() Timestamp + func (t Timestamp) Prev() Timestamp + func (t Timestamp) String() string + func (t Timestamp) ToLegacyTimestamp() LegacyTimestamp + func (t Timestamp) TryToClockTimestamp() (ClockTimestamp, bool) + func (t Timestamp) UnsafeToClockTimestamp() ClockTimestamp + func (t Timestamp) WallPrev() Timestamp + func (t Timestamp) WithSynthetic(val bool) Timestamp + func (this *Timestamp) Equal(that interface{}) bool