sugar

package

v0.0.0-...-973764b Latest Latest Go to latest Published: Aug 28, 2026 License: MIT Imports: 13 Imported by: 0

Details

语法糖

This section is empty.

View Source

var (
	ErrClosed = errors.New("subscriber closed")
	ErrFull   = errors.New("message channel full")
)

func InArrayContain[T comparable](item T, items []T) bool

func LoadCertPool(certPaths ...string) (*x509.CertPool, error)

LoadCertPool 从多个证书文件路径加载证书池

func PrintEsRequest(reqFun func(ctx context.Context) (*http.Request, error))

func RandInt(minV, maxV int) int

RandInt generate random int between [min, max).

func RandomWithProbability(probability float64) bool

RandomWithProbability 随机概率 0.01 -> 1.

func SliceLast[T comparable](c []T) T

func SliceOf[T any](val ...T) []T

type Channel[V any] struct {
	// contains filtered or unexported fields
}

func NewChannel[V any](ctx context.Context, bufSize uint) *Channel[V]

func (s *Channel[V]) Channel() chan V

func (s *Channel[V]) Close()

func (s *Channel[V]) Push(v V) error

func (s *Channel[V]) PushWithContext(ctx context.Context, v V) error

func (s *Channel[V]) PushWithTimeout(msg V, timeout time.Duration) error

type Singleton[T any] interface {
	Load() T
	Inject(newFn func() T)
	Replace(newObj T)
}

func NewSingleton[T any](newFn func() T) Singleton[T]

type SingletonWithValue[T any, I any] interface {
	Singleton[T]

	Init(value I) T
	Reload(value I)
}

func NewSingletonWithValue[T any, I any](newFn func(I) T) SingletonWithValue[T, I]