do

May 8, 2024

Changes in this version

+ func FirstOr[T any](s []T) (t T)

+ func HTTPSProxy(localAddr string, opt *HTTPSProxyOption) (err error)

+ func IndexOr[T any](s []T, i int) (t T)

+ func LastOr[T any](s []T) (t T)

+ type HTTPSProxyOption struct

+ CaCertFile string

+ CaKeyFile string

+ CertFile string

+ KeyFile string

Apr 30, 2024

Changes in this version

+ func Date(year int, month time.Month, day int, loc *time.Location) time.Time

+ func DateLocal(year int, month time.Month, day int) time.Time

Apr 29, 2024

Changes in this version

+ func MapFrom2[T any, R interface{ ... }](s []T) []R

+ func MapTo2[T interface{ ... }, R any](s []T) []R

Apr 29, 2024

Changes in this version

+ func AssertSlicePtr[T comparable](handler AssertHandler, lslice, rslice []*T, msgAndArgs ...any)

+ func IsPowerOf2(n uint64) bool

+ func IsSignDiff(x, y int) bool

+ func MapFrom[T any, R interface{ ... }](s []T, initial func() R) []R

+ func MapTo[T interface{ ... }, R any](s []T) []R

+ func SwapByBit(a, b int) (int, int)

Apr 24, 2024

Changes in this version

type E

+ func RunLogicIf[P, R any](cond bool, ctx C, param P, f Logic[P, R]) (r R, err E)

type Logic

+ func LogicFromWE[P, R any](f func(C, P) R) Logic[P, R]

+ func LogicFromWPE[R any](f func(C) R) Logic[struct{}, R]

+ func LogicFromWPR(f func(C) E) Logic[struct{}, struct{}]

+ func LogicFromWPRE(f func(C)) Logic[struct{}, struct{}]

+ func LogicFromWP[R any](f func(C) (R, E)) Logic[struct{}, R]

+ func LogicFromWRE[P any](f func(C, P)) Logic[P, struct{}]

+ func LogicFromWR[P any](f func(C, P) E) Logic[P, struct{}]

Apr 24, 2024

Changes in this version

+ func Or[T comparable](vals ...T) T

type E

+ func RunIf[P, R any, F LogicSet[P, R]](cond bool, ctx C, param P, f F) (r R, err E)

Mar 28, 2024

Changes in this version

+ func ValueOf[F any](v any, field string) (f F, ok bool)

+ type LogicSet interface

type Pager

+ func (p Pager) Limit() int

+ func (p Pager) Offset() int

Mar 20, 2024

Changes in this version

type E

+ func Pipes[B, D, A, R any](ctx C, b B, before Piper[B, D], do Piper[D, A], after Piper[A, R]) (r R, e E)

type Logic

+ func PipeToLogic[I, O any](pf PipeFunc[I, O]) Logic[I, O]

+ func (l Logic[P, R]) ToLogic() Logic[P, R]

type PipeFunc

+ func PipeFromLogic[I, O any](logic Logic[I, O]) PipeFunc[I, O]

+ func PipeFrom[I, O any](f func(C, I) (O, E)) PipeFunc[I, O]

+ func (pf PipeFunc[I, O]) Run(c C, i I) (r O, e E)

+ type Piper interface

+ Run func(C, I) (O, E)

+ type ToLogic interface

+ ToLogic func() Logic[P, R]

Mar 13, 2024

Changes in this version

+ type Logic func(C, P) (R, E)

+ var EmptyLogicFunc = func(C, struct{}) (r struct{}, err E) { ... }

+ var NilLogicFunc Logic[struct{}, struct{}]

+ func LogicFrom[P, R any](f func(C, P) (R, E)) Logic[P, R]

+ type LogicWithoutError func(C, P) R

+ func LogicWE[P, R any](f func(C, P) R) LogicWithoutError[P, R]

+ func (l LogicWithoutError[P, R]) ToLogic() Logic[P, R]

+ type LogicWithoutPR func(C) E

+ func LogicWPR[P any](f func(C) E) LogicWithoutPR

+ func (l LogicWithoutPR) ToLogic() Logic[struct{}, struct{}]

+ type LogicWithoutParam func(C) (R, E)

+ func LogicWP[R any](f func(C) (R, E)) LogicWithoutParam[R]

+ func (l LogicWithoutParam[R]) ToLogic() Logic[struct{}, R]

+ type LogicWithoutParamError func(C) R

+ func LogicWPE[R any](f func(C) R) LogicWithoutParamError[R]

+ func (l LogicWithoutParamError[R]) ToLogic() Logic[struct{}, R]

+ type LogicWithoutParamResultError func(C)

+ func LogicWPRE(f func(C)) LogicWithoutParamResultError

+ func (l LogicWithoutParamResultError) ToLogic() Logic[struct{}, struct{}]

+ type LogicWithoutResult func(C, P) E

+ func LogicWR[P any](f func(C, P) E) LogicWithoutResult[P]

+ func (l LogicWithoutResult[P]) ToLogic() Logic[P, struct{}]

+ type LogicWithoutResultError func(C, P)

+ func LogicWRE[P any](f func(C, P)) LogicWithoutResultError[P]

+ func (l LogicWithoutResultError[P]) ToLogic() Logic[P, struct{}]

Mar 13, 2024

Changes in this version

type Struct

+ func ResolveStructSlice(value any) ([]Struct, error)

Mar 1, 2024

Changes in this version

+ func Factorial(n int) int

+ func FactorialBig(n int) string

Feb 4, 2024

Changes in this version

+ func EscapeStruct(v any, escaper Escaper) (err error)

+ func HTMLEscaper(field any) (r any, err error)

+ func XMLEscaper(field any) (r any, err error)

+ type Escaper func(field any) (any, error)

Jan 31, 2024

Changes in this version

+ func AgeByBirth(birthday time.Time, now ...time.Time) (age int, unit string)

Jan 25, 2024

Changes in this version

+ type Signer struct

+ func NewSigner(secret string) *Signer

+ func (s *Signer) Sign(raw []byte) (r string, err error)

Jan 10, 2024

Changes in this version

+ func First[T any](s []T) (t T, ok bool)

+ func Index[T any](s []T, i int) (t T, ok bool)

+ func Last[T any](s []T) (t T, ok bool)

+ func Pointer[T any]() *T

Jan 6, 2024

Changes in this version

+ func ReplaceIP(link, ip, nip string) (r string, err error)

Jan 2, 2024

Changes in this version

type Route

+ Opt *RouteOption

+ func (r *Route[T]) WithOption(opt *RouteOption) *Route[T]

+ type RouteOption struct

+ NeedLogin bool

+ ParamFormat string

+ ResultFormat string

+ UseBody bool

Dec 28, 2023

Changes in this version

+ func NewHTTPClient(opts ...HTTPClientSetter) *http.Client

+ type HTTPClientOption struct

+ type HTTPClientSetter func(*HTTPClientOption)

+ func HTTPClientSkipVerify() HTTPClientSetter

+ func HTTPClientWithTimeout(timeout time.Duration) HTTPClientSetter

+ func HTTPClientWithTransport(tp *http.Transport) HTTPClientSetter

Dec 28, 2023

Changes in this version

+ func DeepCopy[T any](v T) T

+ type Interface interface

+ DeepCopy func() interface{}

Dec 27, 2023

Changes in this version

+ func HandleResult(r sql.Result) (id int64, n int64, err error)

Dec 26, 2023

Changes in this version

+ func Copy[T any](v *T) *T

Dec 25, 2023

Changes in this version

+ func RunWithTimeout[P, R any](ctx C, d time.Duration, p P, f func(ctx C, p P) R) (r R, ok bool)

Dec 19, 2023

Changes in this version

+ func CallInDefRec[P, R any](c C, p P, f func(C, P) R) R

Dec 18, 2023

Changes in this version

+ func GoR[P, R any](c C, p P, f func(C, P) R) <-chan R

+ func Go[P any](c C, p P, f func(C, P))

Dec 6, 2023

Changes in this version

+ func In[S comparable](s []S, e S) bool

+ func Unique[S comparable](s []S) []S

+ type StateFunc func(pre S) S

+ type StateMachine struct

+ func NewStateMachineByMap[S comparable](m map[S]StateFunc[S]) *StateMachine[S]

+ func NewStateMachine[S comparable](states []S) *StateMachine[S]

