-
Notifications
You must be signed in to change notification settings - Fork 1
/
esDocManager.go
55 lines (48 loc) · 1.29 KB
/
esDocManager.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package managers
import (
"go.mongodb.org/mongo-driver/bson/primitive"
"log"
)
type EsDocManager struct {
host string
shardId string
}
func (dm *EsDocManager) BulkUpsert(docs []interface{}, ns string, ts *primitive.Timestamp) {
log.Println("Es bulk upsert", ns, docs)
}
func (dm *EsDocManager) Update(docId primitive.ObjectID, updateSpec interface{}, ns string, ts *primitive.Timestamp) {
log.Println("Es update")
}
func (dm *EsDocManager) Upsert(doc interface{}, ns string, ts *primitive.Timestamp) {
log.Println("Es upsert")
}
func (dm *EsDocManager) Remove(docId primitive.ObjectID, ns string, ts *primitive.Timestamp) {
log.Println("Es remove")
}
func (dm *EsDocManager) HandCommand(doc interface{}, ns string, ts *primitive.Timestamp) {
log.Println("Es hand command")
}
func (dm *EsDocManager) GetLastDoc() {
}
func (dm *EsDocManager) GetTs() (ts *primitive.Timestamp) {
return nil
}
func (dm *EsDocManager) SetTs(ts *primitive.Timestamp) {
}
func (dm *EsDocManager) Commit() {
}
func (dm *EsDocManager) Stop() {
}
func (dm *EsDocManager) Init() bool {
return true
}
func (dm *EsDocManager) GetName() string {
return "es"
}
func (dm *EsDocManager) SetShardId(shardId string) {
}
func (dm *EsDocManager) GetShardId() string {
return dm.shardId
}
//func (dm *EsDocManager) SetName(name string) {
//}