types

package

Go to main page

Versions in this module

v0

v0.1.21

Jun 13, 2026

v0.1.20

Jun 12, 2026

v0.1.19

Jun 12, 2026

v0.1.18

Jun 6, 2026

Changes in this version

type ScopedCreateRequest

+ ScopedKey TScopedKey

type ScopedDeleteRequest

+ ScopedKey TScopedKey

type ScopedGetRequest

+ ScopedKey TScopedKey

type ScopedQueryRequest

+ ScopedKey TScopedKey

+ type ScopedServiceCreate interface

+ Create func(ctx context.Context, scopedKey TScopedKey, model TCreate) (TKey, error)

+ type ScopedServiceDelete interface

+ Delete func(ctx context.Context, scopedKey TScopedKey, itemKey TKey) error

+ type ScopedServiceGet interface

+ Get func(ctx context.Context, scopedKey TScopedKey, itemKey TKey) (TResult, error)

+ type ScopedServiceOperation interface

+ type ScopedServiceQuery interface

+ Query func(ctx context.Context, scopedKey TScopedKey, filters TFilter, ...) (int64, []TResult, error)

+ type ScopedServiceUpdate interface

+ Update func(ctx context.Context, scopedKey TScopedKey, model TUpdate) error

type ScopedUpdateRequest

+ ScopedKey TScopedKey

v0.1.17

Jun 6, 2026

Changes in this version

type DeleteRequest

+ Key TKey

+ type ScopedCreateRequest struct

+ Item TCreate

+ Key TScopedKey

+ type ScopedDeleteRequest struct

+ ItemKey TScopedKey

+ Key TScopedKey

+ type ScopedGetRequest struct

+ ItemKey TScopedKey

+ Key TScopedKey

+ type ScopedQueryRequest struct

+ Filters TFilter

+ Key TScopedKey

+ List *protobuf.ListParam

+ type ScopedUpdateRequest struct

+ Item TUpdate

+ Key TScopedKey

v0.1.16

Jun 6, 2026

v0.1.9

Jun 5, 2026

v0.1.8

Jun 5, 2026

Changes in this version

+ type UpdateRequest struct

+ Item TUpdateModel

v0.1.7

Jun 5, 2026

v0.1.6

Jun 5, 2026

Changes in this version

+ type CreateRequest struct

+ Item TCreateModel

+ type DeleteRequest struct

+ Keys []TKey

+ type EditRequest struct

+ Item TUpdateModel

+ type GetRequest struct

+ Key TKey

+ type KeyType interface

+ type QueryRequest struct

+ Filters TFilter

+ List *protobuf.ListParam

+ type QueryResponse struct

+ Items []TResult

+ Total int64

+ type RepoCount interface

+ Count func(ctx context.Context, filter TFilter) (int64, error)

+ type RepoGet interface

+ Get func(ctx context.Context, key TKey) (TModel, error)

+ type RepoList interface

+ List func(ctx context.Context, filter TFilter, list ...*protobuf.ListParam) ([]TModel, error)

+ type RepoOperation interface

+ type RepoQuery interface

+ type ScopedRepoCount interface

+ Count func(ctx context.Context, scopeKey TScopeKey, filters TFilter) (int64, error)

+ type ScopedRepoCreate interface

+ Create func(ctx context.Context, scopeKey TScopeKey, item TCreate) (TKey, error)

+ type ScopedRepoDelete interface

+ Delete func(ctx context.Context, scopeKey TScopeKey, keys ...TKey) (int64, error)

+ type ScopedRepoGet interface

+ Get func(ctx context.Context, scopeKey TScopeKey, key TKey) (TModel, error)

+ type ScopedRepoList interface

+ List func(ctx context.Context, scopeKey TScopeKey, filters TFilter, ...) ([]TModel, error)

+ type ScopedRepoOperation interface

+ type ScopedRepoUpdate interface

+ Update func(ctx context.Context, scopeKey TScopeKey, item TUpdate) error

v0.1.5

May 23, 2026

v0.1.4

May 22, 2026

v0.1.3

May 22, 2026

v0.1.2

May 22, 2026

v0.1.1

May 14, 2026

Changes in this version

+ type RepoBulkCreate interface

+ BulkCreate func(ctx context.Context, items []TModelObject) ([]TModelObject, error)

+ type RepoBulkGet interface

+ BulkGet func(ctx context.Context, ids []TObjectKey) (map[TObjectKey]TModelObject, error)

+ type RepoCRUD interface

+ type RepoCRUDFull interface

+ type RepoCRUDWithBulk interface

+ type RepoCreate interface

+ Create func(ctx context.Context, bizObj TBizObject) (TModelObject, error)

+ type RepoDelete interface

+ Delete func(ctx context.Context, key TObjectKey) error

+ type RepoEdit interface

+ Edit func(ctx context.Context, bizObj TBizObject) (TModelObject, error)

+ type RepoRetrieve interface

+ Count func(ctx context.Context, filters map[string]string) (int64, error)

+ Get func(ctx context.Context, key TObjectKey) (TModelObject, error)

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

+ type RepoUpdate interface

+ Update func(ctx context.Context, modelObj TModelObject) error

+ type RepoUpsert interface

+ Upsert func(ctx context.Context, bizObj TBizObject) (TModelObject, error)

+ type ServiceBulkCreate interface

+ BulkCreate func(ctx context.Context, items []TModelObject) ([]TModelObject, error)

+ type ServiceBulkGet interface

+ BulkGet func(ctx context.Context, ids []TObjectKey) (map[TObjectKey]TModelObject, error)

+ type ServiceEdit interface

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

type ServiceUpdate

+ Update func(ctx context.Context, modelObj TModelObject) error

v0.1.0

May 8, 2026

v0.0.15

May 7, 2026

v0.0.14

May 7, 2026

v0.0.13

Apr 25, 2026

v0.0.12

Apr 22, 2026

v0.0.11

Apr 22, 2026

Changes in this version

type BulkOperateObjectRequest

+ Keys []TObjectKey

type CreateRefObjectRequest

+ Key TObjectKey

type DeleteRefObjectRequest

+ ItemKey TObjectKey

+ Key TObjectKey

type EditRefObjectRequest

+ Key TObjectKey

type GetRefObjectRequest

+ ItemKey TObjectKey

+ Key TObjectKey

+ type ObjectKeyType interface

type OperateObjectRequest

+ Key TObjectKey

type QueryRefObjectRequest

+ Key TObjectKey

+ type ServiceGet interface

+ Get func(ctx biz.Context, key TObjectKey) (TBizObject, error)

+ type ServiceQuery interface

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

v0.0.10

Apr 1, 2026

v0.0.9

Mar 19, 2026

v0.0.8

Mar 13, 2026

Changes in this version

type DbClient

+ SqlDB func() *sql.DB

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL