business

Documentation

Index

• type AegisResource
  • func NewAegisResource(d *dao.Dao, appid string, c *conf.Config) (a *AegisResource)
  • func (a *AegisResource) AllMessages(c context.Context) (length int, err error)
  • func (a *AegisResource) BulkIndex(c context.Context, start, end int, writeEntityIndex bool) (err error)
  • func (a *AegisResource) Business() string
  • func (a *AegisResource) Commit(c context.Context) (err error)
  • func (a *AegisResource) IncrMessages(c context.Context) (length int, err error)
  • func (a *AegisResource) InitIndex(c context.Context)
  • func (a *AegisResource) InitOffset(c context.Context)
  • func (a *AegisResource) Offset(c context.Context)
  • func (a *AegisResource) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)
  • func (a *AegisResource) Size(c context.Context) int
  • func (a *AegisResource) Sleep(c context.Context)
• type Avr
  • func NewAvr(d *dao.Dao, appid string, c *conf.Config) (a *Avr)
  • func (a *Avr) AllMessages(c context.Context) (length int, err error)
  • func (a *Avr) BulkIndex(c context.Context, start, end int, writeEntityIndex bool) (err error)
  • func (a *Avr) Business() string
  • func (a *Avr) Commit(c context.Context) (err error)
  • func (a *Avr) IncrMessages(c context.Context) (length int, err error)
  • func (a *Avr) InitIndex(c context.Context)
  • func (a *Avr) InitOffset(c context.Context)
  • func (a *Avr) Offset(c context.Context)
  • func (a *Avr) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)
  • func (a *Avr) Size(c context.Context) int
  • func (a *Avr) Sleep(c context.Context)
• type AvrArchive
  • func NewAvrArchive(d *dao.Dao, appid string) (av *AvrArchive)
  • func (av *AvrArchive) AllMessages(c context.Context) (length int, err error)
  • func (av *AvrArchive) BulkIndex(c context.Context, start int, end int, writeEntityIndex bool) (err error)
  • func (av *AvrArchive) Business() string
  • func (av *AvrArchive) Commit(c context.Context) (err error)
  • func (av *AvrArchive) IncrMessages(c context.Context) (length int, err error)
  • func (av *AvrArchive) InitIndex(c context.Context)
  • func (av *AvrArchive) InitOffset(c context.Context)
  • func (av *AvrArchive) Offset(c context.Context)
  • func (av *AvrArchive) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)
  • func (av *AvrArchive) Size(c context.Context) int
  • func (av *AvrArchive) Sleep(c context.Context)
• type DmDate
  • func NewDmDate(d *dao.Dao, appid string) (dd *DmDate)
  • func (dd *DmDate) AllMessages(c context.Context) (length int, err error)
  • func (dd *DmDate) BulkIndex(c context.Context, start int, end int, writeEntityIndex bool) (err error)
  • func (dd *DmDate) Business() string
  • func (dd *DmDate) Commit(c context.Context) (err error)
  • func (dd *DmDate) IncrMessages(c context.Context) (length int, err error)
  • func (dd *DmDate) InitIndex(c context.Context)
  • func (dd *DmDate) InitOffset(c context.Context)
  • func (dd *DmDate) Offset(c context.Context)
  • func (dd *DmDate) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)
  • func (dd *DmDate) Size(c context.Context) int
  • func (dd *DmDate) Sleep(c context.Context)
• type Log
  • func NewLog(d *dao.Dao, appid string) (l *Log)
  • func (l *Log) AllMessages(c context.Context) (length int, err error)
  • func (l *Log) Attrs(c context.Context) (attrs *model.Attrs)
  • func (l *Log) BulkIndex(c context.Context, start, end int, writeEntityIndex bool) (err error)
  • func (l *Log) Business() string
  • func (l *Log) Commit(c context.Context) (err error)
  • func (l *Log) IncrMessages(c context.Context) (length int, err error)
  • func (l *Log) InitIndex(c context.Context)
  • func (l *Log) InitOffset(c context.Context)
  • func (l *Log) MapData(c context.Context) (mapData []model.MapData)
  • func (l *Log) Offset(c context.Context)
  • func (l *Log) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)
  • func (l *Log) Size(c context.Context) (size int)
  • func (l *Log) Sleep(c context.Context)