+ func (m *StateMachine[S]) Run(s S) S

+ func (m *StateMachine[S]) WithFunc(s S, f StateFunc[S])

Dec 5, 2023

Changes in this version

type Claims

+ Nonce string

Nov 29, 2023

Changes in this version

+ type HandlerFunc func(T)

+ func (h HandlerFunc[T]) HTTPHandlerFunc(t T) http.HandlerFunc

+ type Route struct

+ Childs []*Route[T]

+ Comment string

+ Handler HandlerFunc[T]

+ Method string

+ Path string

+ func NewRoute[T any](method, path, comment string, h HandlerFunc[T], childs ...*Route[T]) *Route[T]

+ func (r *Route[T]) SetChilds(childs ...*Route[T]) *Route[T]

+ func (r *Route[T]) WithChilds(childs ...*Route[T]) *Route[T]

Nov 21, 2023

Changes in this version

+ type Entity struct

+ Id U

+ Name string

+ type TreeEntity struct

+ Childs []Entity[U]

Nov 20, 2023

Changes in this version

+ type IdsType struct

+ Ids []T

+ type ListResult struct

+ List []T

Nov 13, 2023

Changes in this version

+ type IdType struct

+ Id T

Nov 13, 2023

Changes in this version

+ type PageResult struct

+ List []T

+ Total int64

Nov 9, 2023

Changes in this version

+ type EntityWithTotal struct

+ Inner T

+ Total int

+ func (s *EntityWithTotal[T]) ValuePtrs() []any

Nov 8, 2023

Changes in this version

+ func AssertSlice(handler AssertHandler, lslice, rslice []T, msgAndArgs ...any)

Nov 7, 2023

Changes in this version

+ var ErrBadIssuer = errors.New("Token Bad Issuer")

+ var ErrExpired = errors.New("Token Expired")

+ var ErrNotValid = errors.New("Token Not Valid")

+ type Claims struct

+ User T

+ type Token struct

+ func New(secret []byte, exp time.Duration, issuer string) *Token[T]

+ func (t *Token[T]) Sign(user T) (string, error)

+ func (t *Token[T]) Verify(tokenString string) (user T, err error)

Nov 7, 2023

Changes in this version

+ const DateFormat

+ const DateTimeFormat

+ var Location = time.FixedZone("CST", 8 * 3600)

+ type Crypto struct

+ func NewCrypto(key string) (*Crypto, error)

+ func (e Crypto) Decrypt(r string) (money string, err error)

+ func (e Crypto) Encrypt(money string) (r string, err error)

+ type Id uint64

+ func (id *Id) UnmarshalJSON(data []byte) error

+ func (id Id) MarshalJSON() ([]byte, error)

+ type Pager struct

+ Page int

+ PageSize int

+ type Password string

+ func (p Password) Compare(hash string) error

+ func (p Password) Encrypt() (pp string, err error)

+ func (p Password) String() string

Oct 27, 2023

Changes in this version

+ func ConvByName(from F, to T)

+ func ConvSliceByName(from []F, to []T)

+ func MakeSlice(l int) (to []*T)

Oct 26, 2023

Changes in this version

+ func FieldWithAlias(field, alias, defaultAlias string) string

+ func WithWhere(t T, cond func(field string, value interface{}) string, field string, ...) string

Oct 24, 2023

Changes in this version

+ func Ignore1(a1 T1, i T2) T1

+ func Ignore2(a1 T1, a2 T2, i T3) (T1, T2)

+ func Ignore3(a1 T1, a2 T2, a3 T3, i T4) (T1, T2, T3)

+ func Ignore4(a1 T1, a2 T2, a3 T3, a4 T4, i T5) (T1, T2, T3, T4)

+ func Ignore5(a1 T1, a2 T2, a3 T3, a4 T4, a5 T5, i T6) (T1, T2, T3, T4, T5)

Oct 11, 2023

Changes in this version

+ func WrapTxV(ctx context.Context, db *sql.DB, ...) (r R, err error)

Oct 10, 2023

Changes in this version

+ func Ceil(x float64, p int) float64

+ func Floor(x float64, p int) float64

+ func Round(x float64, p int) float64

Sep 13, 2023

Changes in this version

