Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

types

package

Go to main page

Versions in this module

v0

v0.0.7

Mar 5, 2026

Changes in this version

type DbClient

+ RunInTransaction func(ctx context.Context, fn func(ctx context.Context) error) error

+ type DbContextExecutor interface

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

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

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

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

type DbProvider

+ Read func() DbClient

+ Write func() DbClient

+ type TxCtxKey struct

v0.0.6

Feb 25, 2026

v0.0.5

Jan 29, 2026

v0.0.2

Jan 29, 2026

v0.0.1

Jan 29, 2026

Changes in this version

+ var DefaultPublisherOption = &PublisherOption

+ var DefaultSubscriberOption = &SubscriberOption

+ type AppServer interface

+ HookPreStart func(fns ...HookFunction) AppServer

+ HookPreStop func(fns ...HookFunction) AppServer

+ Start func() error

+ Stop func(forced ...bool) error

+ type BulkOperateObjectRequest struct

+ Ids []TObjectId

+ type Capability struct

+ Category ProviderCategory

+ Module fx.Option

+ Name string

+ type ConfigProvider interface

+ Get func(key string) any

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

+ type CreateObjectResponse struct

+ Id TObjectId

+ type CreateRefObjectRequest struct

+ Id TObjectId

+ Item TBizObject

+ type DbBulkRetrieve interface

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

+ type DbClient interface

+ Close func() error

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

+ 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 TObjectId) error

+ type DbEdit interface

+ Edit func(bizObj TBizObject) 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 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 TObjectId) (TModelObject, error)

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

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

+ type DbUpdate interface

+ Update func(modelObj TModelObject) error

+ type DeleteRefObjectRequest struct

+ Id TObjectId

+ ItemId TObjectId

+ type EditRefObjectRequest struct

+ Id TObjectId

+ Item TBizObject

+ type GetRefObjectRequest struct

+ Id TObjectId

+ ItemId TObjectId

+ 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 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 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 ObjectIdentifier interface

+ type OperateObjectRequest struct

+ Id TObjectId

+ 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 Payload []byte

+ type Provider interface

+ GetCapability func() Capability

+ type ProviderCategory int

+ const ProviderCategoryConfig

+ const ProviderCategoryDb

+ const ProviderCategoryLogger

+ const ProviderCategoryMq

+ const ProviderCategoryOss

+ const ProviderCategoryRedis

+ const ProviderCategoryUnknown

+ type PublisherOption struct

+ PublishDelayMessage bool

+ 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

+ 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 TObjectId, refIds []TObjectId) (map[TObjectId]TRefModelObject, error)

+ type RefDbCreate interface

+ Create func(id TObjectId, refBizObj TRefBizObject) (TRefModelObject, error)

+ type RefDbDelete interface

+ Delete func(id, refId TObjectId) error

+ type RefDbEdit interface

+ Edit func(id TObjectId, refBizObj TRefBizObject) error

+ type RefDbOperation interface

+ type RefDbRetrieve interface

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

+ Get func(id, refId TObjectId) (TRefModelObject, error)

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

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

+ type RefDbUpdate interface

+ Update func(refObjModel TRefObjectModel) error

+ type ServiceCreate interface

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

+ type ServiceDelete interface

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

+ type ServiceOperation interface

+ type ServiceRetrieve interface

+ Get func(ctx biz.Context, id TObjectId) (TBizObject, error)

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

+ type ServiceUpdate interface

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

+ type SubscriberOption struct

+ SubscribeDelayMessage bool