dps

package module

v1.8.0 Latest Latest Go to latest Published: Jan 29, 2024 License: GPL-3.0 Imports: 6 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

git.sxidc.com/service-supports/dps-sdk

README ¶

dps-sdk

数据库代理服务SDK

Documentation ¶

Index ¶

func AutoMigrate(items ...client.AutoMigrateItem) error
func CheckEventExistByKeys(req *client.CountEventByKeysRequest) (bool, error)
func CheckEventHistoryExistByKeys(req *client.CountEventByKeysRequest) (bool, error)
func CheckExistWhere(req *client.CountWhereRequest) (bool, error)
func CommonCheckEventExist(req *client.CommonCountEventRequest) (bool, error)
func CommonCheckEventHistoryExist(req *client.CommonCountEventRequest) (bool, error)
func CommonCheckExist(req *client.CommonCountRequest) (bool, error)
func CommonCount(req *client.CommonCountRequest) (int64, error)
func CommonCountEvent(req *client.CommonCountEventRequest) (int64, error)
func CommonCountEventHistory(req *client.CommonCountEventRequest) (int64, error)
func CommonEventHistoryQuery(req *client.CommonEventQueryRequest) ([]client.EventInfo, int64, error)
func CommonEventHistoryQueryOnly(req *client.CommonEventQueryRequest) ([]client.EventInfo, error)
func CommonEventQuery(req *client.CommonEventQueryRequest) ([]client.EventInfo, int64, error)
func CommonEventQueryOnly(req *client.CommonEventQueryRequest) ([]client.EventInfo, error)
func CommonQuery(req *client.CommonQueryRequest) ([]client.TableRow, int64, error)
func CommonQueryOnly(req *client.CommonQueryRequest) ([]client.TableRow, error)
func CountEventByKeys(req *client.CountEventByKeysRequest) (int64, error)
func CountEventHistoryByKeys(req *client.CountEventByKeysRequest) (int64, error)
func CountWhere(req *client.CountWhereRequest) (int64, error)
func Delete(req *client.DeleteRequest, tx client.Transaction) error
func DeleteWhere(req *client.DeleteWhereRequest, tx client.Transaction) error
func DestroyClient(clientVersion string, databaseID string) error
func DestroyInstance(clientVersion string, databaseID string) error
func EventHistoryQueryByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, int64, error)
func EventHistoryQueryOnlyByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, error)
func EventQueryByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, int64, error)
func EventQueryOnlyByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, error)
func GetDataCreateUserID(dataMap map[string]any) string
func GetDataLastUpdateUserID(dataMap map[string]any) string
func GetLastEventTime(dataMap map[string]any) *time.Time
func InitInstance(address string, clientVersion string, databaseID string) error
func Insert(req *client.InsertRequest, tx client.Transaction) error
func InsertBatch(req *client.InsertBatchRequest, tx client.Transaction) error
func NewClient(address string, clientVersion string, databaseID string) (client.Client, error)
func QueryByKeys(req *client.QueryByKeysRequest) (*client.TableRow, error)
func QueryByWhereAndOrderBy(req *client.QueryByWhereAndOrderByRequest) ([]client.TableRow, int64, error)
func QueryOnlyByWhereAndOrderBy(req *client.QueryByWhereAndOrderByRequest) ([]client.TableRow, error)
func Replay(req *client.ReplayRequest) error
func Transaction(txFunc client.TransactionFunc) error
func Update(req *client.UpdateRequest, tx client.Transaction) error
func UpdateWhere(req *client.UpdateWhereRequest, tx client.Transaction) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AutoMigrate ¶

func AutoMigrate(items ...client.AutoMigrateItem) error

func CheckEventExistByKeys ¶

func CheckEventExistByKeys(req *client.CountEventByKeysRequest) (bool, error)

func CheckEventHistoryExistByKeys ¶

func CheckEventHistoryExistByKeys(req *client.CountEventByKeysRequest) (bool, error)

func CheckExistWhere ¶

func CheckExistWhere(req *client.CountWhereRequest) (bool, error)

func CommonCheckEventExist ¶

func CommonCheckEventExist(req *client.CommonCountEventRequest) (bool, error)

func CommonCheckEventHistoryExist ¶