type FindFunc

+ func FindFuncHelper(query string, args []any, fieldMappers ...func(string) string) FindFunc[T]

Sep 11, 2023

Changes in this version

+ type Enum struct

+ Name string

+ Value T

Sep 8, 2023

Changes in this version

+ func ObjectAndFieldsHelper(fieldMappers ...func(string) string) func(colTypes []*sql.ColumnType) (r *T, fields []any)

Sep 8, 2023

Changes in this version

+ func JoinUint(parts []uint64) (n uint64)

+ func Pow10(n int) (r uint64)

+ func SplitUint(n uint64) []uint64

Sep 1, 2023

Changes in this version

+ type ContextHelper struct

+ func NewContextHelper() *ContextHelper[K, V]

+ func (h *ContextHelper[K, V]) MustValue(ctx context.Context) (v V)

+ func (h *ContextHelper[K, V]) Value(ctx context.Context) (v V, ok bool)

+ func (h *ContextHelper[K, V]) WithValue(ctx context.Context, v V) context.Context

Aug 29, 2023

Changes in this version

+ func BatchRun(s []T, batchNum int, handler func([]T) error) (err error)

+ func StreamRun(s chan T, batchNum int, handler func([]T) error) (err error)

Aug 29, 2023

Changes in this version

+ func ExecWithBatch(db S, q Q) (ra, lid int64, err error)

+ func FindWithBatch(db S, finder F, res *[]R) (err error)

+ type BatchFinder interface

+ type BatchQueryer interface

+ type Batcher interface

+ Batch func() [][]any

+ type Queryer interface

+ Query func() (query string, args []any)

type Storer

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

Jul 24, 2023

Changes in this version

+ func RegisterRouter(g H, rh RH, method, path string, f func(context.Context, P) (R, error))

+ type RouteHandler interface

+ Parse func(req *http.Request, p *P) error

+ Write func(w http.ResponseWriter, r R, err error)

+ type RouteRegister interface

+ Handle func(method, path string, handlers http.HandlerFunc)

Jul 12, 2023

Changes in this version

+ func Assert(handler AssertHandler, l, r T, msgAndArgs ...any)

+ func Equal(l, r T) bool

+ type AssertHandler interface

+ Errorf func(format string, args ...any)

Jul 12, 2023

Changes in this version

+ func Log(err error)

+ func Log1(a1 T, err error) T

+ func Log2(a1 T1, a2 T2, err error) (T1, T2)

+ func Log3(a1 T1, a2 T2, a3 T3, err error) (T1, T2, T3)

+ func Log4(a1 T1, a2 T2, a3 T3, a4 T4, err error) (T1, T2, T3, T4)

+ func Log5(a1 T1, a2 T2, a3 T3, a4 T4, a5 T5, err error) (T1, T2, T3, T4, T5)

Jul 4, 2023

Changes in this version

+ var ErrOpenState = errors.New("circuit breaker is open")

+ var ErrTooManyRequests = errors.New("too many requests")

+ type CircuitBreaker struct

+ func NewCircuitBreaker(st Settings) *CircuitBreaker[P, R]

+ func (cb *CircuitBreaker[P, R]) Counts() Counts

+ func (cb *CircuitBreaker[P, R]) Execute(param P, req func(p P) (R, error)) (r R, err error)

+ func (cb *CircuitBreaker[P, R]) Name() string

+ func (cb *CircuitBreaker[P, R]) State() State

+ type Counts struct

+ ConsecutiveFailures uint32

+ ConsecutiveSuccesses uint32

+ Requests uint32

+ TotalFailures uint32

+ TotalSuccesses uint32

+ type Settings struct

+ Interval time.Duration

+ IsSuccessful func(err error) bool

+ MaxRequests uint32

+ Name string

+ OnStateChange func(name string, from State, to State)

+ ReadyToTrip func(counts Counts) bool

+ Timeout time.Duration

+ type State int

+ const StateClosed

+ const StateHalfOpen

+ const StateOpen

+ func (s State) String() string

+ type TwoStepCircuitBreaker struct

+ func NewTwoStepCircuitBreaker(st Settings) *TwoStepCircuitBreaker[P, R]

+ func (tscb *TwoStepCircuitBreaker[P, R]) Allow() (done func(success bool), err error)

