util

May 20, 2024

Changes in this version

+ func EqualsAnyIgnoreCase(s string, strs ...string) bool

Feb 29, 2024

Changes in this version

+ const MaxReadTimeout

Feb 29, 2024

Changes in this version

+ const MaxReadHeaderTimeout

Feb 29, 2024

Changes in this version

+ const MaxHeaderBytes

Jan 22, 2024

Changes in this version

+ func Go(handle func())

Jan 22, 2024

Changes in this version

+ func RecoverGo(handle func())

Jan 19, 2024

Changes in this version

+ func NewWaitNumGroup() *waitNumGroup

Jan 17, 2024

Changes in this version

+ func ContainsArray(str string, targetStr ...string) bool

Jan 17, 2024

Changes in this version

type Request

+ func (r *Request) CallBreak(link string, jsonData []byte) ([]byte, error)

Jan 16, 2024

Changes in this version

+ func ContainsInArray(strArray []string, targetStr string) bool

Sep 18, 2023

Changes in this version

+ var TimestampFormat = "2006-01-02 15:04:05"

+ func FormatTime(tm *time.Time) string

+ func FreeChanBool(flag chan bool)

+ func GetChanBool() chan bool

+ func GetGroupId(re *http.Request) string

+ func GetGroupIds(re *http.Request) []string

+ func GetLiveTime(re *http.Request) int

+ func GetMessage(re *http.Request) string

+ func GetSize(re *http.Request) int

+ func GetStart(re *http.Request) int

+ func GetUsername(re *http.Request) string

+ func HttpCross(w http.ResponseWriter)

+ func HttpCrossChunked(w http.ResponseWriter)

+ func Millisecond() uint32

+ func NewPtr(v interface{}) interface

+ type HttpServer struct

+ func NewServer() *HttpServer

+ func (hs *HttpServer) AddRoute(pattern string, handler func(http.ResponseWriter, *http.Request))

+ func (hs *HttpServer) IsTls() bool

+ func (hs *HttpServer) Start(port int) error

+ func (hs *HttpServer) StartAutoTLS(port int, certFile, keyFile string) error

+ func (hs *HttpServer) StartTLS(port int, certFile, keyFile string) error

+ type Queue struct

+ func NewQueue() *Queue

+ func (queue *Queue) Dequeue(ctx context.Context) (value interface{}, num int32, cols bool)

+ func (queue *Queue) Num() int32

+ func (queue *Queue) Offer(value interface{}) (num int32)

+ func (queue *Queue) Peek() (value interface{}, num int32)

+ func (queue *Queue) Poll() (value interface{}, num int32)

+ func (queue *Queue) Take(duration time.Duration) (value interface{}, num int32)

+ type Request struct

+ func NewRequest() *Request

+ func (r *Request) Call(link string, jsonData []byte) ([]byte, error)

+ func (r *Request) Get(link string) ([]byte, error)

+ func (r *Request) JustCall(link string, jsonData []byte) error

+ type RetryTransport struct

+ Retries int

+ Transport http.RoundTripper

+ func (r *RetryTransport) RoundTrip(req *http.Request) (*http.Response, error)

+ type VQueue struct

+ func NewVQueue() *VQueue

+ func (queue *VQueue) Dequeue(ctx context.Context) (value interface{}, num int32, hasClose bool)

+ func (queue *VQueue) Num() int32

+ func (queue *VQueue) Offer(value interface{}) (nu int32)

+ func (queue *VQueue) Poll() (value interface{}, nu int32)

+ func (queue *VQueue) Take(duration time.Duration) (value interface{}, num int32)