Types

type AegisResource

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

AegisResource single table consume databus.

func NewAegisResource

func NewAegisResource(d *dao.Dao, appid string, c *conf.Config) (a *AegisResource)

NewAppDatabus .

func (*AegisResource) AllMessages

func (a *AegisResource) AllMessages(c context.Context) (length int, err error)

AllMessages .

func (*AegisResource) BulkIndex

func (a *AegisResource) BulkIndex(c context.Context, start, end int, writeEntityIndex bool) (err error)

BulkIndex .

func (*AegisResource) Business

func (a *AegisResource) Business() string

Business return business.

func (*AegisResource) Commit

func (a *AegisResource) Commit(c context.Context) (err error)

Commit commit offset.

func (*AegisResource) IncrMessages

func (a *AegisResource) IncrMessages(c context.Context) (length int, err error)

IncrMessages .

func (*AegisResource) InitIndex

func (a *AegisResource) InitIndex(c context.Context)

InitIndex init index.

func (*AegisResource) InitOffset

func (a *AegisResource) InitOffset(c context.Context)

InitOffset insert init value to offset.

func (*AegisResource) Offset

func (a *AegisResource) Offset(c context.Context)

Offset get offset.

func (*AegisResource) SetRecover

func (a *AegisResource) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)

SetRecover set recover

func (*AegisResource) Size

func (a *AegisResource) Size(c context.Context) int

Size return size.

func (*AegisResource) Sleep

func (a *AegisResource) Sleep(c context.Context)

Sleep interval duration.

type Avr

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

Avr single table consume databus.

func NewAvr

func NewAvr(d *dao.Dao, appid string, c *conf.Config) (a *Avr)

NewAvr .

func (*Avr) AllMessages

func (a *Avr) AllMessages(c context.Context) (length int, err error)

AllMessages .

func (*Avr) BulkIndex

func (a *Avr) BulkIndex(c context.Context, start, end int, writeEntityIndex bool) (err error)

BulkIndex .

func (*Avr) Business

func (a *Avr) Business() string

Business return business.

func (*Avr) Commit

func (a *Avr) Commit(c context.Context) (err error)

Commit commit offset.

func (*Avr) IncrMessages

func (a *Avr) IncrMessages(c context.Context) (length int, err error)

IncrMessages .

func (*Avr) InitIndex

func (a *Avr) InitIndex(c context.Context)

InitIndex init index.

func (*Avr) InitOffset

func (a *Avr) InitOffset(c context.Context)

InitOffset insert init value to offset.

func (*Avr) Offset

func (a *Avr) Offset(c context.Context)

Offset get offset.

func (*Avr) SetRecover

func (a *Avr) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)

SetRecover set recover

func (*Avr) Size

func (a *Avr) Size(c context.Context) int

Size return size.

func (*Avr) Sleep

func (a *Avr) Sleep(c context.Context)

Sleep interval duration.

type AvrArchive

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

AvrArchive .

func NewAvrArchive

func NewAvrArchive(d *dao.Dao, appid string) (av *AvrArchive)

NewAvrArchive .

func (*AvrArchive) AllMessages

func (av *AvrArchive) AllMessages(c context.Context) (length int, err error)

AllMessages .

func (*AvrArchive) BulkIndex

func (av *AvrArchive) BulkIndex(c context.Context, start int, end int, writeEntityIndex bool) (err error)

BulkIndex .

func (*AvrArchive) Business

func (av *AvrArchive) Business() string

Business return business.

