intf

package

Go to main page

Versions in this module

v0

v0.0.22

Jul 28, 2025

v0.0.21

Jul 28, 2025

Changes in this version

+ type DataAccessObject interface

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

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

+ Create func(businessObject) (int64, error)

+ Delete func(id int64) error

+ Edit func(businessObject) 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)

v0.0.20

Jul 25, 2025

Changes in this version

type DatabaseObject

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

v0.0.19

Jul 24, 2025

Changes in this version

+ type DatabaseObject interface

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

+ Create func(props map[string]any) (int64, error)

+ Delete func(id int64) error

+ Edit func(props map[string]any) error

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

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

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

v0.0.18

Jul 22, 2025

Changes in this version

type OssProvider

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

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

+ WithContentTypes func(contentTypes []string) OssProvider

+ WithMaxFileSize func(fileSize int64) OssProvider

+ WithSignExpiresIn func(duration time.Duration) OssProvider

v0.0.17

Jul 11, 2025

v0.0.16

Jul 9, 2025

v0.0.15

Jul 7, 2025

v0.0.14

Jul 7, 2025

v0.0.13

Jul 7, 2025

Changes in this version

type AppServer

+ HookPreStart func(fns ...HookFunction) AppServer

+ HookPreStop func(fns ...HookFunction) AppServer

v0.0.12

Jun 9, 2025

Changes in this version

type ConfigProvider

+ Get func(key string) any

v0.0.11

May 30, 2025

v0.0.10

May 16, 2025

v0.0.9

Apr 25, 2025

v0.0.8

Apr 23, 2025

Changes in this version

+ type AppServer interface

+ AddHook func(point HookPoint, fns ...HookFunction) AppServer

+ Start func() error

+ Stop func(forced ...bool) error

+ type HookFunction func() error

+ type HookPoint int

+ const HookPointBeforeStart

+ const HookPointBeforeStop

+ const HookPointUnknown

v0.0.7

Mar 17, 2025

v0.0.6

Mar 17, 2025

v0.0.5

Mar 15, 2025

Changes in this version

type Provider

+ GetCapability func() types.Capability

v0.0.4

Mar 15, 2025

Changes in this version

+ type Provider interface

+ GetCategory func() types.ProviderCategory

+ GetName func() string

v0.0.3

Feb 28, 2025

Changes in this version

+ type OssProvider interface

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

v0.0.2

Feb 26, 2025

v0.0.1

Feb 22, 2025

Changes in this version

+ type ConfigProvider interface

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

+ type DbBuilderClient interface

+ ToSql func() (string, []any, error)

+ XCount func() (int64, error)

+ XGet func(v any) error

+ XQuery func(args ...*protobuf.ListParam) (*sqlx.Rows, error)

+ XSelect func(v any, args ...*protobuf.ListParam) error

+ type DbBuilderProvider interface

+ By func(name string) DbBuilderClient

+ Master func() DbBuilderClient

+ My func() DbBuilderClient

+ Set func(sqlizer Sqlizer)

+ Slave func(i int) DbBuilderClient

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

+ By func(name string) DbClient

+ Master func() DbClient

+ My func() DbClient

+ Slave func(i int) DbClient

+ 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 ...*types.PublisherOption) (MessageQueuePublisher, error)

+ NewSubscriber func(name string, args ...*types.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 *types.Message, error)

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

+ ToSql func() (string, []interface{}, error)

+ type SqlxDbClient interface

+ Beginx func() (*sqlx.Tx, error)

+ Db func() *sqlx.DB

+ NamedExec func(query string, arg interface{}) (sql.Result, error)

+ Queryx func(query string, args ...interface{}) (*sqlx.Rows, error)

+ type SqlxDbProvider interface

+ By func(name string) SqlxDbClient

+ Master func() SqlxDbClient

+ My func() SqlxDbClient

+ Slave func(i int) SqlxDbClient

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