utils

package

v0.0.0-...-d7dfbf7 Latest Latest Go to latest Published: Apr 3, 2024 License: MIT Imports: 27 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

git.gammaspectra.live/P2Pool/p2pool-observer

Documentation ¶

Rendered for

Index ¶

Constants
Variables
func ContextTick(ctx context.Context, d time.Duration) <-chan time.Time
func Debugf(format string, v ...any)
func DecodeBinaryNumber(i string) uint64
func DecodeHexBinaryNumber(i string) string
func EncodeBinaryNumber(n uint64) string
func EncodeHexBinaryNumber(v2 string) string
func EncodeSliceBinaryNumber(dst, src []byte) []byte
func Error(v ...any)
func Errorf(prefix, format string, v ...any)
func Factorial(n uint64) (result uint64)
func Fatalf(format string, v ...any)
func GetOutboundIPv6() ([]netip.Addr, error)
func Keys[M ~map[K]V, K comparable, V any](m M) []K
func Logf(prefix, format string, v ...any)
func MarshalJSON(val any) ([]byte, error)
func MarshalJSONIndent(val any, indent string) ([]byte, error)
func NetIPGetEUI48Information(addr netip.Addr)
func NetIPIsCGNAT(addr netip.Addr) bool
func NewJSONDecoder(reader io.Reader) *gojson.Decoder
func NewJSONEncoder(writer io.Writer) *gojson.Encoder
func Noticef(format string, v ...any)
func NthElementSlice[S ~[]E, E cmp.Ordered](s S, k int)
func NthElementSliceFunc[S ~[]E, E any](s S, cmp func(a, b E) int, k int)
func Panic(v ...any)
func Panicf(format string, v ...any)
func ParseUint64(s []byte) (uint64, error)
func PreviousPowerOfTwo(x uint64) int
func Print(v ...any)
func ProbabilityEffort(effort float64) float64
func ProbabilityMode(i ...float64) (n float64)
func ProbabilityNShares(shares uint64, effort float64) float64
func Shorten(value string, n int) string
func ShortenSlice(value []byte, n int) []byte
func SiUnits(number float64, decimals int) string
func SliceCount[S ~[]E, E any](s S, f func(E) bool) (count int)
func SplitWork(routines int, workSize uint64, ...) bool
func UVarInt64Size[T uint64 | int](v T) (n int)
func UVarInt64SliceSize[T uint64 | int](v []T) (n int)
func UnmarshalJSON(data []byte, val any) error
func XMRUnits(v uint64) string
func XorShift64Star(x uint64) uint64
type Cache
type CircularBuffer
- func NewCircularBuffer[T comparable](size int) *CircularBuffer[T]
- func (b *CircularBuffer[T]) Current() T
- func (b *CircularBuffer[T]) Exists(value T) bool
- func (b *CircularBuffer[T]) Get(index uint32) T
- func (b *CircularBuffer[T]) Push(value T)
- func (b *CircularBuffer[T]) PushUnique(value T) bool
- func (b *CircularBuffer[T]) Replace(value, replace T)
- func (b *CircularBuffer[T]) Reverse()
- func (b *CircularBuffer[T]) Slice() []T
type ExtendedIPFlags
type ExtendedIPNet
- func InterfaceAddrs(ifi *net.Interface) ([]*ExtendedIPNet, error)
- func (n *ExtendedIPNet) String() string
type LRUCache
- func NewLRUCache[K comparable, T any](size int) *LRUCache[K, T]
- func (c *LRUCache[K, T]) Clear()
- func (c *LRUCache[K, T]) Delete(key K)
- func (c *LRUCache[K, T]) Get(key K) (value T, ok bool)
- func (c *LRUCache[K, T]) Set(key K, value T)
- func (c *LRUCache[K, T]) Stats() (hits, misses uint64)
type LimitedByteReader
- func LimitByteReader(r ReaderAndByteReader, n int64) *LimitedByteReader
- func (l *LimitedByteReader) Left() int64
- func (l *LimitedByteReader) Read(p []byte) (n int, err error)
- func (l *LimitedByteReader) ReadByte() (v byte, err error)
type LogLevel
type MapCache
- func NewMapCache[K comparable, T any](preAllocateSize int) *MapCache[K, T]
- func (m *MapCache[K, T]) Clear()
- func (m *MapCache[K, T]) Delete(key K)
- func (m *MapCache[K, T]) Get(key K) (value T, ok bool)
- func (m *MapCache[K, T]) Set(key K, value T)
- func (m *MapCache[K, T]) Stats() (hits, misses uint64)
type ReaderAndByteReader

