Documentation
¶
Index ¶
- type EsDocManager
- func (dm *EsDocManager) BulkUpsert(docs []interface{}, ns string, ts *primitive.Timestamp)
- func (dm *EsDocManager) Commit()
- func (dm *EsDocManager) GetLastDoc()
- func (dm *EsDocManager) GetName() string
- func (dm *EsDocManager) GetShardId() string
- func (dm *EsDocManager) GetTs() (ts *primitive.Timestamp)
- func (dm *EsDocManager) HandCommand(doc interface{}, ns string, ts *primitive.Timestamp)
- func (dm *EsDocManager) Init() bool
- func (dm *EsDocManager) Remove(docId primitive.ObjectID, ns string, ts *primitive.Timestamp)
- func (dm *EsDocManager) SetShardId(shardId string)
- func (dm *EsDocManager) SetTs(ts *primitive.Timestamp)
- func (dm *EsDocManager) Stop()
- func (dm *EsDocManager) Update(docId primitive.ObjectID, updateSpec interface{}, ns string, ...)
- func (dm *EsDocManager) Upsert(doc interface{}, ns string, ts *primitive.Timestamp)
- type IDocManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EsDocManager ¶
type EsDocManager struct {
// contains filtered or unexported fields
}
func (*EsDocManager) BulkUpsert ¶
func (dm *EsDocManager) BulkUpsert(docs []interface{}, ns string, ts *primitive.Timestamp)
func (*EsDocManager) Commit ¶
func (dm *EsDocManager) Commit()
func (*EsDocManager) GetLastDoc ¶
func (dm *EsDocManager) GetLastDoc()
func (*EsDocManager) GetName ¶
func (dm *EsDocManager) GetName() string
func (*EsDocManager) GetShardId ¶
func (dm *EsDocManager) GetShardId() string
func (*EsDocManager) GetTs ¶
func (dm *EsDocManager) GetTs() (ts *primitive.Timestamp)
func (*EsDocManager) HandCommand ¶
func (dm *EsDocManager) HandCommand(doc interface{}, ns string, ts *primitive.Timestamp)
func (*EsDocManager) Init ¶
func (dm *EsDocManager) Init() bool
func (*EsDocManager) SetShardId ¶
func (dm *EsDocManager) SetShardId(shardId string)
func (*EsDocManager) SetTs ¶
func (dm *EsDocManager) SetTs(ts *primitive.Timestamp)
func (*EsDocManager) Stop ¶
func (dm *EsDocManager) Stop()
type IDocManager ¶
type IDocManager interface {
BulkUpsert(docs []interface{}, ns string, ts *primitive.Timestamp)
Update(docId primitive.ObjectID, updateSpec interface{}, ns string, ts *primitive.Timestamp)
Upsert(doc interface{}, ns string, ts *primitive.Timestamp)
Remove(docId primitive.ObjectID, ns string, ts *primitive.Timestamp)
HandCommand(doc interface{}, ns string, ts *primitive.Timestamp)
GetLastDoc()
GetTs() (ts *primitive.Timestamp)
SetTs(ts *primitive.Timestamp)
Commit()
Stop()
Init() bool
GetName() string
//SetName(name string)
GetShardId() string
SetShardId(shardId string)
}
Source Files
Click to show internal directories.
Click to hide internal directories.