+ func (tscb *TwoStepCircuitBreaker[P, R]) Counts() Counts

+ func (tscb *TwoStepCircuitBreaker[P, R]) Name() string

+ func (tscb *TwoStepCircuitBreaker[P, R]) State() State

Jun 26, 2023

Changes in this version

+ type Ioc struct

+ func NewIoc(opt *IocOption) *Ioc

+ func (ioc *Ioc) Inject(v any) (err error)

+ func (ioc *Ioc) RegisterProvider(v any) (err error)

+ type IocOption struct

+ EnableUnexportedFieldSetValue bool

+ Print bool

Jun 21, 2023

Changes in this version

+ func IsValidIP(ip string) bool

+ type DecodeFunc func(src T, v any) error

+ func (f DecodeFunc[T]) Decode(src T, v any) error

+ type Decoder interface

+ Decode func(src T, v any) error

+ type ParamData interface

+ type ParamParser struct

+ func NewParamParser(decoder Decoder[T]) *ParamParser[T]

+ func (p *ParamParser[T]) Parse(data T, v any) error

+ func (p *ParamParser[T]) ParseAndCheck(ctx context.Context, data T, v any) error

Jun 15, 2023

Changes in this version

+ func AsOk(v any) (T, bool)

+ func HTTPProxy(localAddr, remoteAddr string, opt *HTTPProxyOption) (err error)

+ func PtrTo(v T) *T

+ func Zero() T

+ type HTTPProxyOption struct

+ Director func(req *http.Request)

+ ErrorHandler func(w http.ResponseWriter, r *http.Request, err error)

+ ModifyResponse func(r *http.Response) error

Jun 12, 2023

Changes in this version

+ type TraceId string

Jun 8, 2023

Changes in this version

+ func EventLoop(ctx C, n int) (chan<- EventEntity[I, O, R], chan<- struct{})

+ func RawExtractor(data []byte) ([]byte, error)

+ type EventEntity struct

+ Do PipeFunc[I, O]

+ Failed func(E) R

+ Handler func(R)

+ Param I

+ Success func(O) R

+ type EventFunc func(ctx C, param I, do PipeFunc[I, O], success func(O) R, failed func(E) R) (r R)

Jun 6, 2023

Changes in this version

+ func Event(ctx C, param I, do PipeFunc[I, O], success func(O) R, failed func(E) R) (r R)

+ type C = context.Context

+ type E = error

+ func Pipe(ctx C, b B, before PipeFunc[B, D], do PipeFunc[D, A], after PipeFunc[A, R]) (r R, err E)

+ type PipeFunc func(C, I) (O, E)

Jun 2, 2023

Changes in this version

+ func MultipartBody(body io.Writer, fieldname, filename string, data []byte) (fileContentType string, err error)

Jun 1, 2023

Changes in this version

+ type TraceKey struct

May 22, 2023

Changes in this version

+ type RespHeaderExtractor interface

+ Extract func(h http.Header)

May 19, 2023

Changes in this version

+ func TCPProxyDefaultHandler(lconn, rconn net.Conn)

May 19, 2023

Changes in this version

+ func TCPProxy(localAddr, remoteAddr string) (err error)

+ func TCPRecv(localAddr string, handler func(conn net.Conn)) (err error)

+ func TCPSend(remoteAddr string, handler func(conn net.Conn) error) (err error)

May 18, 2023

Changes in this version

+ func DayZero(t time.Time) time.Time

+ func MonthFirst(t time.Time) time.Time

+ func ParseTime(t string, layouts ...string) (r time.Time, err error)

+ func YearFirst(t time.Time) time.Time

May 17, 2023

Changes in this version

+ func SQLProcessRaw(funcs ...SQLQueryFunc) (query string, args []any)

May 17, 2023

Changes in this version

+ func SQLProcess(funcs ...SQLQueryFunc) (query SQLQuery, args SQLArgs)

+ type SQLArgs []any

+ func (a SQLArgs) Append(s SQLArgs) SQLArgs

+ func (a SQLArgs) Raw() []any

+ type SQLQuery string

+ func (q SQLQuery) Append(ss ...SQLQuery) (r SQLQuery)

