types

Jan 21, 2026

Changes in this version

+ type BulkOperateObjectRequest struct

+ Ids []TObjectId

+ type CreateObjectResponse struct

+ Id TObjectId

+ type CreateRefObjectRequest struct

+ Id TObjectId

+ Item TBizObject

+ type DeleteRefObjectRequest struct

+ Id TObjectId

+ ItemId TObjectId

+ type EditRefObjectRequest struct

+ Id TObjectId

+ Item TBizObject

+ type GetRefObjectRequest struct

+ Id TObjectId

+ ItemId TObjectId

+ type ObjectIdentifier interface

+ type OperateObjectRequest struct

+ Id TObjectId

+ type QueryObjectRequest struct

+ Filters map[string]string

+ List *protobuf.ListParam

+ type QueryObjectResponse struct

+ Items []TBizObject

+ Total int64

+ type QueryRefObjectRequest struct

+ Filters map[string]string

+ Id TObjectId

+ List *protobuf.ListParam

+ type QueryRefObjectResponse struct

+ Items []TBizObject

+ Total int64

Oct 16, 2025

Changes in this version

+ type DbEdit interface

+ Edit func(bizObj BizObject) error

+ type DbExecutor interface

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ type RefDbEdit interface

+ Edit func(id int64, refBizObj RefBizObject) error

+ type ServiceCreate interface

+ Create func(ctx biz.Context, object BizObject) (int64, error)

+ type ServiceDelete interface

+ Delete func(ctx biz.Context, id int64) error

+ type ServiceOperation interface

+ type ServiceQueryResponse struct

+ Items []BizObject

+ Total int64

+ type ServiceRetrieve interface

+ Get func(ctx biz.Context, id int64) (BizObject, error)

+ Query func(ctx biz.Context, filters map[string]string, list *protobuf.ListParam) (int64, []BizObject, error)

+ type ServiceUpdate interface

+ Edit func(ctx biz.Context, bizObject BizObject) error

Sep 12, 2025

Changes in this version

+ type CtxKeyTid struct

+ type CtxKeyTx struct

Sep 6, 2025

Changes in this version

+ type AppServer interface

+ HookPreStart func(fns ...HookFunction) AppServer

+ HookPreStop func(fns ...HookFunction) AppServer

+ Start func() error

+ Stop func(forced ...bool) error

+ type BizSvcCreate interface

+ Create func(object BizObject) (int64, error)

+ type BizSvcDelete interface

+ Delete func(id int64) error

+ type BizSvcOperation interface

+ type BizSvcQueryResponse struct

+ Items []BizObject

+ Total int64

+ type BizSvcRetrieve interface

+ Get func(id int64) (BizObject, error)

+ Query func(filters map[string]string, list *protobuf.ListParam) (*BizSvcQueryResponse[BizObject], error)

+ type BizSvcUpdate interface

+ Edit func(BizObject) error

+ type ConfigProvider interface

+ Get func(key string) any

+ Unmarshal func(configVar any, key ...string) error

+ type DbBulkRetrieve interface

+ BulkGet func(ids []int64) (map[int64]ModelObject, error)

+ type DbClient interface

+ Close func() error

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Get func(dest interface{}, query string, args ...interface{}) error

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ Rebind func(query string) string

+ Select func(dest interface{}, query string, args ...interface{}) error

+ type DbCreate interface

+ Create func(bizObj BizObject) (ModelObject, error)

+ type DbDelete interface

+ Delete func(id int64) error

+ type DbFind interface

+ Find func(filters map[string]string) ([]ModelObject, error)

+ type DbOperation interface

+ type DbProvider interface

+ By func(name string) DbClient

+ Master func() DbClient

+ My func() DbClient

+ Slave func(i int) DbClient

+ type DbRetrieve interface

+ Count func(filters map[string]string) (int64, error)

+ Get func(id int64) (ModelObject, error)

+ GetQueryConditions func(filters map[string]string) []Condition

+ List func(filters map[string]string, list ...*protobuf.ListParam) ([]ModelObject, error)

