mongo

type DbClient struct {
	// contains filtered or unexported fields
}

type DbSession struct {
	*mgo.Session
	// contains filtered or unexported fields
}

type Hashable interface {
	GetId() string
}

type Hint struct {
	// ServerName is used to specify the server.
	ServerName string `json:"server_name"`

	// Database and Collection is used to determine the whether this server
	// should be used. It follows the rule to choose the server:
	// 1. Both database and collection argument are perfectly matched.
	// 2. If no such match, the LAST hint matching the db.
	// 3. If no such match(no such database in the config), the LAST hint matching the collection.
	// 4. Choose the first server given in Servers section.
	Database   string `json:"database"`
	Collection string `json:"collection"`
}

type LocalRepos struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type ReposKVEntry struct {
	Key   string
	Value Hashable
}

type ReposOption func(*LocalRepos)

type Router struct {
	Servers []*Server `json:"servers"`
	Hints   []*Hint   `json:"hints"`

	HintMap map[string]*Server `json:"-"`
}

type Server struct {
	// Name is required to identify the server. MUST be unique in the configuation.
	Name string `json:"name"`
	// Address will be directly passed to mgo.Dial()
	Address string `json:"address"`
}