datastore

package

v0.0.0-...-0a3be77 Latest Latest Go to latest Published: Jul 2, 2024 License: MIT Imports: 8 Imported by: 0

Documentation ¶

Index ¶

Constants
func InitOtsClient()
type Config
- func NewOtsConfig(tableName string) *Config
- func NewSQLiteConfig(tableName string) *Config
type Datastore
type DatastoreFactory
- func (f *DatastoreFactory) NewTable(dbType DatastoreType, tableName string) Datastore
type DatastoreType
type OtsStore
- func NewOtsDatastore(config *Config) (*OtsStore, error)
type SQLiteDatastore
- func NewSQLiteDatastore(config *Config) *SQLiteDatastore

Constants ¶

const (
	KModelServiceTableName      = "function"
	KModelServiceKey            = "PRIMARY_KEY"
	KModelServiceFunctionName   = "FUNCTION"
	KModelServiceSdModel        = "SD_MODEL"
	KModelServiceEndPoint       = "END_POINT"
	KModelServerImage           = "IMAGE"
	KModelServiceMessage        = "MESSAGE"
	KModelServiceCreateTime     = "FUNC_CREATE_TIME"
	KModelServiceLastModifyTime = "FUNC_LAST_MODIFY_TIME"
)

function table

View Source

const (
	KModelTableName  = "models"
	KModelType       = "MODEL_TYPE"
	KModelName       = "MODEL_NAME"
	KModelOssPath    = "MODEL_OSS_PATH"
	KModelEtag       = "MODEL_ETAG"
	KModelStatus     = "MODEL_STATUS"
	KModelLocalPath  = "MODEL_LOCAL_PATH"
	KModelCreateTime = "MODEL_REGISTERED"
	KModelModifyTime = "MODEL_MODIFY"
)

models table

View Source

const (
	KTaskTableName          = "tasks"
	KTaskIdColumnName       = "TASK_ID"
	KTaskUser               = "TASK_USER"
	KTaskProgressColumnName = "TASK_PROGRESS"
	KTaskInfo               = "TASK_INFO"
	KTaskImage              = "TASK_IMAGE"
	KTaskCode               = "TASK_CODE"
	KTaskCancel             = "TASK_CANCEL"
	KTaskParams             = "TASK_PARAMS"
	KTaskStatus             = "TASK_STATUS"
	KTaskCreateTime         = "TASK_CREATE_TIME"
	KTaskModifyTime         = "TASK_MODIFY_TIME"
)

tasks table

View Source

const (
	KUserTableName        = "users"
	KUserName             = "USER_NAME"
	KUserPassword         = "USER_PASSWORD"
	KUserSession          = "USER_SESSION"
	KUserSessionValidTime = "USER_SESSION_VALID"
	KUserConfig           = "USER_CONFIG"
	KUserConfigVer        = "USER_CONFIG_VERSION"
	KUserCreateTime       = "USER_CREATE_TIME"
	KUserModifyTime       = "USER_MODIFY_TIME"
)

user table

View Source

const (
	KConfigTableName  = "config"
	KConfigKey        = "CONFIG_KEY"
	KConfigVal        = "CONFIG_VAL"
	KConfigMd5        = "CONFIG_MD5"
	KConfigVer        = "CONFIG_VERSION"
	KConfigCreateTime = "CONFIG_CREATE_TIME"
	KConfigModifyTime = "CONFIG_MODIFY_TIME"
)

config

Variables ¶

This section is empty.

Functions ¶

func InitOtsClient ¶

func InitOtsClient()

InitOtsClient init ots client

Types ¶

type Config ¶

type Config struct {
	Type                 DatastoreType // the datastore type
	DBName               string        // the database name
	TableName            string
	ColumnConfig         map[string]string // map of column name to column type
	PrimaryKeyColumnName string
	TimeToAlive          int
	MaxVersion           int
}

func NewOtsConfig ¶

func NewOtsConfig(tableName string) *Config

func NewSQLiteConfig ¶

func NewSQLiteConfig(tableName string) *Config

type Datastore ¶

type Datastore interface {
	// Put inserts or updates the column values in the datastore.
	// It takes a key and a map of column names to values, and returns an error if the operation failed.
	Put(key string, values map[string]interface{}) error

	// Update the partial column values.
	// It tasks a key and a map of column names to values, and returns an error if the operation failed.
	Update(key string, values map[string]interface{}) error

	// Get retrieves the column values from the datastore.
	// It takes a key and a slice of column names, and returns a map of column names to values,
	// along with an error if the operation failed.
	// If the key does not exist, the returned map and error are both nil.
	Get(key string, columns []string) (map[string]interface{}, error)

	// Delete removes a value from the datastore.
	// It takes a key, and returns an error if the operation failed.
	// Note: delete a non-existent key will not return an error.
	Delete(key string) error

	// ListAll read all data from the datastore.
	// It takes a list of column name, and  return a nested map, which means map[primaryKey]map[columanName]columanValue.
	// Note: since it reads all data and store them in memory, so do not call this function on a large datastore.
	ListAll(columns []string) (map[string]map[string]interface{}, error)

	// Close close the datastore.
	Close() error
}

type DatastoreFactory ¶

type DatastoreFactory struct{}

func (*DatastoreFactory) NewTable ¶

func (f *DatastoreFactory) NewTable(dbType DatastoreType, tableName string) Datastore

type DatastoreType ¶

type DatastoreType string

const (
	SQLite     DatastoreType = "sqlite"
	MySQL      DatastoreType = "mysql"
	TableStore DatastoreType = "tableStore"
)

type OtsStore ¶

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

func NewOtsDatastore ¶

func NewOtsDatastore(config *Config) (*OtsStore, error)

func (*OtsStore) Close ¶

func (o *OtsStore) Close() error

func (*OtsStore) Delete ¶

func (o *OtsStore) Delete(key string) error

func (*OtsStore) Get ¶

func (o *OtsStore) Get(key string, columns []string) (map[string]interface{}, error)

func (*OtsStore) ListAll ¶

func (o *OtsStore) ListAll(columns []string) (map[string]map[string]interface{}, error)

func (*OtsStore) Put ¶

func (o *OtsStore) Put(key string, datas map[string]interface{}) error

func (*OtsStore) Update ¶

func (o *OtsStore) Update(key string, datas map[string]interface{}) error

type SQLiteDatastore ¶

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

func NewSQLiteDatastore ¶

func NewSQLiteDatastore(config *Config) *SQLiteDatastore

func (*SQLiteDatastore) Close ¶

func (ds *SQLiteDatastore) Close() error

func (*SQLiteDatastore) Delete ¶

func (ds *SQLiteDatastore) Delete(key string) error

func (*SQLiteDatastore) Get ¶

func (ds *SQLiteDatastore) Get(key string, columns []string) (map[string]interface{}, error)

func (*SQLiteDatastore) ListAll ¶

func (ds *SQLiteDatastore) ListAll(columns []string) (map[string]map[string]interface{}, error)

func (*SQLiteDatastore) Put ¶

func (ds *SQLiteDatastore) Put(key string, values map[string]interface{}) error

func (*SQLiteDatastore) Update ¶

func (ds *SQLiteDatastore) Update(key string, values map[string]interface{}) error

Source Files ¶

View all Source files

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