+ type DbUpdate interface

+ Edit func(bizObj BizObject) error

+ Update func(modelObj ModelObject, columns map[string]any) (int64, error)

+ type HookFunction func() error

+ type LoggerProvider interface

+ Debug func(msg string, keyvals ...interface{})

+ Error func(msg string, keyvals ...interface{})

+ Fatal func(msg string, keyvals ...interface{})

+ GetStdLogger func() *log.Logger

+ Info func(msg string, keyvals ...interface{})

+ Log func(keyvals ...interface{}) error

+ Panic func(msg string, keyvals ...interface{})

+ Trace func(msg string, keyvals ...interface{})

+ Warn func(msg string, keyvals ...interface{})

+ type MessageQueueProvider interface

+ NewPublisher func(name string, args ...*PublisherOption) (MessageQueuePublisher, error)

+ NewSubscriber func(name string, args ...*SubscriberOption) (MessageQueueSubscriber, error)

+ type MessageQueuePublisher interface

+ Close func() error

+ Publish func(topic string, messages [][]byte, delaySeconds ...int64) error

+ type MessageQueueSubscriber interface

+ Close func() error

+ Subscribe func(ctx context.Context, topic string) (<-chan *Message, error)

+ type OssProvider interface

+ GetPostSignature func(dir, filename string) (map[string]string, error)

+ GetPresignedURL func(dir, filename, contentType string) (string, map[string]string, error)

+ Upload func(dir, filename string, data []byte) (string, error)

+ WithContentTypes func(contentTypes []string) OssProvider

+ WithMaxFileSize func(fileSize int64) OssProvider

+ WithSignExpiresIn func(duration time.Duration) OssProvider

type Provider

+ GetCapability func() Capability

+ type RedisClient interface

+ BfAdd func(key string, item string) (exists bool, err error)

+ BfAddMulti func(key string, items []interface{}) ([]int64, error)

+ BfExists func(key string, item string) (exists bool, err error)

+ BfExistsMulti func(key string, items []interface{}) ([]int64, error)

+ BfReserve func(key string, errorRate float64, capacity uint64) (err error)

+ DecrBy func(key string, number int) error

+ Del func(key string) error

+ Dels func(keys []string) error

+ Eval func(scriptContent string, keys []interface{}, args []interface{}) (interface{}, error)

+ Exists func(key string) (bool, error)

+ Expire func(key string, expire int) error

+ Get func(key string) ([]byte, error)

+ GetFloat64 func(key string) (float64, error)

+ GetInt func(key string) (int, error)

+ GetInt64 func(key string) (int64, error)

+ GetString func(key string) (string, error)

+ HDel func(key string, field interface{}) (int, error)

+ HDels func(key string, fields []interface{}) (int, error)

+ HGet func(key string, field any) ([]byte, error)

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

+ HGetFloat64 func(key string, field string) (float64, error)

+ HGetInt func(key string, field string) (int, error)

+ HGetInt64 func(key string, field string) (int64, error)

+ HGetString func(key string, field string) (string, error)

+ HLen func(key string) (int, error)

+ HMGet func(key string, fields []string) ([][]byte, error)

+ HMSet func(key string, args map[string]interface{}) error

+ HSet func(key string, field interface{}, value interface{}) (int, error)

+ Incr func(key string) error

+ IncrBy func(key string, number int) error

+ LLen func(key string) (int64, error)

+ LPush func(key string, values ...any) error

+ LRangeInt64 func(key string, start, end int64) ([]int64, error)

+ LRangeString func(key string, start, end int64) ([]string, error)

+ Ping func() error

+ Pipeline func(commands []*RedisCommand) (reply interface{}, err error)

+ RPop func(key string) ([]byte, error)

+ RPush func(key string, values ...any) error

+ SAdd func(key string, members interface{}) error

+ SDiff func(keys []string) ([]string, error)

+ SInter func(keys []string) ([]string, error)

+ SIsMember func(key string, member interface{}) (bool, error)

+ SMembers func(key string) ([]string, error)

