Documentation
¶
Index ¶
- Variables
- func ByteSliceHasAnyPrefix(s []byte, prefixes ...string) bool
- func CheckClockSync(ntpHost string, driftThreshold time.Duration) (bool, error)
- func IsNumber(s []byte) bool
- func SanitizeError(err error) error
- func SanitizeString(str string) string
- func SuppressCancellation(ctx context.Context) context.Context
- func UnquoteBytes(s []byte) []byte
- type CountingWriter
- type ManualTicker
- type Ticker
- type TickerFactory
- type TickerFactoryFunc
Constants ¶
This section is empty.
Variables ¶
var MaxCommitOrTagMessageSize = 10 * 1024
MaxCommitOrTagMessageSize is the threshold for a commit/tag message, if exceeded then message is truncated and it's up to the client to request it in full separately.
Functions ¶
func ByteSliceHasAnyPrefix ¶
ByteSliceHasAnyPrefix tests whether the byte slice s begins with any of the prefixes.
func CheckClockSync ¶
CheckClockSync checks if machine clock has allowed drift threshold compare to NTP service. ntpHost is a URL of the NTP service to query, if not set the default pool.ntp.org is used. driftThreshold is a time duration that is considered acceptable time offset.
func SanitizeError ¶
SanitizeError does the same thing as SanitizeString but for error types
func SanitizeString ¶
SanitizeString will clean password and tokens from URLs, and replace them with [FILTERED].
func SuppressCancellation ¶
SuppressCancellation returns a context that suppresses cancellation or expiration of the parent context.
func UnquoteBytes ¶
UnquoteBytes removes surrounding double-quotes from a byte slice returning a new slice if they exist, otherwise it returns the same byte slice passed.
Types ¶
type CountingWriter ¶
CountingWriter wraps an io.Writer and counts all the writes. Accessing the count N is not thread-safe.
type ManualTicker ¶
type ManualTicker struct {
StopFunc func()
ResetFunc func()
// contains filtered or unexported fields
}
ManualTicker implements a ticker that ticks when Tick is called. Stop and Reset functions call the provided functions.
func NewCountTicker ¶
func NewCountTicker(n int, callback func()) *ManualTicker
NewCountTicker returns a ManualTicker with a ResetFunc that calls the provided callback on Reset call after it has been called N times.
func NewManualTicker ¶
func NewManualTicker() *ManualTicker
NewManualTicker returns a Ticker that can be manually controlled.
func (*ManualTicker) C ¶
func (mt *ManualTicker) C() <-chan time.Time
func (*ManualTicker) Reset ¶
func (mt *ManualTicker) Reset()
func (*ManualTicker) Stop ¶
func (mt *ManualTicker) Stop()
func (*ManualTicker) Tick ¶
func (mt *ManualTicker) Tick()
type Ticker ¶
Ticker ticks on the channel returned by C to signal something.
func NewTimerTicker ¶
NewTimerTicker returns a Ticker that ticks after the specified interval has passed since the previous Reset call.
type TickerFactory ¶ added in v16.6.0
type TickerFactory interface {
// NewTicker returns a new Ticker.
NewTicker() Ticker
}
TickerFactory constructs a new ticker.
func NewNullTickerFactory ¶ added in v16.6.0
func NewNullTickerFactory() TickerFactory
NewNullTickerFactory returns new tickers that don't tick.
func NewTimerTickerFactory ¶ added in v16.6.0
func NewTimerTickerFactory(interval time.Duration) TickerFactory
NewTimerTickerFactory returns new tickers that tick after the given interval.
type TickerFactoryFunc ¶ added in v16.6.0
type TickerFactoryFunc func() Ticker
TickerFactoryFunc is a function that implements TickerFactory
func (TickerFactoryFunc) NewTicker ¶ added in v16.6.0
func (fn TickerFactoryFunc) NewTicker() Ticker
NewTicker returns a new ticker.
Source Files
Directories