db

package

v1.2.1 Latest Latest Go to latest Published: Sep 24, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/irisnet/rainbow-sync

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 ¶

View Source

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

View Source

const (
	CollectionNameTxn = "sync_mgo_txn"
)

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL