dao

package
v0.0.0-...-e89c34c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 27, 2024 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ProviderSet = wire.NewSet(
	NewMySQL,
	NewRedis,
	NewRedisCache,

	NewGlobal,
	NewApplication,
	NewToken,
	NewUser,
	NewTimer,
	NewTask,
)

Functions

func NewMySQL 

func NewMySQL(c *common.DataConfig, logger log.Logger) (*gorm.DB, func(), error)

func NewRedis 

func NewRedis(c *common.DataConfig, logger log.Logger) (*redis.Client, func(), error)

func NewRedisCache 

func NewRedisCache(redisClient *redis.Client) (goCache.Cache, error)

Types

type Application 

type Application struct {
	// contains filtered or unexported fields
}

func NewApplication 

func NewApplication(db *gorm.DB) *Application

func (*Application) Add 

func (s *Application) Add(ctx context.Context, in *models.Application, opts ...igorm.Option) error

func (*Application) CountByName 

func (s *Application) CountByName(ctx context.Context, name string, opts ...igorm.Option) (int64, error)

func (*Application) CountByNameWithInclude 

func (s *Application) CountByNameWithInclude(ctx context.Context, name, excludeId string, opts ...igorm.Option) (int64, error)

func (*Application) Delete 

func (s *Application) Delete(ctx context.Context, id string, opts ...igorm.Option) error

func (*Application) Find 

func (s *Application) Find(ctx context.Context, size int, offset string, opts ...igorm.Option) ([]*models.Application, string, error)

func (*Application) Get 

func (s *Application) Get(ctx context.Context, id string, opts ...igorm.Option) (*models.Application, error)

func (*Application) Update 

func (s *Application) Update(ctx context.Context, in *models.Application, opts ...igorm.Option) error

func (*Application) UpdateSecret 

func (s *Application) UpdateSecret(ctx context.Context, id, secret string, opts ...igorm.Option) error

func (*Application) UpdateStatus 

func (s *Application) UpdateStatus(ctx context.Context, id string, status v1.ApplicationStatus, opts ...igorm.Option) error

type Global 

type Global struct {
	// contains filtered or unexported fields
}

func NewGlobal 

func NewGlobal(db *gorm.DB) *Global

func (*Global) Add 

func (s *Global) Add(ctx context.Context, in *models.Global, opts ...igorm.Option) (int64, error)

func (*Global) DeleteByKey 

func (s *Global) DeleteByKey(ctx context.Context, namespace, name string, opts ...igorm.Option) error

func (*Global) GetByName 

func (s *Global) GetByName(ctx context.Context, namespace, name string, opts ...igorm.Option) (*models.Global, error)

func (*Global) UpsertByKey 

func (s *Global) UpsertByKey(ctx context.Context, in *models.Global, opts ...igorm.Option) error

type Task 

type Task struct {
	// contains filtered or unexported fields
}

func NewTask 

func NewTask(db *gorm.DB) *Task

func (*Task) Add 

func (s *Task) Add(ctx context.Context, in *models.Task, opts ...igorm.Option) (int64, error)

func (*Task) FindByTime 

func (s *Task) FindByTime(ctx context.Context, offset string, start, end time.Time, size int, status v1.TaskStatus, opts ...igorm.Option) ([]*models.Task, string, error)

func (*Task) FindByTimerId 

func (s *Task) FindByTimerId(ctx context.Context, timerId, offset string, size int, status v1.TaskStatus, opts ...igorm.Option) ([]*models.Task, string, error)

type TimerRecord 

type TimerRecord struct {
	// contains filtered or unexported fields
}

func NewTimer 

func NewTimer(db *gorm.DB) *TimerRecord

func (*TimerRecord) Add 

func (s *TimerRecord) Add(ctx context.Context, in *models.Timer, opts ...igorm.Option) error

func (*TimerRecord) Delete 

func (s *TimerRecord) Delete(ctx context.Context, id string, opts ...igorm.Option) error

func (*TimerRecord) Find 

func (s *TimerRecord) Find(ctx context.Context, size int, offset string, opts ...igorm.Option) ([]*models.Timer, string, error)

func (*TimerRecord) Get 

func (s *TimerRecord) Get(ctx context.Context, id string, opts ...igorm.Option) (*models.Timer, error)

func (*TimerRecord) Update 

func (s *TimerRecord) Update(ctx context.Context, in *models.Timer, opts ...igorm.Option) error

func (*TimerRecord) UpdateStatus 

func (s *TimerRecord) UpdateStatus(ctx context.Context, id string, status v1.TimerStatus, opts ...igorm.Option) error

type Token 

type Token struct {
	// contains filtered or unexported fields
}

func NewToken 

func NewToken(db *gorm.DB) *Token

func (*Token) Add 

func (s *Token) Add(ctx context.Context, in *models.Token, opts ...igorm.Option) error

func (*Token) GetByRefreshToken 

func (s *Token) GetByRefreshToken(ctx context.Context, in string, opts ...igorm.Option) (*models.Token, error)

func (*Token) Upsert 

func (s *Token) Upsert(ctx context.Context, in *models.Token, opts ...igorm.Option) error

type User 

type User struct {
	// contains filtered or unexported fields
}

func NewUser 

func NewUser(mysql *gorm.DB, redisClient *redis.Client) *User

func (*User) Add 

func (s *User) Add(ctx context.Context, in *models.User, opts ...igorm.Option) error

func (*User) CountByName 

func (s *User) CountByName(ctx context.Context, name string, opts ...igorm.Option) (int64, error)

func (*User) CountByNameWithInclude 

func (s *User) CountByNameWithInclude(ctx context.Context, name, excludeId string, opts ...igorm.Option) (int64, error)

func (*User) Delete 

func (s *User) Delete(ctx context.Context, id string, opts ...igorm.Option) error

func (*User) FindByOffset 

func (s *User) FindByOffset(ctx context.Context, size int, offset string, opts ...igorm.Option) ([]*models.User, string, error)

func (*User) FindByPage 

func (s *User) FindByPage(ctx context.Context, page, size int, opts ...igorm.Option) ([]*models.User, error)

func (*User) Get 

func (s *User) Get(ctx context.Context, id string, opts ...igorm.Option) (*models.User, error)

func (*User) GetByName 

func (s *User) GetByName(ctx context.Context, name string, opts ...igorm.Option) (*models.User, error)

func (*User) Update 

func (s *User) Update(ctx context.Context, in *models.User, opts ...igorm.Option) error

func (*User) UpdatePassword 

func (s *User) UpdatePassword(ctx context.Context, id, password string, opts ...igorm.Option) error

func (*User) UpdateStatus 

func (s *User) UpdateStatus(ctx context.Context, id string, status v1.UserStatus, opts ...igorm.Option) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.