gocom

Oct 26, 2023

Changes in this version

type Context

+ FormFile func(key string) (*multipart.FileHeader, error)

+ SaveFile func(key, path string) error

type FiberContext

+ func (o *FiberContext) FormFile(key string) (*multipart.FileHeader, error)

+ func (o *FiberContext) SaveFile(key, path string) error

Oct 17, 2023

Changes in this version

type Context

+ InvokeNativeCtx func(handlerFunc interface{}) error

type FiberContext

+ func (o *FiberContext) InvokeNativeCtx(handlerFunc interface{}) error

Jun 6, 2023

Changes in this version

type DistLock

+ Mode string

+ func TryLock(name string, ttl time.Duration) *DistLock

+ func (o *DistLock) IsExpired() bool

May 22, 2023

Changes in this version

+ type DistObjClient struct

+ func DistObj(name ...string) *DistObjClient

+ func (o *DistObjClient) AddImpl(className string, impl interface{}) error

+ func (o *DistObjClient) Invoke(className string, methodName string, param ...interface{}) ([]interface{}, error)

+ type DistObjReqMsg struct

+ Params []interface{}

+ type DistObjResMsg struct

+ ErrMsg string

+ IsErr bool

+ Result []interface{}

type NatsPubSubClient

+ func (o *NatsPubSubClient) Request(subject string, msg interface{}, timeOut ...time.Duration) (string, error)

+ func (o *NatsPubSubClient) RequestSubscribe(subject string, eventHandler PubSubReqEventHandler)

type PubSubClient

+ Request func(subject string, msg interface{}, timeOut ...time.Duration) (string, error)

+ RequestSubscribe func(subject string, eventHandler PubSubReqEventHandler)

+ type PubSubReqEventHandler func(name string, msg string) string

Mar 12, 2023

Changes in this version

type KeyValClient

+ Expire func(key string, ttl time.Duration) error

+ HDel func(key string, fields ...string) error

+ HGet func(key, field string) string

+ HGetAll func(key string) map[string]string

+ HSet func(key string, keyval ...interface{}) error

type RedisKeyVal

+ func (o *RedisKeyVal) Expire(key string, ttl time.Duration) error

+ func (o *RedisKeyVal) HDel(key string, fields ...string) error

+ func (o *RedisKeyVal) HGet(key, field string) string

+ func (o *RedisKeyVal) HGetAll(key string) map[string]string

+ func (o *RedisKeyVal) HSet(key string, keyval ...interface{}) error

Mar 10, 2023

Changes in this version

+ func AddCtrl(ctrl Controller)

+ func DB(name ...string) *gorm.DB

+ func DELETE(path string, handlers ...HandlerFunc)

+ func FileSecret(dsn string, key string) (string, error)

+ func GET(path string, handlers ...HandlerFunc)

+ func GetSecret(name string) (string, error)

+ func Logger() *zap.Logger

+ func NewJWT(data map[string]interface{}, ttl ...time.Duration) (string, error)

+ func PATCH(path string, handlers ...HandlerFunc)

+ func POST(path string, handlers ...HandlerFunc)

+ func PUT(path string, handlers ...HandlerFunc)

+ func RegAppCreator(name string, creator HttpAppCreatorFunc)

+ func RegDBCreator(typeName string, creator DBCreatorFunc)

+ func RegKeyValCreator(typeName string, creator KeyValCreatorFunc)

+ func RegPubSubCreator(typeName string, creator PubSubCreatorFunc)

+ func RegQueueCreator(typeName string, creator QueueCreatorFunc)

+ func RegSecretFunc(typeName string, secFunc SecretFunc)

+ func ReleaseLock(lock *DistLock) error

+ func Start()

+ func ValidateJWT(token string) (map[string]interface{}, error)

+ type App interface

+ Delete func(path string, handlers ...HandlerFunc)

+ Get func(path string, handlers ...HandlerFunc)

+ Patch func(path string, handlers ...HandlerFunc)

+ Post func(path string, handlers ...HandlerFunc)

+ Put func(path string, handlers ...HandlerFunc)

+ Start func()

+ type BaseRepo struct

+ ConnName string

+ func (o *BaseRepo) AutoMigrate(value interface{}) error

+ func (o *BaseRepo) Create(value interface{}) *gorm.DB

+ func (o *BaseRepo) Delete(value interface{}) *gorm.DB

+ func (o *BaseRepo) Exec(sql string, args ...interface{}) *gorm.DB

+ func (o *BaseRepo) Find(dest interface{}, conds ...interface{}) *gorm.DB

+ func (o *BaseRepo) First(dest interface{}, conds ...interface{}) *gorm.DB

+ func (o *BaseRepo) Model(value interface{}) *gorm.DB

+ func (o *BaseRepo) Raw(sql string, args ...interface{}) *gorm.DB

+ func (o *BaseRepo) Table(name string) *gorm.DB

+ func (o *BaseRepo) Update(value interface{}) *gorm.DB

+ func (o *BaseRepo) Where(query interface{}, args ...interface{}) *gorm.DB

+ type CodedError struct

+ Code int

+ Message string

+ func NewError(code int, msg string) *CodedError

+ func (o *CodedError) Error() string

+ type Context interface

+ Bind func(target interface{}) error

+ Body func() []byte

+ FormValue func(key string, defaulVal ...string) string

+ Get func(key string) interface{}

+ GetHeader func(key string) string

+ Next func() error

+ Param func(key string, defaulVal ...string) string

+ Query func(key string, defaulVal ...string) string

+ SendError func(err *CodedError) error

+ SendFile func(filePath string, fileName string) error

+ SendFileBytes func(data []byte, fileName string) error

+ SendJSON func(data interface{}) error