Constants ¶

View Source

const (
	LogLevelError = LogLevel(1 << iota)
	LogLevelInfo
	LogLevelNotice
	LogLevelDebug
)

View Source

const (
	IFA_F_SECONDARY = 0x01
	IFA_F_TEMPORARY = IFA_F_SECONDARY

	IFA_F_NODAD          = 0x02
	IFA_F_OPTIMISTIC     = 0x04
	IFA_F_DADFAILED      = 0x08
	IFA_F_HOMEADDRESS    = 0x10
	IFA_F_DEPRECATED     = 0x20
	IFA_F_TENTATIVE      = 0x40
	IFA_F_PERMANENT      = 0x80
	IFA_F_MANAGETEMPADDR = 0x100
	IFA_F_NOPREFIXROUTE  = 0x200
	IFA_F_MCAUTOJOIN     = 0x400
)

View Source

const (
	VarIntLen1 uint64 = 1 << ((iota + 1) * 7)
	VarIntLen2
	VarIntLen3
	VarIntLen4
	VarIntLen5
	VarIntLen6
	VarIntLen7
	VarIntLen8
	VarIntLen9
)

View Source

const IFA_FLAGS = 0x8

Variables ¶

View Source

var GlobalLogLevel = LogLevelError | LogLevelInfo

View Source

var JsonEncodeOptions = []gojson.EncodeOptionFunc{gojson.DisableHTMLEscape(), gojson.DisableNormalizeUTF8()}

View Source

var LogFile bool

View Source

var LogFunc bool

Functions ¶

func ContextTick ¶

func ContextTick(ctx context.Context, d time.Duration) <-chan time.Time

func Debugf ¶

func Debugf(format string, v ...any)

func DecodeBinaryNumber ¶

func DecodeBinaryNumber(i string) uint64

func DecodeHexBinaryNumber ¶

func DecodeHexBinaryNumber(i string) string

func EncodeBinaryNumber ¶

func EncodeBinaryNumber(n uint64) string

func EncodeHexBinaryNumber ¶

func EncodeHexBinaryNumber(v2 string) string

func EncodeSliceBinaryNumber ¶

func EncodeSliceBinaryNumber(dst, src []byte) []byte

func Error ¶

func Error(v ...any)

func Errorf ¶

func Errorf(prefix, format string, v ...any)

func Fatalf ¶

func Fatalf(format string, v ...any)

func GetOutboundIPv6 ¶

func GetOutboundIPv6() ([]netip.Addr, error)

func Keys ¶

func Keys[M ~map[K]V, K comparable, V any](m M) []K

func Logf ¶

func Logf(prefix, format string, v ...any)

func MarshalJSON ¶

func MarshalJSON(val any) ([]byte, error)

func MarshalJSONIndent ¶

func MarshalJSONIndent(val any, indent string) ([]byte, error)

func NetIPGetEUI48Information ¶

func NetIPGetEUI48Information(addr netip.Addr)

func NetIPIsCGNAT ¶

func NetIPIsCGNAT(addr netip.Addr) bool

func NewJSONDecoder ¶

func NewJSONDecoder(reader io.Reader) *gojson.Decoder

func NewJSONEncoder ¶

func NewJSONEncoder(writer io.Writer) *gojson.Encoder

func Noticef ¶

func Noticef(format string, v ...any)

func NthElementSlice ¶

func NthElementSlice[S ~[]E, E cmp.Ordered](s S, k int)

NthElementSlice QuickSelect implementation k is the desired index value, where array[k] is the k+1 smallest element values between s[0, k-1] are guaranteed <= to s[k] values between s[k+1, len(s)] are guaranteed >= to s[k]

func NthElementSliceFunc ¶

func NthElementSliceFunc[S ~[]E, E any](s S, cmp func(a, b E) int, k int)

NthElementSliceFunc QuickSelect implementation k is the desired index value, where array[k] is the k+1 smallest element values between s[0, k-1] are guaranteed <= to s[k] values between s[k+1, len(s)] are guaranteed >= to s[k]

func Panic ¶

func Panic(v ...any)

func Panicf ¶

func Panicf(format string, v ...any)

func ParseUint64 ¶

func ParseUint64(s []byte) (uint64, error)

ParseUint64 parses uint64 from s.

It is equivalent to strconv.ParseUint(s, 10, 64), but is faster.

From https://github.com/valyala/fastjson

func PreviousPowerOfTwo ¶

