misc

Documentation

Index

• Constants
• func Base64DecodeFilename(src string) ([]byte, error)
• func Base64DecodeMap(str string) (data map[string]interface{}, err error)
• func Base64EncodeFilename(src string) string
• func Base64EncodeMap(data map[string]interface{}) string
• func BasenameWithoutExt(cf string) (base string)
• func BuildInfo(vars ...[2]string) (info [][2]string)
• func CheckDuplicateFilename(p string) (out string, err error)
• func EqualVector[T constraints.Ordered](arr1, arr2 []T) (ok bool)
• func ExampleRequestTmpls() string
• func FileSize2Str(n int64) string
• func First[T any](v []T) *T
• func GetOClock(shift int) (clock time.Time)
• func Hello()
• func Last[T any](v []T) *T
• func ListenOSSignal(ch chan int, sgs ...os.Signal)
• func LoadPprof(mux *http.ServeMux)
• func NTSFunc(delay int64) http.HandlerFunc
• func NowMs() string
• func ParseDatetime(value string) (at time.Time, err error)
• func RandString(n int) string
• func RegisterLogPrinter()
• func RootDir() (dir string, err error)
• func RootFile(p2f ...string) (fp string, err error)
• func RootModule() (mod string, err error)
• func SegnmentsDiv(length, num int) (segs [][2]int)
• func SliceGet[T any](slice []T, index int) (val T, exists bool)
• func Stack(prefix string) (slice []string)
• func TimeCeil(at time.Time, tu string) (out time.Time, err error)
• func TimeFloor(at time.Time, tu string) (out time.Time, err error)
• func UniqVector[T constraints.Ordered](arr []T) (list []T)
• func ValidJSON(bts []byte) (err error)
• func VectorIndex[T constraints.Ordered](list []T, v T) int
• type LogIntf
• type LogPrinter
  • func (w *LogPrinter) Write(bts []byte) (int, error)
• type LogWriter
  • func NewLogWriter(prefix string, w io.Writer) (lw *LogWriter, err error)
  • func (lw *LogWriter) Close() (err error)
  • func (lw *LogWriter) Register()
  • func (lw *LogWriter) Write(bts []byte) (int, error)
• type Logger
  • func NewLogger() (logger *Logger)
  • func (logger *Logger) Debug(format string, a ...any)
  • func (logger *Logger) Error(format string, a ...any)
  • func (logger *Logger) Info(format string, a ...any)
  • func (logger *Logger) Printf(format string, a ...any) (int, error)
  • func (logger *Logger) Trace(format string, a ...any)
  • func (logger *Logger) Warn(format string, a ...any)
• type NetworkTimeResult
  • func GetNetworkTime(addr string, delay int64) (result *NetworkTimeResult, err error)
  • func (result NetworkTimeResult) String() string
• type NetworkTimeServer
  • func NewNetworkTimeServer(addr string, delay int64) (ser *NetworkTimeServer, err error)
  • func (ser *NetworkTimeServer) Run() error
• type Output
  • func (output *Output) Get(bts []byte) (value string, err error)
• type RequestTmpl
• type RequestTmpls
  • func LoadRequestTmpls(name, fp string) (item *RequestTmpls, err error)
  • func (item *RequestTmpls) Match(names ...string) (tmpls []*RequestTmpl, err error)
  • func (item *RequestTmpls) Request(tmpl *RequestTmpl) (statusCode int, body string, err error)
• type SigningUrlMd5
  • func NewSigningUrlMd5(secrete, key string, lowcase bool) SigningUrlMd5
  • func (sign *SigningUrlMd5) Sign(param map[string]string) (query string)
  • func (sign *SigningUrlMd5) Verify(query string) (err error)

Constants

const (
	RFC3339ms = "2006-01-02T15:04:05.000Z07:00"
)

Functions

func Base64DecodeFilename

func Base64DecodeFilename(src string) ([]byte, error)

replace +/ with -_

func Base64DecodeMap

func Base64DecodeMap(str string) (data map[string]interface{}, err error)

func Base64EncodeFilename

func Base64EncodeFilename(src string) string

replace +/ with -_

func Base64EncodeMap

func Base64EncodeMap(data map[string]interface{}) string

func BasenameWithoutExt

func BasenameWithoutExt(cf string) (base string)

func BuildInfo

func BuildInfo(vars ...[2]string) (info [][2]string)

func CheckDuplicateFilename

func CheckDuplicateFilename(p string) (out string, err error)

func EqualVector

func EqualVector[T constraints.Ordered](arr1, arr2 []T) (ok bool)

func ExampleRequestTmpls

func ExampleRequestTmpls() string

func FileSize2Str

func FileSize2Str(n int64) string

func First

func First[T any](v []T) *T

func GetOClock

func GetOClock(shift int) (clock time.Time)

func Hello

func Hello()

func Last

func Last[T any](v []T) *T

func ListenOSSignal

func ListenOSSignal(ch chan int, sgs ...os.Signal)

func LoadPprof

func LoadPprof(mux *http.ServeMux)

create new Pprof and run server

func NTSFunc

func NTSFunc(delay int64) http.HandlerFunc

func NowMs

func NowMs() string

func ParseDatetime

func ParseDatetime(value string) (at time.Time, err error)

datetime format: "2021-06-24", "09:00:01", "2021-06-24 09:10:11" or "2021-06-24T09:10:11"

func RandString

func RandString(n int) string

func RegisterLogPrinter

func RegisterLogPrinter()

func RootDir

func RootDir() (dir string, err error)

get root path of project by recursively match go.mod in parent directory

func RootFile

