dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (d *Dao)
  • func (d *Dao) BeginTx(c context.Context) (*sql.Tx, error)
  • func (d *Dao) DelDocumentCache(ctx context.Context, checkSum int64) (err error)
  • func (d *Dao) DelUserConfCache(ctx context.Context, mid int64, moduleKey int) (err error)
  • func (d *Dao) Document(ctx context.Context, checkSum int64) (doc *model.Document, err error)
  • func (d *Dao) DocumentCache(ctx context.Context, checkSum int64) (data json.RawMessage, err error)
  • func (d *Dao) Ping(ctx context.Context) (err error)
  • func (d *Dao) SetDocumentCache(ctx context.Context, checkSum int64, data json.RawMessage) (err error)
  • func (d *Dao) SetUserConfCache(ctx context.Context, uc *model.UserConf) (err error)
  • func (d *Dao) TxUpDocuement(ctx context.Context, tx *sql.Tx, checkSum int64, data string, now time.Time) (err error)
  • func (d *Dao) TxUpUserConf(ctx context.Context, tx *sql.Tx, mid int64, moduleKey int, checkSum int64, ...) (err error)
  • func (d *Dao) UserConf(ctx context.Context, mid int64, moduleKey int) (userConf *model.UserConf, err error)
  • func (d *Dao) UserConfCache(ctx context.Context, mid int64, moduleKey int) (uc *model.UserConf, err error)

Types

type Dao

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

Dao kvo data access obj with bfs

func New

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

New new data access

func (*Dao) BeginTx

func (d *Dao) BeginTx(c context.Context) (*sql.Tx, error)

BeginTx begin trans

func (*Dao) DelDocumentCache

func (d *Dao) DelDocumentCache(ctx context.Context, checkSum int64) (err error)

DelDocumentCache remove memcache document detail

func (*Dao) DelUserConfCache

func (d *Dao) DelUserConfCache(ctx context.Context, mid int64, moduleKey int) (err error)

DelUserConfCache del user config cache

func (*Dao) Document

func (d *Dao) Document(ctx context.Context, checkSum int64) (doc *model.Document, err error)

Document get docuemtn

func (*Dao) DocumentCache

func (d *Dao) DocumentCache(ctx context.Context, checkSum int64) (data json.RawMessage, err error)

DocumentCache memcache get document(hash)

func (*Dao) Ping

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

Ping check if health

func (*Dao) SetDocumentCache

func (d *Dao) SetDocumentCache(ctx context.Context, checkSum int64, data json.RawMessage) (err error)

SetDocumentCache add document cache

func (*Dao) SetUserConfCache

func (d *Dao) SetUserConfCache(ctx context.Context, uc *model.UserConf) (err error)

SetUserConfCache set user config cache

func (*Dao) TxUpDocuement

func (d *Dao) TxUpDocuement(ctx context.Context, tx *sql.Tx, checkSum int64, data string, now time.Time) (err error)

TxUpDocuement add a document

func (*Dao) TxUpUserConf

func (d *Dao) TxUpUserConf(ctx context.Context, tx *sql.Tx, mid int64, moduleKey int, checkSum int64, now time.Time) (err error)

TxUpUserConf add or update user conf

func (*Dao) UserConf

func (d *Dao) UserConf(ctx context.Context, mid int64, moduleKey int) (userConf *model.UserConf, err error)

UserConf get userconf

func (*Dao) UserConfCache

func (d *Dao) UserConfCache(ctx context.Context, mid int64, moduleKey int) (uc *model.UserConf, err error)

UserConfCache user config cache