data

type Data struct {
	Redis *redis.Client
	Mongo *mongo.Client
}

type Message struct {
	// 插入时，务必设置为0，以使用 mongo的objectId，否则会大幅降低写入性能
	//ObjectId string                 `bson:"_id,omitempty"`
	Id      string                 `bson:"id,omitempty"`      // id，非mongo的对象id
	Seq     int64                  `bson:"seq,omitempty"`     // 连续递增序号
	Message map[string]interface{} `bson:"message,omitempty"` // 数据内容
}

type MessageRepo interface {
	Store(ctx context.Context, message *Message) (string, error)
	StoreBatch(ctx context.Context, messages []*Message) (failed []*Message, err error)
	Update(ctx context.Context, objId string, message *Message) error
	LoadById(ctx context.Context, objId string) (*Message, error)
	DeleteById(ctx context.Context, objId string) error

	Load(ctx context.Context, id string, seq int64) (*Message, error)
	Scan(ctx context.Context, id string, param ScanParameter) ([]Message, error)
}

type ScanParameter struct {
	From      int64 // 起始序号
	To        int64 // 结束序号
	MaxCount  int   // 一次性取出的最大数量
	IsForward bool  // 是否向前搜索
}

type SequenceCache interface {
	Incr(ctx context.Context, key string) (int64, error)
	GetLatest(ctx context.Context, key string) (int64, error)
}