sqlkv

Documentation

Index

• Constants
• func NewClientConnImpl(storeConf *model.StoreConfig) (*clientConnImpl, error)
• func NewSQLDB(storeConf *model.StoreConfig) (*sql.DB, error)
• func NewSQLKVClientImpl(sqlDB *sql.DB, storeType metaModel.StoreType, table string, ...) (*sqlKVClientImpl, error)
• type ClientBuilderImpl
  • func (b *ClientBuilderImpl) ClientType() model.ClientType
  • func (b *ClientBuilderImpl) NewKVClientWithNamespace(cc model.ClientConn, projectID model.ProjectID, jobID model.JobID) (model.KVClient, error)

Constants

const (
	WhereClauseWithJobID     = "job_id = ?"
	WhereClauseWithKeyRange  = "meta_key >= ? AND meta_key < ?"
	WhereClauseWithKeyPrefix = "meta_key like ?"
	WhereClauseWithFromKey   = "meta_key >= ?"
	WhereClauseWithKey       = "meta_key = ?"
)

Where clause for meta kv option NOTE: 'job_id' and 'meta_key' MUST be same as backend table

Functions

func NewClientConnImpl

func NewClientConnImpl(storeConf *model.StoreConfig) (*clientConnImpl, error)

NewClientConnImpl return a new clientConnImpl

func NewSQLDB

func NewSQLDB(storeConf *model.StoreConfig) (*sql.DB, error)

NewSQLDB news a sql.DB.

func NewSQLKVClientImpl

func NewSQLKVClientImpl(sqlDB *sql.DB, storeType metaModel.StoreType, table string,
	jobID metaModel.JobID,
) (*sqlKVClientImpl, error)

NewSQLKVClientImpl new a sql implement for kvclient

Types

type ClientBuilderImpl

type ClientBuilderImpl struct{}

ClientBuilderImpl is the implement of ClientBuilder for sqlkv

func (*ClientBuilderImpl) ClientType

func (b *ClientBuilderImpl) ClientType() model.ClientType

ClientType implements ClientType of clientBuilder

func (*ClientBuilderImpl) NewKVClientWithNamespace

func (b *ClientBuilderImpl) NewKVClientWithNamespace(cc model.ClientConn,
	projectID model.ProjectID, jobID model.JobID,
) (model.KVClient, error)

NewKVClientWithNamespace implements NewKVClientWithNamespace of clientBuilder