Versions in this module Expand all Collapse all v0 v0.0.3 Jan 29, 2023 v0.0.2 Jan 29, 2023 Changes in this version + type Auth interface + CreateByte16 func(context.Context, string, time.Duration, ...string) (string, error) + Expire func(context.Context, string, bool) error + List func(context.Context, func(AuthToken)) error + UpdateExpiry func(context.Context, string, time.Duration) error + UpdateScope func(context.Context, string, ...string) error + Valid func(context.Context, string, ...string) error + ValidByValue func(context.Context, string, ...string) (string, error) + type AuthToken interface + AccessAt func() time.Time + ExpireAt func() time.Time + Name func() string + Scope func() []string + Type func() string + Valid func(...string) error + type Collection interface + Delete func(context.Context, ...Filter) (int64, error) + DeleteMany func(context.Context, ...Filter) (int64, error) + Find func(context.Context, Sort, ...Filter) (any, error) + FindMany func(context.Context, Sort, ...Filter) (Cursor, error) + FindUpdate func(context.Context, any, Sort, ...Filter) (any, error) + Name func() string + Update func(context.Context, any, ...Filter) (int64, int64, error) + UpdateMany func(context.Context, any, ...Filter) (int64, int64, error) + type Conn interface + Database func(string) Database + Databases func(context.Context) ([]Database, error) + Do func(context.Context, func(context.Context) error) error + F func() Filter + Ping func(context.Context) error + S func() Sort + Timeout func() time.Duration + type CreateTable interface + type Cursor interface + Next func(context.Context) (any, error) + type Database interface + Collection func(any) Collection + Insert func(context.Context, ...any) error + Name func() string + type Filter interface + Eq func(string, any) error + Key func(string) error + type Name interface + As func(string) Name + CreateTable func(...Name) CreateTable + WithSchema func(string) Name + WithType func(string) Name + type Pool interface + Get func() Conn + Put func(Conn) + Size func() int + type Query interface + Query func() string + With func(QueryFlag) Query + type QueryFlag uint + const ASC + const AUTO_INCREMENT + const DESC + const IF_NOT_EXISTS + const NONE + const NOT_NULL + const ON_CONFLICT_ABORT + const ON_CONFLICT_FAIL + const ON_CONFLICT_IGNORE + const ON_CONFLICT_REPLACE + const ON_CONFLICT_ROLLBACK + const PRIMARY_KEY + const QUERY_CONFLICT + const QUERY_MAX + const QUERY_MIN + const QUERY_SORT + const STRICT + const TEMPORARY + const UNIQUE_KEY + const WITHOUT_ROWID + func (v QueryFlag) FlagString() string + func (v QueryFlag) Is(f QueryFlag) bool + func (v QueryFlag) String() string + type Sort interface + Asc func(...string) error + Desc func(...string) error + Limit func(int64) error + type Tag struct + Type TagType + Value any + func (t Tag) String() string + type TagType string + const TaskAge + const TaskCreatedAt + const TaskExpiresAt + const TaskLastError + const TaskPriority + const TaskRetryCount + const TaskScheduledAt + type Task interface + Key func() string + Namespace func() string + Tags func() []Tag + type TaskQueue interface + New func(context.Context, ...Tag) (Task, error) + Run func(context.Context, WorkerFunc) error + type WorkerFunc func(context.Context, Task) error
Go to main page