+ SRem func(key string, members interface{}) error

+ SUnion func(keys []string) ([]string, error)

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

+ SetEx func(key string, value interface{}, expire int) error

+ Ttl func(key string) (int64, error)

+ ZAdd func(key string, score int64, member interface{}) error

+ ZCard func(key string) (int, error)

+ ZIncrBy func(key string, increment int64, member interface{}) error

+ ZInterstore func(newKey string, keys ...interface{}) (int64, error)

+ ZRange func(key string, min, max int64) ([]string, error)

+ ZRangeByScore func(key string, min, max interface{}, withScores bool, list *protobuf.ListParam) ([]string, error)

+ ZRem func(destKey string, members ...interface{}) (int64, error)

+ ZRemRangeByScore func(key string, min, max interface{}) error

+ ZScore func(key string, member interface{}) (int64, error)

+ type RedisCommand struct

+ Args []interface{}

+ Name string

+ type RedisProvider interface

+ By func(string) RedisClient

+ My func() RedisClient

+ type RefDbBulkRetrieve interface

+ BulkGet func(id int64, refIds []int64) (map[int64]ModelObject, error)

+ type RefDbCreate interface

+ Create func(id int64, refBizObj RefBizObject) (RefModelObject, error)

+ type RefDbDelete interface

+ Delete func(id int64, refId int64) error

+ type RefDbFind interface

+ Find func(id int64, refObjFilters map[string]string) (ModelObject, error)

+ type RefDbOperation interface

+ type RefDbRetrieve interface

+ Count func(id int64, refObjFilters map[string]string) (int64, error)

+ Get func(id, refId int64) (RefModelObject, error)

+ GetQueryConditions func(id int64, refObjFilters map[string]string) []Condition

+ List func(id int64, refObjFilters map[string]string, list ...*protobuf.ListParam) ([]RefModelObject, error)

+ type RefDbUpdate interface

+ Edit func(id int64, refBizObj RefBizObject) error

+ Update func(refModelObj RefModelObject, columns map[string]any) (int64, error)

Feb 28, 2025

Changes in this version

type ProviderCategory

+ const ProviderCategoryOss

type ProviderName

+ const ProviderNameMysqlSqlBoiler

+ const ProviderNameOssAliyun

+ const ProviderNameSqlite3SqlBoiler

Feb 22, 2025

Changes in this version

+ var DefaultPublisherOption = &PublisherOption

+ var DefaultSubscriberOption = &SubscriberOption

+ type Capability struct

+ Category ProviderCategory

+ Module fx.Option

+ Name ProviderName

+ type Message struct

+ Payload Payload

+ func NewMessage(payload Payload) *Message

+ func (m *Message) Ack() bool

+ func (m *Message) Acked() <-chan struct{}

+ func (m *Message) Context() context.Context

+ func (m *Message) Nack() bool

+ func (m *Message) Nacked() <-chan struct{}

+ func (m *Message) SetContext(ctx context.Context)

+ type Payload []byte

+ type Provider interface

+ Init func(args ...any) error

+ type ProviderCategory int

+ const ProviderCategoryConfig

+ const ProviderCategoryDb

+ const ProviderCategoryDbBuilder

+ const ProviderCategoryDbSqlx

+ const ProviderCategoryLogger

+ const ProviderCategoryMq

+ const ProviderCategoryRedis

+ const ProviderCategoryUnknown

+ type ProviderName string

+ const ProviderNameConfigViper

+ const ProviderNameDbSqlBoilerMysql

+ const ProviderNameDbSqlBoilerSqlite

+ const ProviderNameDbSqlxMysql

+ const ProviderNameDbSquirrelMysql

+ const ProviderNameLoggerZerolog

+ const ProviderNameMqRabbitMq

+ const ProviderNameRedisRedigo

+ type PublisherOption struct

+ PublishDelayMessage bool

+ type SdkConfig struct

+ App string

+ ConfigFilePath string

+ ConfigRootDirs []string

+ Debug bool

+ type SubscriberOption struct

+ SubscribeDelayMessage bool