func RootFile(p2f ...string) (fp string, err error)

func RootModule

func RootModule() (mod string, err error)

func SegnmentsDiv

func SegnmentsDiv(length, num int) (segs [][2]int)

func SliceGet

func SliceGet[T any](slice []T, index int) (val T, exists bool)

func Stack

func Stack(prefix string) (slice []string)

func TimeCeil

func TimeCeil(at time.Time, tu string) (out time.Time, err error)

ceil time, e.g. TimeCeil('2020-12-01T17:39:07.123+08:00', "M") -> '2020-12-01T17:40:00+08:00'

valid unit(key or value)
H: hour, M: minute, S: second
y: year, s: season, m: month, w: week, d: day

func TimeFloor

func TimeFloor(at time.Time, tu string) (out time.Time, err error)

floor time, e.g. TimeFloor('2020-12-01T17:39:07.123+08:00', "M") -> '2020-12-01T17:39:00+08:00'

valid unit(key or value)
H: hour, M: minute, S: second
y: year, s: season, m: month, w: week, d: day

func UniqVector

func UniqVector[T constraints.Ordered](arr []T) (list []T)

func ValidJSON

func ValidJSON(bts []byte) (err error)

func VectorIndex

func VectorIndex[T constraints.Ordered](list []T, v T) int

Types

type LogIntf

type LogIntf interface {
	Trace(string, ...any)
	Debug(string, ...any)
	Info(string, ...any)
	Warn(string, ...any)
	Error(string, ...any)
}

customize yourself, no concurrency safety guaranteed

type LogPrinter

type LogPrinter struct{}

func (*LogPrinter) Write

func (w *LogPrinter) Write(bts []byte) (int, error)

type LogWriter

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

a simple log writer

func NewLogWriter

func NewLogWriter(prefix string, w io.Writer) (lw *LogWriter, err error)

func (*LogWriter) Close

func (lw *LogWriter) Close() (err error)

func (*LogWriter) Register

func (lw *LogWriter) Register()

set as output of log pkg

func (*LogWriter) Write

func (lw *LogWriter) Write(bts []byte) (int, error)

type Logger

type Logger struct{}

func NewLogger

func NewLogger() (logger *Logger)

func (*Logger) Debug

func (logger *Logger) Debug(format string, a ...any)

func (*Logger) Error

func (logger *Logger) Error(format string, a ...any)

func (*Logger) Info

func (logger *Logger) Info(format string, a ...any)

func (*Logger) Printf

func (logger *Logger) Printf(format string, a ...any) (int, error)

func (*Logger) Trace

func (logger *Logger) Trace(format string, a ...any)

func (*Logger) Warn

func (logger *Logger) Warn(format string, a ...any)

type NetworkTimeResult

type NetworkTimeResult struct {
	T1    time.Time `json:"t1"`
	T2    time.Time `json:"t2"`
	T3    time.Time `json:"t3"`
	T4    time.Time `json:"t4"`
	Sigma int64     `json:"sigma"`
	Delta int64     `json:"delta"`
}

func GetNetworkTime

func GetNetworkTime(addr string, delay int64) (result *NetworkTimeResult, err error)

func (NetworkTimeResult) String

func (result NetworkTimeResult) String() string

type NetworkTimeServer

type NetworkTimeServer struct {
	*http.Server
	// contains filtered or unexported fields
}

https://en.wikipedia.org/wiki/Network_Time_Protocol https://en.wikipedia.org/wiki/File:NTP-Algorithm.svg

func NewNetworkTimeServer

func NewNetworkTimeServer(addr string, delay int64) (ser *NetworkTimeServer, err error)

func (*NetworkTimeServer) Run

func (ser *NetworkTimeServer) Run() error

type Output

type Output struct {
	Key    string `mapstructure:"key"`    // key in json
	Header string `mapstructure:"header"` // header key
	Tmpl   string `mapstructure:"tmpl"`   // header value template
}

func (*Output) Get

func (output *Output) Get(bts []byte) (value string, err error)

type RequestTmpl

type RequestTmpl struct {
	Name            string            `mapstructure:"name"`
	Method          string            `mapstructure:"method"`
	Path            string            `mapstructure:"path"`
	Params          map[string]string `mapstructure:"params"`
	Body            string            `mapstructure:"body"`
	NoPublicHeaders bool              `mapstructure:"no_public_headers"`
	Headers         map[string]string `mapstructure:"headers"`
	Outputs         []Output          `mapstructure:"outputs"`
}

type RequestTmpls

type RequestTmpls struct {
	Url     string            `mapstructure:"url"`
	Headers map[string]string `mapstructure:"headers"`
	Prelude []RequestTmpl     `mapstructure:"prelude"`
	APIs    []RequestTmpl     `mapstructure:"apis"`
	// contains filtered or unexported fields
}

func LoadRequestTmpls

func LoadRequestTmpls(name, fp string) (item *RequestTmpls, err error)

func (*RequestTmpls) Match

func (item *RequestTmpls) Match(names ...string) (tmpls []*RequestTmpl, err error)

func (*RequestTmpls) Request

func (item *RequestTmpls) Request(tmpl *RequestTmpl) (
	statusCode int, body string, err error)

type SigningUrlMd5

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

func NewSigningUrlMd5

func NewSigningUrlMd5(secrete, key string, lowcase bool) SigningUrlMd5

func (*SigningUrlMd5) Sign

func (sign *SigningUrlMd5) Sign(param map[string]string) (query string)

func (*SigningUrlMd5) Verify

func (sign *SigningUrlMd5) Verify(query string) (err error)