util

Documentation

Index

• Constants
• Variables
• func ContainsArray(str string, targetStr ...string) bool
• func ContainsInArray(strArray []string, targetStr string) bool
• func EqualsAnyIgnoreCase(s string, strs ...string) bool
• func FormatTime(tm *time.Time) string
• func FreeQueue(queue *Queue)
• func FreeSliceQueue(sliceQueue *SliceQueue)
• 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 Go(handle func())
• func HttpCross(w http.ResponseWriter)
• func HttpCrossChunked(w http.ResponseWriter)
• func Millisecond() uint32
• func NewPtr(v interface{}) interface{}
• func NewWaitNumGroup() *waitNumGroup
• func RecoverGo(handle func())
• type CancelContext
  • func NewCancelContext() *CancelContext
  • func (c *CancelContext) Cancel()
  • func (c *CancelContext) Close()
  • func (c *CancelContext) Err() error
  • func (c *CancelContext) Wait()
• type HttpServer
  • 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
  • func GetQueue() *Queue
  • func NewQueue() *Queue
  • func (queue *Queue) Dequeue(ctx context.Context) (value interface{}, hasClose bool)
  • func (queue *Queue) DequeueWithCanceled(ctx *CancelContext) (value interface{}, hasClose bool)
  • func (queue *Queue) Offer(value interface{}) error
  • func (queue *Queue) Poll() (value interface{})
• type Request
  • func NewRequest() *Request
  • func (r *Request) Call(link string, jsonData []byte) ([]byte, error)
  • func (r *Request) CallBreak(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
  • func (r *RetryTransport) RoundTrip(req *http.Request) (*http.Response, error)
• type SliceMap
  • func (b *SliceMap[V]) Delete(key string)
  • func (b *SliceMap[V]) Each(f func(string, V))
  • func (b *SliceMap[V]) EachIndex(f func(int, string, V))
  • func (b *SliceMap[V]) Get(key string) (V, bool)
  • func (b *SliceMap[V]) Len() int
  • func (b *SliceMap[V]) Put(key string, value V) error
  • func (b *SliceMap[V]) PutOrReplace(key string, value V) error
  • func (b *SliceMap[V]) Read() (any, error)
  • func (b *SliceMap[V]) Reset()
• type SliceQueue
  • func GetSliceQueue() *SliceQueue
  • func (b *SliceQueue) Len() int
  • func (b *SliceQueue) Read() (any, error)
  • func (b *SliceQueue) Reset()
  • func (b *SliceQueue) Write(c any) error

Constants

const MaxHeaderBytes = 8192

const MaxReadHeaderTimeout = time.Second * 30

const MaxReadTimeout = time.Minute * 10

Variables

var CloseExceeded error = closeExceededError{}

var ErrTooLarge = errors.New("sliceQueue: too large")

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

Functions

func ContainsArray

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

func ContainsInArray

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

func EqualsAnyIgnoreCase

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

func FormatTime

func FormatTime(tm *time.Time) string

func FreeQueue

func FreeQueue(queue *Queue)

func FreeSliceQueue

func FreeSliceQueue(sliceQueue *SliceQueue)

func GetGroupId

func GetGroupId(re *http.Request) string

func GetGroupIds

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

func GetLiveTime

func GetLiveTime(re *http.Request) int

func GetMessage

func GetMessage(re *http.Request) string

func GetSize

func GetSize(re *http.Request) int

func GetStart

func GetStart(re *http.Request) int

func GetUsername

func GetUsername(re *http.Request) string

func Go

func Go(handle func())

func HttpCross

func HttpCross(w http.ResponseWriter)

func HttpCrossChunked

func HttpCrossChunked(w http.ResponseWriter)

func Millisecond

func Millisecond() uint32

func NewPtr

func NewPtr(v interface{}) interface{}

func NewWaitNumGroup

func NewWaitNumGroup() *waitNumGroup

func RecoverGo

func RecoverGo(handle func())

Types

type CancelContext

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

func NewCancelContext

func NewCancelContext() *CancelContext

func (*CancelContext) Cancel

func (c *CancelContext) Cancel()

func (*CancelContext) Close

func (c *CancelContext) Close()

func (*CancelContext) Err

func (c *CancelContext) Err() error

func (*CancelContext) Wait

func (c *CancelContext) Wait()

type HttpServer

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

func NewServer

func NewServer() *HttpServer

func (*HttpServer) AddRoute

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

func (*HttpServer) IsTls

func (hs *HttpServer) IsTls() bool

func (*HttpServer) Start

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

func (*HttpServer) StartAutoTLS

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

func (*HttpServer) StartTLS

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

type Queue

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

func GetQueue

func GetQueue() *Queue

func NewQueue

func NewQueue() *Queue

func (*Queue) Dequeue

func (queue *Queue) Dequeue(ctx context.Context) (value interface{}, hasClose bool)

func (*Queue) DequeueWithCanceled

func (queue *Queue) DequeueWithCanceled(ctx *CancelContext) (value interface{}, hasClose bool)

func (*Queue) Offer

func (queue *Queue) Offer(value interface{}) error

func (*Queue) Poll

func (queue *Queue) Poll() (value interface{})

type Request

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

func NewRequest

func NewRequest() *Request

func (*Request) Call

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

func (*Request) CallBreak

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

func (*Request) Get

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

func (*Request) JustCall

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

type RetryTransport

type RetryTransport struct {
	Transport http.RoundTripper
	Retries   int
}

func (*RetryTransport) RoundTrip

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

type SliceMap

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

func (*SliceMap[V]) Delete

func (b *SliceMap[V]) Delete(key string)

func (*SliceMap[V]) Each

func (b *SliceMap[V]) Each(f func(string, V))

func (*SliceMap[V]) EachIndex

func (b *SliceMap[V]) EachIndex(f func(int, string, V))

func (*SliceMap[V]) Get

func (b *SliceMap[V]) Get(key string) (V, bool)

func (*SliceMap[V]) Len

func (b *SliceMap[V]) Len() int

func (*SliceMap[V]) Put

func (b *SliceMap[V]) Put(key string, value V) error

func (*SliceMap[V]) PutOrReplace

func (b *SliceMap[V]) PutOrReplace(key string, value V) error

func (*SliceMap[V]) Read

func (b *SliceMap[V]) Read() (any, error)

func (*SliceMap[V]) Reset

func (b *SliceMap[V]) Reset()

type SliceQueue

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

func GetSliceQueue

func GetSliceQueue() *SliceQueue

func (*SliceQueue) Len

func (b *SliceQueue) Len() int

func (*SliceQueue) Read

func (b *SliceQueue) Read() (any, error)

func (*SliceQueue) Reset

func (b *SliceQueue) Reset()

func (*SliceQueue) Write

func (b *SliceQueue) Write(c any) error