fsatomic

Documentation

Index

• type Error
• type ErrorCounter
  • func (ec *ErrorCounter) AddError(err error)
  • func (ec *ErrorCounter) AddFail() int64
  • func (ec *ErrorCounter) AddFailN(delta int64) int64
  • func (ec *ErrorCounter) AddSuccess() int64
  • func (ec *ErrorCounter) AddSuccessN(delta int64) int64
  • func (ec *ErrorCounter) Fail() int64
  • func (ec *ErrorCounter) Success() int64
• type NumberInt32
  • func (n *NumberInt32[T]) Add(v T)
  • func (n *NumberInt32[T]) CompareAndSwap(old T, new T) (swapped bool)
  • func (n *NumberInt32[T]) Load() T
  • func (n *NumberInt32[T]) Store(v T)
  • func (n *NumberInt32[T]) Swap(v T) (old T)
• type NumberInt64
  • func (n *NumberInt64[T]) Add(v T)
  • func (n *NumberInt64[T]) CompareAndSwap(old T, new T) (swapped bool)
  • func (n *NumberInt64[T]) Load() T
  • func (n *NumberInt64[T]) Store(v T)
  • func (n *NumberInt64[T]) Swap(v T) (old T)
• type NumberUint32
  • func (n *NumberUint32[T]) Add(v T)
  • func (n *NumberUint32[T]) CompareAndSwap(old T, new T) (swapped bool)
  • func (n *NumberUint32[T]) Load() T
  • func (n *NumberUint32[T]) Store(v T)
  • func (n *NumberUint32[T]) Swap(v T) (old T)
• type NumberUint64
  • func (n *NumberUint64[T]) Add(v T)
  • func (n *NumberUint64[T]) CompareAndSwap(old T, new T) (swapped bool)
  • func (n *NumberUint64[T]) Load() T
  • func (n *NumberUint64[T]) Store(v T)
  • func (n *NumberUint64[T]) Swap(v T) (old T)
• type String
• type TimeDuration
• type TimeStamp
  • func (at *TimeStamp) After(n time.Time) bool
  • func (at *TimeStamp) Before(n time.Time) bool
  • func (at *TimeStamp) Load() time.Time
  • func (at *TimeStamp) Since(n time.Time) time.Duration
  • func (at *TimeStamp) Store(n time.Time)
  • func (at *TimeStamp) Sub(n time.Time) time.Duration
• type Value
  • func (a *Value[T]) CompareAndSwap(old, new T) (swapped bool)
  • func (a *Value[T]) Load() T
  • func (a *Value[T]) Store(v T)
  • func (a *Value[T]) Swap(v T) T

Types

type Error

type Error = Value[error]

type ErrorCounter

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

ErrorCounter 统计成功失败次数

func (*ErrorCounter) AddError

func (ec *ErrorCounter) AddError(err error)

func (*ErrorCounter) AddFail

func (ec *ErrorCounter) AddFail() int64

func (*ErrorCounter) AddFailN

func (ec *ErrorCounter) AddFailN(delta int64) int64

func (*ErrorCounter) AddSuccess

func (ec *ErrorCounter) AddSuccess() int64

func (*ErrorCounter) AddSuccessN

func (ec *ErrorCounter) AddSuccessN(delta int64) int64

func (*ErrorCounter) Fail

func (ec *ErrorCounter) Fail() int64

func (*ErrorCounter) Success

func (ec *ErrorCounter) Success() int64

type NumberInt32

type NumberInt32[T ~int32] int32

func (*NumberInt32[T]) Add

func (n *NumberInt32[T]) Add(v T)

func (*NumberInt32[T]) CompareAndSwap

func (n *NumberInt32[T]) CompareAndSwap(old T, new T) (swapped bool)

func (*NumberInt32[T]) Load

func (n *NumberInt32[T]) Load() T

func (*NumberInt32[T]) Store

func (n *NumberInt32[T]) Store(v T)

func (*NumberInt32[T]) Swap

func (n *NumberInt32[T]) Swap(v T) (old T)

type NumberInt64

type NumberInt64[T ~int64] int64

func (*NumberInt64[T]) Add

func (n *NumberInt64[T]) Add(v T)

func (*NumberInt64[T]) CompareAndSwap

func (n *NumberInt64[T]) CompareAndSwap(old T, new T) (swapped bool)

func (*NumberInt64[T]) Load

func (n *NumberInt64[T]) Load() T

func (*NumberInt64[T]) Store

func (n *NumberInt64[T]) Store(v T)

func (*NumberInt64[T]) Swap

func (n *NumberInt64[T]) Swap(v T) (old T)

type NumberUint32

type NumberUint32[T ~uint32] uint32

func (*NumberUint32[T]) Add

func (n *NumberUint32[T]) Add(v T)

func (*NumberUint32[T]) CompareAndSwap

func (n *NumberUint32[T]) CompareAndSwap(old T, new T) (swapped bool)

func (*NumberUint32[T]) Load

func (n *NumberUint32[T]) Load() T

func (*NumberUint32[T]) Store

func (n *NumberUint32[T]) Store(v T)

func (*NumberUint32[T]) Swap

func (n *NumberUint32[T]) Swap(v T) (old T)

type NumberUint64

type NumberUint64[T ~uint64] uint64

func (*NumberUint64[T]) Add

func (n *NumberUint64[T]) Add(v T)

func (*NumberUint64[T]) CompareAndSwap

func (n *NumberUint64[T]) CompareAndSwap(old T, new T) (swapped bool)

func (*NumberUint64[T]) Load

func (n *NumberUint64[T]) Load() T

func (*NumberUint64[T]) Store

func (n *NumberUint64[T]) Store(v T)

func (*NumberUint64[T]) Swap

func (n *NumberUint64[T]) Swap(v T) (old T)

type String

type String = Value[string]

type TimeDuration

type TimeDuration = NumberInt64[time.Duration]

type TimeStamp

type TimeStamp int64

TimeStamp atomic store for time stamp without time Location

func (*TimeStamp) After

func (at *TimeStamp) After(n time.Time) bool

After reports whether the time instant t is after u.

func (*TimeStamp) Before

func (at *TimeStamp) Before(n time.Time) bool

Before reports whether the time instant t is before u.

func (*TimeStamp) Load

func (at *TimeStamp) Load() time.Time

Load atomic load time

func (*TimeStamp) Since

func (at *TimeStamp) Since(n time.Time) time.Duration

Since returns the time elapsed since n.

func (*TimeStamp) Store

func (at *TimeStamp) Store(n time.Time)

Store atomic store time stamp

func (*TimeStamp) Sub

func (at *TimeStamp) Sub(n time.Time) time.Duration

Sub returns the duration t-n

type Value

type Value[T any] struct {
	// contains filtered or unexported fields
}

Value 存储值类型

func (*Value[T]) CompareAndSwap

func (a *Value[T]) CompareAndSwap(old, new T) (swapped bool)

CompareAndSwap atomically compare and swap

func (*Value[T]) Load

func (a *Value[T]) Load() T

Load atomically loads

func (*Value[T]) Store

func (a *Value[T]) Store(v T)

Store atomically store

func (*Value[T]) Swap

func (a *Value[T]) Swap(v T) T

Swap atomically swap