dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (d *Dao)
  • func (d *Dao) AddAsoAccountsCloud(c context.Context, vs []*model.AsoAccount) (err error)
  • func (d *Dao) AddIgnoreAsoAccount(c context.Context, a *model.AsoAccount) (affected int64, err error)
  • func (d *Dao) AsoAccountRangeCloud(c context.Context, st, ed time.Time) (res []*model.AsoAccount, err error)
  • func (d *Dao) AsoAccountRangeLocal(c context.Context, st, ed time.Time) (res []*model.OriginAsoAccount, err error)
  • func (d *Dao) AsoAccountsCloud(c context.Context, vs []int64) (res []*model.AsoAccount, err error)
  • func (d *Dao) AsoAccountsLocal(c context.Context, vs []int64) (res []*model.OriginAsoAccount, err error)
  • func (d *Dao) Close() (err error)
  • func (d *Dao) Ping(c context.Context) (err error)
  • func (d *Dao) UpdateAsoAccountCloud(c context.Context, a *model.AsoAccount, mt time.Time) (affected int64, err error)

Types

type Dao

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

Dao dao

func New

func New(c *conf.Config) (d *Dao)

New new dao.

func (*Dao) AddAsoAccountsCloud

func (d *Dao) AddAsoAccountsCloud(c context.Context, vs []*model.AsoAccount) (err error)

AddAsoAccountsCloud batch add aso account to cloud.

func (*Dao) AddIgnoreAsoAccount

func (d *Dao) AddIgnoreAsoAccount(c context.Context, a *model.AsoAccount) (affected int64, err error)

AddIgnoreAsoAccount add ignore aso account.

func (*Dao) AsoAccountRangeCloud

func (d *Dao) AsoAccountRangeCloud(c context.Context, st, ed time.Time) (res []*model.AsoAccount, err error)

AsoAccountRangeCloud get aso account from cloud.

func (*Dao) AsoAccountRangeLocal

func (d *Dao) AsoAccountRangeLocal(c context.Context, st, ed time.Time) (res []*model.OriginAsoAccount, err error)

AsoAccountRangeLocal get aso account from local range start and end time.

func (*Dao) AsoAccountsCloud

func (d *Dao) AsoAccountsCloud(c context.Context, vs []int64) (res []*model.AsoAccount, err error)

AsoAccountsCloud get aso accounts from cloud.

func (*Dao) AsoAccountsLocal

func (d *Dao) AsoAccountsLocal(c context.Context, vs []int64) (res []*model.OriginAsoAccount, err error)

AsoAccountsLocal get aso accounts from origin.

func (*Dao) Close

func (d *Dao) Close() (err error)

Close close connections.

func (*Dao) Ping

func (d *Dao) Ping(c context.Context) (err error)

Ping check dao ok.

func (*Dao) UpdateAsoAccountCloud

func (d *Dao) UpdateAsoAccountCloud(c context.Context, a *model.AsoAccount, mt time.Time) (affected int64, err error)

UpdateAsoAccountCloud update aso account.