+ func (q SQLQuery) Raw() string

+ type SQLQueryFunc func() (query SQLQuery, args SQLArgs)

May 15, 2023

Changes in this version

+ func FindFirstByFunc(db S, finder F, res *R) (err error)

+ func FindListByFunc(db S, finder F, res *[]R) (err error)

+ type FindFunc func() (query string, args []any, ...)

+ func (f FindFunc[R]) NewScanObjAndFields(colTypes []*sql.ColumnType) (r *R, fields []any)

+ func (f FindFunc[R]) Query() (query string, args []any)

May 8, 2023

Changes in this version

+ func MergeKeyValue(m1, m2 map[K]V) map[K]V

May 8, 2023

Changes in this version

+ func RegisterProxyMethod(pctx ProxyContext, cf ProxyCtxFunc, typeParams ...string)

type ProxyCtxFuncStore

+ func GlobalProxyCtxMap() *ProxyCtxFuncStore

May 6, 2023

Changes in this version

+ func ProxyTraceBegin(pctx ProxyContext) (stop func())

+ func RegisterProxyTracer(tracers ...Tracer)

+ type ProxyContext struct

+ InterfaceName string

+ MethodName string

+ PkgPath string

+ func (pctx ProxyContext) IsEmpty() bool

+ func (pctx ProxyContext) LogShortf(format string, args ...any)

+ func (pctx ProxyContext) Logf(format string, args ...any)

+ func (pctx ProxyContext) String() string

+ func (pctx ProxyContext) Uniq() string

+ type ProxyCtxFunc func(ctx ProxyContext, method any, args []any) (res []any)

+ type ProxyCtxFuncStore struct

+ func NewProxyCtxMap() *ProxyCtxFuncStore

+ func (m *ProxyCtxFuncStore) Lookup(pctx ProxyContext, typeParams ...string) (ProxyCtxFunc, bool)

+ func (m *ProxyCtxFuncStore) Set(pctx ProxyContext, f ProxyCtxFunc, typeParams ...string)

+ type TimeTracer struct

+ func (impl *TimeTracer) Begin()

+ func (impl *TimeTracer) New(pctx ProxyContext) Tracer

+ func (impl *TimeTracer) Stop()

+ type Tracer interface

+ Begin func()

+ New func(ProxyContext) Tracer

+ Stop func()

May 5, 2023

Changes in this version

+ func IsZero(v T) bool

+ func ThisMonthFirst() time.Time

+ func ThisYearFirst() time.Time

+ func TodayZero() time.Time

Apr 24, 2023

Changes in this version

+ func IsExpired(deadline, now time.Time) bool

+ type KeyOption struct

+ Timeout time.Duration

Apr 21, 2023

Changes in this version

+ func FieldsByColumnType(t any, colTypes []*sql.ColumnType, fieldMapper func(string) string) (fields []any)

Apr 20, 2023

Changes in this version

+ type Field struct

+ Comment string

+ Struct Struct

+ type Struct struct

+ Comment string

+ Description string

+ Fields []Field

+ Name string

+ Type reflect.Type

+ func MakeStruct() Struct

+ func ResolveStruct(value any) (Struct, error)

+ func (s Struct) GetFields() []Field

+ type StructCommentEntity struct

+ FieldComment map[string]string

+ StructComment map[string]string

+ StructName string

Apr 18, 2023

Changes in this version

+ func As(v any) T

+ func IsComparable()

+ func Keys(collection map[K]E) []K

+ func MkdirAllIfNotExist(dir string) error

+ func ValueAs(m *Map[K, any], key K) T

+ func Values(collection map[K]E) []E

Apr 4, 2023

Changes in this version

+ func ForgotKey(key string)

+ func SingleFlight(key string, fn SingleFlightCall[R]) (r R, err error)

+ type Map struct

+ func NewMap(size ...int) *Map[K, T]

+ func (m *Map[K, T]) Get(key K) (value T)

+ func (m *Map[K, T]) Insert(key K, value T)

+ func (m *Map[K, T]) Lookup(key K) (value T, ok bool)

+ func (m *Map[K, T]) Range(f func(key K, value T))

+ func (m *Map[K, T]) Remove(key K)

+ type SingleFlightCall func() (R, error)

+ type Slice struct

