store

func GetEtcdAddrs ¶

func GetEtcdAddrs(store kv.Storage) (kv.EtcdBackend, []string, error)

GetEtcdAddrs gets the etcd addrs from store if the store support it.

func GetSystemStorage ¶

func GetSystemStorage() kv.Storage

GetSystemStorage returns the kv.Storage for the SYSTEM keyspace.

func InitStorage ¶

func InitStorage(keyspaceName string) (kv.Storage, error)

InitStorage initializes the kv.Storage for the given keyspace name.

func IsKeyspaceNotExistError ¶

func IsKeyspaceNotExistError(err error) bool

IsKeyspaceNotExistError returns true the error is caused by keyspace not exists.

func IsNotBootstrappedError ¶

func IsNotBootstrappedError(err error) bool

IsNotBootstrappedError returns true if the error is pd not bootstrapped error.

func MustInitStorage ¶

func MustInitStorage(keyspaceName string) kv.Storage

MustInitStorage initializes the kv.Storage for this instance.

func New ¶

func New(path string) (kv.Storage, error)

New creates a kv Storage with path.

The path must be a URL format 'engine://path?params' like the one for session.Open() but with the dbname cut off. Examples:

goleveldb://relative/path
boltdb:///absolute/path

The engine should be registered before creating storage.

func NewEtcdCli ¶

func NewEtcdCli(store kv.Storage) (*clientv3.Client, error)

NewEtcdCli creates a new clientv3.Client from store if the store support it. the returned client will have the same keyspace the store, and it might be nil. TODO currently uni-store/mock-tikv/tikv all implements EtcdBackend while they don't support actually. refactor this part.

func NewEtcdCliWithAddrs ¶

func NewEtcdCliWithAddrs(addrs []string, ebd kv.EtcdBackend) (*clientv3.Client, error)

NewEtcdCliWithAddrs creates a new clientv3.Client with specified addrs and etcd backend.

func Register ¶

func Register(tp config.StoreType, driver kv.Driver) error

Register registers a kv storage with unique name and its associated Driver. TODO: remove this function and use driver directly, TiDB is not a SDK.

func SetSystemStorage ¶

func SetSystemStorage(s kv.Storage)

SetSystemStorage returns the kv.Storage for the SYSTEM keyspace. it's only used in test.