managers

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

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) Remove

func (dm *EsDocManager) Remove(docId primitive.ObjectID, ns string, ts *primitive.Timestamp)

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()

func (*EsDocManager) Update

func (dm *EsDocManager) Update(docId primitive.ObjectID, updateSpec interface{}, ns string, ts *primitive.Timestamp)

func (*EsDocManager) Upsert

func (dm *EsDocManager) Upsert(doc interface{}, ns string, ts *primitive.Timestamp)

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)
}