func PreviousPowerOfTwo(x uint64) int

func Print ¶

func Print(v ...any)

func ProbabilityEffort ¶

func ProbabilityEffort(effort float64) float64

func ProbabilityMode ¶

func ProbabilityMode(i ...float64) (n float64)

func ProbabilityNShares ¶

func ProbabilityNShares(shares uint64, effort float64) float64

func Shorten ¶

func Shorten(value string, n int) string

func ShortenSlice ¶

func ShortenSlice(value []byte, n int) []byte

func SiUnits ¶

func SiUnits(number float64, decimals int) string

func SliceCount ¶

func SliceCount[S ~[]E, E any](s S, f func(E) bool) (count int)

func SplitWork ¶

func SplitWork(routines int, workSize uint64, do func(workIndex uint64, routineIndex int) error, init func(routines, routineIndex int) error, errorFunc func(routineIndex int, err error)) bool

func UVarInt64Size ¶

func UVarInt64Size[T uint64 | int](v T) (n int)

func UVarInt64SliceSize ¶

func UVarInt64SliceSize[T uint64 | int](v []T) (n int)

func UnmarshalJSON ¶

func UnmarshalJSON(data []byte, val any) error

func XMRUnits ¶

func XMRUnits(v uint64) string

func XorShift64Star ¶

func XorShift64Star(x uint64) uint64

XorShift64Star Implementation of xorshift* https://en.wikipedia.org/wiki/Xorshift#xorshift* x must be initialized to a non-zero value

Types ¶

type Cache ¶

type Cache[K comparable, T any] interface {
	Get(key K) (value T, ok bool)
	Set(key K, value T)
	Delete(key K)
	Clear()
	Stats() (hits, misses uint64)
}

type CircularBuffer ¶

type CircularBuffer[T comparable] struct {
	// contains filtered or unexported fields
}

func NewCircularBuffer ¶

func NewCircularBuffer[T comparable](size int) *CircularBuffer[T]

func (*CircularBuffer[T]) Current ¶

func (b *CircularBuffer[T]) Current() T

func (*CircularBuffer[T]) Exists ¶

func (b *CircularBuffer[T]) Exists(value T) bool

func (*CircularBuffer[T]) Get ¶

func (b *CircularBuffer[T]) Get(index uint32) T

func (*CircularBuffer[T]) Push ¶

func (b *CircularBuffer[T]) Push(value T)

func (*CircularBuffer[T]) PushUnique ¶

func (b *CircularBuffer[T]) PushUnique(value T) bool

func (*CircularBuffer[T]) Replace ¶

func (b *CircularBuffer[T]) Replace(value, replace T)

func (*CircularBuffer[T]) Reverse ¶

func (b *CircularBuffer[T]) Reverse()

func (*CircularBuffer[T]) Slice ¶

func (b *CircularBuffer[T]) Slice() []T

type ExtendedIPFlags ¶

type ExtendedIPFlags uint

const (
	FlagTemporary ExtendedIPFlags = 1 << iota
	FlagPermanent
	FlagNoPrefixRoute
	FlagManageTempAddress
	FlagStablePrivacy
	FlagDeprecated
)

type ExtendedIPNet ¶

type ExtendedIPNet struct {
	IP    net.IP     // network number
	Mask  net.IPMask // network mask
	Flags ExtendedIPFlags
}

func InterfaceAddrs ¶

func InterfaceAddrs(ifi *net.Interface) ([]*ExtendedIPNet, error)

InterfaceAddrs returns a list of unicast interface addresses for a specific interface.

func (*ExtendedIPNet) String ¶

func (n *ExtendedIPNet) String() string

type LRUCache ¶

type LRUCache[K comparable, T any] struct {
	// contains filtered or unexported fields
}

func NewLRUCache ¶

func NewLRUCache[K comparable, T any](size int) *LRUCache[K, T]

func (*LRUCache[K, T]) Clear ¶

func (c *LRUCache[K, T]) Clear()

func (*LRUCache[K, T]) Delete ¶

func (c *LRUCache[K, T]) Delete(key K)

func (*LRUCache[K, T]) Get ¶

func (c *LRUCache[K, T]) Get(key K) (value T, ok bool)

func (*LRUCache[K, T]) Set ¶

func (c *LRUCache[K, T]) Set(key K, value T)

func (*LRUCache[K, T]) Stats ¶

func (c *LRUCache[K, T]) Stats() (hits, misses uint64)

type LimitedByteReader ¶