+ SendPaged func(data interface{}, currPage, totalPage int) error

+ SendResult func(data interface{}) error

+ SendString func(data string) error

+ Set func(key string, value interface{})

+ SetHeader func(key string, value string)

+ Status func(code int) Context

+ type Controller interface

+ Init func()

+ type DBCreatorFunc func(dsn string) (*gorm.DB, error)

+ type DistLock struct

+ Expire time.Time

+ ID string

+ Name string

+ func GetLock(name string, maxWait time.Duration, ttl time.Duration) *DistLock

+ func (o *DistLock) Release() error

+ type FiberApp struct

+ func (o *FiberApp) Delete(path string, handlers ...HandlerFunc)

+ func (o *FiberApp) Get(path string, handlers ...HandlerFunc)

+ func (o *FiberApp) Patch(path string, handlers ...HandlerFunc)

+ func (o *FiberApp) Post(path string, handlers ...HandlerFunc)

+ func (o *FiberApp) Put(path string, handlers ...HandlerFunc)

+ func (o *FiberApp) Start()

+ type FiberContext struct

+ func (o *FiberContext) Bind(target interface{}) error

+ func (o *FiberContext) Body() []byte

+ func (o *FiberContext) FormValue(key string, defaultVal ...string) string

+ func (o *FiberContext) Get(key string) interface{}

+ func (o *FiberContext) GetHeader(key string) string

+ func (o *FiberContext) Next() error

+ func (o *FiberContext) Param(key string, defaultVal ...string) string

+ func (o *FiberContext) Query(key string, defaultVal ...string) string

+ func (o *FiberContext) SendError(err *CodedError) error

+ func (o *FiberContext) SendFile(filePath string, fileName string) error

+ func (o *FiberContext) SendFileBytes(data []byte, fileName string) error

+ func (o *FiberContext) SendJSON(data interface{}) error

+ func (o *FiberContext) SendPaged(data interface{}, currPage, totalPage int) error

+ func (o *FiberContext) SendResult(data interface{}) error

+ func (o *FiberContext) SendString(data string) error

+ func (o *FiberContext) Set(key string, value interface{})

+ func (o *FiberContext) SetHeader(key, value string)

+ func (o *FiberContext) Status(code int) Context

+ type HandlerFunc func(ctx Context) error

+ type HttpAppCreatorFunc func() App

+ type KeyValClient interface

+ AtIndex func(key string, index int64) string

+ AtIndexInt func(key string, index int64) int

+ Del func(key string) error

+ Get func(key string) string

+ GetInt func(key string) int

+ LPop func(key string) string

+ LPopInt func(key string) int

+ LPush func(key string, val interface{}) error

+ Len func(key string) int64

+ RPop func(key string) string

+ RPopInt func(key string) int

+ RPush func(key string, val interface{}) error

+ Range func(key string, start int64, stop int64) []string

+ Set func(key string, val interface{}, ttl ...time.Duration) error

+ SetNX func(key string, val interface{}, ttl ...time.Duration) bool

+ func KeyVal(name ...string) KeyValClient

+ type KeyValCreatorFunc func(url string) (KeyValClient, error)

+ type NatsPubSubClient struct

+ func (o *NatsPubSubClient) Publish(subject string, msg interface{}) error

+ func (o *NatsPubSubClient) QueueSubscribe(subject string, queue string, eventHandler PubSubEventHandler)

+ func (o *NatsPubSubClient) Subscribe(subject string, eventHandler PubSubEventHandler)

+ type PubSubClient interface

+ Publish func(subject string, msg interface{}) error

+ QueueSubscribe func(subject string, queue string, eventHandler PubSubEventHandler)

+ Subscribe func(subject string, eventHandler PubSubEventHandler)

+ func PubSub(name ...string) PubSubClient

+ type PubSubCreatorFunc func(connString string) (PubSubClient, error)

+ type PubSubEventHandler func(name string, msg string)

+ type QueueClient interface

+ Consume func(name string, consumer QueueConsumerFunc) error

+ Publish func(name string, payload interface{}) error

+ func Queue(name ...string) QueueClient

+ type QueueConsumerFunc func(payload string)

+ type QueueCreatorFunc func(url string) (QueueClient, error)

+ type RedisKeyVal struct

+ func (o *RedisKeyVal) AtIndex(key string, index int64) string

+ func (o *RedisKeyVal) AtIndexInt(key string, index int64) int

+ func (o *RedisKeyVal) Del(key string) error

+ func (o *RedisKeyVal) Get(key string) string

+ func (o *RedisKeyVal) GetInt(key string) int

+ func (o *RedisKeyVal) LPop(key string) string

+ func (o *RedisKeyVal) LPopInt(key string) int

+ func (o *RedisKeyVal) LPush(key string, val interface{}) error

+ func (o *RedisKeyVal) Len(key string) int64

+ func (o *RedisKeyVal) RPop(key string) string

+ func (o *RedisKeyVal) RPopInt(key string) int

+ func (o *RedisKeyVal) RPush(key string, val interface{}) error

+ func (o *RedisKeyVal) Range(key string, start int64, stop int64) []string

+ func (o *RedisKeyVal) Set(key string, val interface{}, ttl ...time.Duration) error

+ func (o *RedisKeyVal) SetNX(key string, val interface{}, ttl ...time.Duration) bool

+ type RedisQueue struct

+ func (o *RedisQueue) Consume(name string, consumer QueueConsumerFunc) error

+ func (o *RedisQueue) Publish(name string, payload interface{}) error

+ type Result struct

+ Code int

+ Data interface{}

+ Messages string

+ type ResultPaged struct

+ CurrPage int

+ TotalPage int

+ type SecretFunc func(dsn string, key string) (string, error)