func CommonCheckEventHistoryExist(req *client.CommonCountEventRequest) (bool, error)

func CommonCheckExist ¶

func CommonCheckExist(req *client.CommonCountRequest) (bool, error)

func CommonCount ¶

func CommonCount(req *client.CommonCountRequest) (int64, error)

func CommonCountEvent ¶

func CommonCountEvent(req *client.CommonCountEventRequest) (int64, error)

func CommonCountEventHistory ¶

func CommonCountEventHistory(req *client.CommonCountEventRequest) (int64, error)

func CommonEventHistoryQuery ¶

func CommonEventHistoryQuery(req *client.CommonEventQueryRequest) ([]client.EventInfo, int64, error)

func CommonEventHistoryQueryOnly ¶

func CommonEventHistoryQueryOnly(req *client.CommonEventQueryRequest) ([]client.EventInfo, error)

func CommonEventQuery ¶

func CommonEventQuery(req *client.CommonEventQueryRequest) ([]client.EventInfo, int64, error)

func CommonEventQueryOnly ¶

func CommonEventQueryOnly(req *client.CommonEventQueryRequest) ([]client.EventInfo, error)

func CommonQuery ¶

func CommonQuery(req *client.CommonQueryRequest) ([]client.TableRow, int64, error)

func CommonQueryOnly ¶

func CommonQueryOnly(req *client.CommonQueryRequest) ([]client.TableRow, error)

func CountEventByKeys ¶

func CountEventByKeys(req *client.CountEventByKeysRequest) (int64, error)

func CountEventHistoryByKeys ¶

func CountEventHistoryByKeys(req *client.CountEventByKeysRequest) (int64, error)

func CountWhere ¶

func CountWhere(req *client.CountWhereRequest) (int64, error)

func Delete ¶

func Delete(req *client.DeleteRequest, tx client.Transaction) error

func DeleteWhere ¶ added in v1.6.6

func DeleteWhere(req *client.DeleteWhereRequest, tx client.Transaction) error

func DestroyClient ¶

func DestroyClient(clientVersion string, databaseID string) error

func DestroyInstance ¶

func DestroyInstance(clientVersion string, databaseID string) error

func EventHistoryQueryByKeys ¶

func EventHistoryQueryByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, int64, error)

func EventHistoryQueryOnlyByKeys ¶

func EventHistoryQueryOnlyByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, error)

func EventQueryByKeys ¶

func EventQueryByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, int64, error)

func EventQueryOnlyByKeys ¶

func EventQueryOnlyByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, error)

func GetDataCreateUserID ¶

func GetDataCreateUserID(dataMap map[string]any) string

func GetDataLastUpdateUserID ¶

func GetDataLastUpdateUserID(dataMap map[string]any) string

func GetLastEventTime ¶

func GetLastEventTime(dataMap map[string]any) *time.Time

func InitInstance ¶

func InitInstance(address string, clientVersion string, databaseID string) error

func Insert ¶

func Insert(req *client.InsertRequest, tx client.Transaction) error

func InsertBatch ¶

func InsertBatch(req *client.InsertBatchRequest, tx client.Transaction) error

func NewClient ¶

func NewClient(address string, clientVersion string, databaseID string) (client.Client, error)

func QueryByKeys ¶

func QueryByKeys(req *client.QueryByKeysRequest) (*client.TableRow, error)

func QueryByWhereAndOrderBy ¶

func QueryByWhereAndOrderBy(req *client.QueryByWhereAndOrderByRequest) ([]client.TableRow, int64, error)

func QueryOnlyByWhereAndOrderBy ¶

func QueryOnlyByWhereAndOrderBy(req *client.QueryByWhereAndOrderByRequest) ([]client.TableRow, error)

func Replay ¶

func Replay(req *client.ReplayRequest) error

func Transaction ¶

func Transaction(txFunc client.TransactionFunc) error

func Update ¶

func Update(req *client.UpdateRequest, tx client.Transaction) error

func UpdateWhere ¶ added in v1.7.0

func UpdateWhere(req *client.UpdateWhereRequest, tx client.Transaction) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
client
dpsv1
pb
v1
v1/request
v1/response
test
instance
v1

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