type LimitedByteReader struct {
	R ReaderAndByteReader // underlying reader
	N int64               // max bytes remaining
}

A LimitedByteReader reads from R but limits the amount of data returned to just N bytes. Each call to Read updates N to reflect the new amount remaining. Read returns EOF when N <= 0 or when the underlying R returns EOF.

func LimitByteReader ¶

func LimitByteReader(r ReaderAndByteReader, n int64) *LimitedByteReader

LimitByteReader returns a Reader that reads from r but stops with EOF after n bytes. The underlying implementation is a *LimitedReader.

func (*LimitedByteReader) Left ¶

func (l *LimitedByteReader) Left() int64

func (*LimitedByteReader) Read ¶

func (l *LimitedByteReader) Read(p []byte) (n int, err error)

func (*LimitedByteReader) ReadByte ¶

func (l *LimitedByteReader) ReadByte() (v byte, err error)

type LogLevel ¶

type LogLevel int

type MapCache ¶

type MapCache[K comparable, T any] struct {
	// contains filtered or unexported fields
}

func NewMapCache ¶

func NewMapCache[K comparable, T any](preAllocateSize int) *MapCache[K, T]

func (*MapCache[K, T]) Clear ¶

func (m *MapCache[K, T]) Clear()

func (*MapCache[K, T]) Delete ¶

func (m *MapCache[K, T]) Delete(key K)

func (*MapCache[K, T]) Get ¶

func (m *MapCache[K, T]) Get(key K) (value T, ok bool)

func (*MapCache[K, T]) Set ¶

func (m *MapCache[K, T]) Set(key K, value T)

func (*MapCache[K, T]) Stats ¶

func (m *MapCache[K, T]) Stats() (hits, misses uint64)

type ReaderAndByteReader ¶

type ReaderAndByteReader interface {
	io.Reader
	io.ByteReader
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func ContextTick ¶

func Debugf ¶

func DecodeBinaryNumber ¶

func DecodeHexBinaryNumber ¶

func EncodeBinaryNumber ¶

func EncodeHexBinaryNumber ¶

func EncodeSliceBinaryNumber ¶

func Error ¶

func Errorf ¶

func Factorial ¶

func Fatalf ¶

func GetOutboundIPv6 ¶

func Keys ¶

func Logf ¶

func MarshalJSON ¶

func MarshalJSONIndent ¶

func NetIPGetEUI48Information ¶

func NetIPIsCGNAT ¶

func NewJSONDecoder ¶

func NewJSONEncoder ¶

func Noticef ¶

func NthElementSlice ¶

func NthElementSliceFunc ¶

func Panic ¶

func Panicf ¶

func ParseUint64 ¶

func PreviousPowerOfTwo ¶

func Print ¶

func ProbabilityEffort ¶

func ProbabilityMode ¶

func ProbabilityNShares ¶

func Shorten ¶

func ShortenSlice ¶

func SiUnits ¶

func SliceCount ¶

func SplitWork ¶

func UVarInt64Size ¶

func UVarInt64SliceSize ¶

func UnmarshalJSON ¶

func XMRUnits ¶

func XorShift64Star ¶

Types ¶

type Cache ¶

type CircularBuffer ¶

func NewCircularBuffer ¶

func (*CircularBuffer[T]) Current ¶

func (*CircularBuffer[T]) Exists ¶

func (*CircularBuffer[T]) Get ¶

func (*CircularBuffer[T]) Push ¶

func (*CircularBuffer[T]) PushUnique ¶

func (*CircularBuffer[T]) Replace ¶

func (*CircularBuffer[T]) Reverse ¶

func (*CircularBuffer[T]) Slice ¶

type ExtendedIPFlags ¶

type ExtendedIPNet ¶

func InterfaceAddrs ¶

func (*ExtendedIPNet) String ¶

type LRUCache ¶

func NewLRUCache ¶

func (*LRUCache[K, T]) Clear ¶

func (*LRUCache[K, T]) Delete ¶

func (*LRUCache[K, T]) Get ¶

func (*LRUCache[K, T]) Set ¶

func (*LRUCache[K, T]) Stats ¶

type LimitedByteReader ¶

func LimitByteReader ¶

func (*LimitedByteReader) Left ¶

func (*LimitedByteReader) Read ¶

func (*LimitedByteReader) ReadByte ¶

type LogLevel ¶

type MapCache ¶

func NewMapCache ¶

func (*MapCache[K, T]) Clear ¶

func (*MapCache[K, T]) Delete ¶

func (*MapCache[K, T]) Get ¶