db

Documentation

Index

• Constants
• func Delete(h Docs) error
• func ExecCollection(collectionName string, s func(*mgo.Collection) error) error
• func Save(h Docs) error
• func Start()
• func Stop()
• func Txn(ops []txn.Op) error
• func Update(h Docs) error
• type Docs

Constants

const (
	// value of status
	SyncTaskStatusUnHandled = "unhandled"
	SyncTaskStatusUnderway  = "underway"
	SyncTaskStatusCompleted = "completed"

	// only for follow task
	// when current_height of follow task add blockNumPerWorkerHandle
	// less than blockchain current_height, this follow task's status should be set invalid
	FollowTaskStatusInvalid = "invalid"

	// taskType
	SyncTaskTypeCatchUp = "catch_up"
	SyncTaskTypeFollow  = "follow"
)

const (
	CollectionNameTxn = "sync_mgo_txn"
)

Functions

func Delete

func Delete(h Docs) error

func ExecCollection

func ExecCollection(collectionName string, s func(*mgo.Collection) error) error

get collection object

func Save

func Save(h Docs) error

func Start

func Start()

func Stop

func Stop()

func Txn

func Txn(ops []txn.Op) error

mgo transaction method detail to see: https://godoc.org/gopkg.in/mgo.v2/txn

func Update

func Update(h Docs) error

Types

type Docs

type Docs interface {
	// collection name
	Name() string
	// primary key pair(used to find a unique record)
	PkKvPair() map[string]interface{}
}