+ func NewSlice(lenAndCap ...int) *Slice[T]

+ func (s *Slice[T]) Append(values ...T)

+ func (s *Slice[T]) Index(i int) T

+ func (s *Slice[T]) Range(f func(item T, index int))

+ func (s *Slice[T]) Reset(lenAndCap ...int)

Apr 3, 2023

Changes in this version

+ var ErrNilDoer = errors.New("f is nil")

+ func BytesToString(b []byte) string

+ func RetryWithDeadline(ctx context.Context, d time.Time, f Doer) error

+ func RetryWithTimes(ctx context.Context, tryTimes int, f Doer) error

+ func StringToBytes(s string) []byte

+ type Doer = func(context.Context) (canRetry bool, err error)

Mar 31, 2023

Changes in this version

+ var DefaultWorker = NewWorker(defaultCount)

+ var ErrNilJobDo = errors.New("Job do field is nil")

+ var ErrWorkerIsStop = errors.New("Worker is stop")

+ func Batch(db S, finder F, batchNum int, handler func([]R) error) (err error)

+ func BatchConcurrent(db S, finder F, batchNum int, handler func([]R) error, concNum int) (err error)

+ func CodeIs200(code int) error

+ func FindAll(db S, finder F, inital R) (r []R, err error)

+ func FindFirst(db S, finder F, res *R) (err error)

+ func FindList(db S, finder F, res *[]R) (err error)

+ func FindOne(db S, finder F, inital R) (r R, err error)

+ func FuncName(skip int, withFileInfo bool) string

+ func HashJoin(left []LE, right []RE, lk func(item LE) K, rk func(item RE) K, ...) []R

+ func JSONExtractor(data []byte) (R, error)

+ func KeyBy(collection []E, iteratee func(item E) K) map[K]E

+ func KeyValueBy(collection []E, iteratee func(item E) (K, V)) map[K]V

+ func NestedJoin(left []J, right []K, match func(J, K) bool, mapper func(J, K) R) []R

+ func PrintFields(fields []any)

+ func SendHTTPRequest(client *http.Client, method string, link string, body io.Reader, ...) (R, error)

+ func WrapConnFindAll(ctx context.Context, db *sql.DB, finder F, inital R) (r []R, err error)

+ func WrapDB(ctx context.Context, driverName string, dataSourceName string, ...) error

+ func WrapSQLConn(ctx context.Context, db *sql.DB, ...) error

+ func WrapSQLQueryRows(ctx context.Context, db *sql.DB, stmt string, args []interface{}, ...) error

+ func WrapTx(ctx context.Context, db *sql.DB, f func(ctx context.Context, tx *sql.Tx) error) (err error)

+ func WrapTxFindAll(ctx context.Context, db *sql.DB, finder F, inital R) (r []R, err error)

+ func XMLExtractor(data []byte) (R, error)

+ type CodeChecker func(code int) error

+ type DoWithCtx func(ctx context.Context) error

+ type ErrorHandler func(error)

+ type Finder interface

+ NewScanObjAndFields func(colTypes []*sql.ColumnType) (r *R, fields []any)

+ Query func() (query string, args []any)

+ type Job struct

+ func NewJob(do DoWithCtx, timeout time.Duration, eh ErrorHandler) *Job

+ type ResultExtractor func(data []byte) (R, error)

+ type Storer interface

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ type Worker struct

+ func NewWorker(n int) *Worker

+ func (w *Worker) Push(job Job) error

+ func (w *Worker) Start()

+ func (w *Worker) Stop()

Mar 30, 2023

Changes in this version

+ func MatchError(v any) bool

+ func Must(args ...any)

+ func Must1(args ...any) (r T)

+ func Must2(args ...any) (r1 T1, r2 T2)

+ func Must3(args ...any) (r1 T1, r2 T2, r3 T3)

+ func Must4(args ...any) (r1 T1, r2 T2, r3 T3, r4 T4)

+ func Must5(args ...any) (r1 T1, r2 T2, r3 T3, r4 T4, r5 T5)

+ func NewError(inner T) error

+ type Error struct

+ func ConvertError(v any) (*Error[*e], bool)

+ func (e Error[T]) Error() string

+ func (e Error[T]) Inner() T