util

Documentation

Index

• Variables
• func ContainsArray(str string, targetStr ...string) bool
• func ContainsInArray(strArray []string, targetStr string) bool
• 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
  • 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 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
  • 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 VQueue
  • 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)

Variables

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 FormatTime

func FormatTime(tm *time.Time) string

func FreeChanBool

func FreeChanBool(flag chan bool)

func GetChanBool

func GetChanBool() chan bool

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 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{}

Types

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 NewQueue

func NewQueue() *Queue

func (*Queue) Dequeue

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

func (*Queue) Num

func (queue *Queue) Num() int32

func (*Queue) Offer

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

func (*Queue) Peek

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

func (*Queue) Poll

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

func (*Queue) Take

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

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 VQueue

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

func NewVQueue

func NewVQueue() *VQueue

func (*VQueue) Dequeue

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

func (*VQueue) Num

func (queue *VQueue) Num() int32

func (*VQueue) Offer

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

func (*VQueue) Poll

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

func (*VQueue) Take

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