func (*AvrArchive) Commit

func (av *AvrArchive) Commit(c context.Context) (err error)

Commit commit offset.

func (*AvrArchive) IncrMessages

func (av *AvrArchive) IncrMessages(c context.Context) (length int, err error)

IncrMessages .

func (*AvrArchive) InitIndex

func (av *AvrArchive) InitIndex(c context.Context)

InitIndex init index.

func (*AvrArchive) InitOffset

func (av *AvrArchive) InitOffset(c context.Context)

InitOffset insert init value to offset.

func (*AvrArchive) Offset

func (av *AvrArchive) Offset(c context.Context)

Offset get offset.

func (*AvrArchive) SetRecover

func (av *AvrArchive) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)

SetRecover set recover

func (*AvrArchive) Size

func (av *AvrArchive) Size(c context.Context) int

Size return size.

func (*AvrArchive) Sleep

func (av *AvrArchive) Sleep(c context.Context)

Sleep interval duration.

type DmDate

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

DmDate .

func NewDmDate

func NewDmDate(d *dao.Dao, appid string) (dd *DmDate)

NewDmDate .

func (*DmDate) AllMessages

func (dd *DmDate) AllMessages(c context.Context) (length int, err error)

AllMessages .

func (*DmDate) BulkIndex

func (dd *DmDate) BulkIndex(c context.Context, start int, end int, writeEntityIndex bool) (err error)

BulkIndex .

func (*DmDate) Business

func (dd *DmDate) Business() string

Business return business.

func (*DmDate) Commit

func (dd *DmDate) Commit(c context.Context) (err error)

Commit commit offset.

func (*DmDate) IncrMessages

func (dd *DmDate) IncrMessages(c context.Context) (length int, err error)

IncrMessages .

func (*DmDate) InitIndex

func (dd *DmDate) InitIndex(c context.Context)

InitIndex init index.

func (*DmDate) InitOffset

func (dd *DmDate) InitOffset(c context.Context)

InitOffset .

func (*DmDate) Offset

func (dd *DmDate) Offset(c context.Context)

Offset get offset.

func (*DmDate) SetRecover

func (dd *DmDate) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)

SetRecover set recover

func (*DmDate) Size

func (dd *DmDate) Size(c context.Context) int

Size return size.

func (*DmDate) Sleep

func (dd *DmDate) Sleep(c context.Context)

Sleep interval duration.

type Log

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

Log .

func NewLog

func NewLog(d *dao.Dao, appid string) (l *Log)

NewLog .

func (*Log) AllMessages

func (l *Log) AllMessages(c context.Context) (length int, err error)

AllMessages .

func (*Log) Attrs

func (l *Log) Attrs(c context.Context) (attrs *model.Attrs)

Attrs .

func (*Log) BulkIndex

func (l *Log) BulkIndex(c context.Context, start, end int, writeEntityIndex bool) (err error)

BulkIndex .

func (*Log) Business

func (l *Log) Business() string

Business return business.

func (*Log) Commit

func (l *Log) Commit(c context.Context) (err error)

Commit .

func (*Log) IncrMessages

func (l *Log) IncrMessages(c context.Context) (length int, err error)

IncrMessages .

func (*Log) InitIndex

func (l *Log) InitIndex(c context.Context)

InitIndex .

func (*Log) InitOffset

func (l *Log) InitOffset(c context.Context)

InitOffset .

func (*Log) MapData

func (l *Log) MapData(c context.Context) (mapData []model.MapData)

MapData .

func (*Log) Offset

func (l *Log) Offset(c context.Context)

Offset .

func (*Log) SetRecover

func (l *Log) SetRecover(c context.Context, recoverID int64, recoverTime string, i int)

SetRecover .

func (*Log) Size

func (l *Log) Size(c context.Context) (size int)

Size .

func (*Log) Sleep

func (l *Log) Sleep(c context.Context)

Sleep .