utils

Documentation

Index

• Variables
• func ArgSplit(str string) (result []string)
• func DecodeGifWithCompleteFrame(r io.Reader) (g *gif.GIF, err error)
• func FilePathWalkDir(root string) ([]string, error)
• func FuncName() string
• func GetGifDimensions(gif *gif.GIF) (x, y int)
• func GroupLogFields(groupCode int64) logrus.Fields
• func ImageFormat(origImage []byte) (string, error)
• func ImageGet(url string, prefer proxy_pool.Prefer, opt ...requests.Option) ([]byte, error)
• func ImageGetAndNorm(url string, prefer proxy_pool.Prefer) ([]byte, error)
• func ImageNormSize(origImage []byte) ([]byte, error)
• func ImageReserve(imgBytes []byte) ([]byte, error)
• func ImageSuffix(name string) bool
• func JoinInt64(ele []int64, sep string) string
• func MergeImages(images [][]byte) ([]byte, error)
• func MessageFilter(msg []message.IMessageElement, filter func(message.IMessageElement) bool) []message.IMessageElement
• func MessageTextf(format string, args ...interface{}) *message.TextElement
• func MsgToString(elements []message.IMessageElement) (res string)
• func NewAnimeCascadeClassifier() gocv.CascadeClassifier
• func NewFaceCascadeClassifier() gocv.CascadeClassifier
• func OpenCvAnimeFaceDetect(imgBytes []byte) ([]byte, error)
• func PrefixMatch(opts []string, target string) (string, bool)
• func Retry(count int, interval time.Duration, f func() bool) bool
• func SubImage(img image.Image, r image.Rectangle) image.Image
• func Switch2Bool(_s string) bool
• func TimestampFormat(ts int64) string
• func ToDatas(data interface{}) (requests.Datas, error)
• func ToParams(get interface{}) (requests.Params, error)
• func UnquoteString(s string) (string, error)
• func UploadGroupImage(groupCode int64, img []byte, isNorm bool) (image *message.GroupImageElement, err error)
• func UploadGroupImageByUrl(groupCode int64, url string, isNorm bool, prefer proxy_pool.Prefer) (*message.GroupImageElement, error)
• func UrlEncode(data requests.Datas) string
• type EmitE
  • func NewEmitE(id interface{}, t concern.Type) *EmitE
• type EmitQueue
  • func NewEmitQueue(c chan<- *EmitE, interval time.Duration) *EmitQueue
  • func (q *EmitQueue) Add(e *EmitE, t time.Time)
  • func (q *EmitQueue) Stop()

Variables

var ErrGoCvNotSetUp = errors.New("gocv not setup")

Functions

func ArgSplit

func ArgSplit(str string) (result []string)

func DecodeGifWithCompleteFrame

func DecodeGifWithCompleteFrame(r io.Reader) (g *gif.GIF, err error)

func FilePathWalkDir

func FilePathWalkDir(root string) ([]string, error)

func FuncName

func FuncName() string

func GetGifDimensions

func GetGifDimensions(gif *gif.GIF) (x, y int)

func GroupLogFields

func GroupLogFields(groupCode int64) logrus.Fields

func ImageFormat

func ImageFormat(origImage []byte) (string, error)

func ImageGet

func ImageGet(url string, prefer proxy_pool.Prefer, opt ...requests.Option) ([]byte, error)

func ImageGetAndNorm

func ImageGetAndNorm(url string, prefer proxy_pool.Prefer) ([]byte, error)

func ImageNormSize

func ImageNormSize(origImage []byte) ([]byte, error)

func ImageReserve

func ImageReserve(imgBytes []byte) ([]byte, error)

func ImageSuffix

func ImageSuffix(name string) bool

func JoinInt64

func JoinInt64(ele []int64, sep string) string

func MergeImages

func MergeImages(images [][]byte) ([]byte, error)

func MessageFilter

func MessageFilter(msg []message.IMessageElement, filter func(message.IMessageElement) bool) []message.IMessageElement

func MessageTextf

func MessageTextf(format string, args ...interface{}) *message.TextElement

func MsgToString

func MsgToString(elements []message.IMessageElement) (res string)

func NewAnimeCascadeClassifier

func NewAnimeCascadeClassifier() gocv.CascadeClassifier

func NewFaceCascadeClassifier

func NewFaceCascadeClassifier() gocv.CascadeClassifier

func OpenCvAnimeFaceDetect

func OpenCvAnimeFaceDetect(imgBytes []byte) ([]byte, error)

func PrefixMatch

func PrefixMatch(opts []string, target string) (string, bool)

func Retry

func Retry(count int, interval time.Duration, f func() bool) bool

func SubImage

func SubImage(img image.Image, r image.Rectangle) image.Image

func Switch2Bool

func Switch2Bool(_s string) bool

func TimestampFormat

func TimestampFormat(ts int64) string

func ToDatas

func ToDatas(data interface{}) (requests.Datas, error)

func ToParams

func ToParams(get interface{}) (requests.Params, error)

func UnquoteString

func UnquoteString(s string) (string, error)

func UploadGroupImage

func UploadGroupImage(groupCode int64, img []byte, isNorm bool) (image *message.GroupImageElement, err error)

func UploadGroupImageByUrl

func UploadGroupImageByUrl(groupCode int64, url string, isNorm bool, prefer proxy_pool.Prefer) (*message.GroupImageElement, error)

func UrlEncode

func UrlEncode(data requests.Datas) string

Types

type EmitE

type EmitE struct {
	Id   interface{}
	Type concern.Type
}

func NewEmitE

func NewEmitE(id interface{}, t concern.Type) *EmitE

type EmitQueue

type EmitQueue struct {
	*sync.Cond

	TimeInterval time.Duration
	// contains filtered or unexported fields
}

func NewEmitQueue

func NewEmitQueue(c chan<- *EmitE, interval time.Duration) *EmitQueue

func (*EmitQueue) Add

func (q *EmitQueue) Add(e *EmitE, t time.Time)

func (*EmitQueue) Stop

func (q *EmitQueue) Stop()