dpsv1

Documentation

Index

• func DestroyClient(client *Client) error
• type Client
  • func NewClient(address string, databaseID string) (*Client, error)
  • func (c *Client) AutoMigrate(req *client.AutoMigrateRequest) error
  • func (c *Client) CommonCount(req *client.CommonCountRequest) (string, int64, error)
  • func (c *Client) CommonCountEvent(req *client.CommonCountEventRequest) (string, int64, error)
  • func (c *Client) CommonCountEventHistory(req *client.CommonCountEventRequest) (string, int64, error)
  • func (c *Client) CommonEventHistoryQuery(req *client.CommonEventQueryRequest) (string, []client.EventInfo, int64, error)
  • func (c *Client) CommonEventQuery(req *client.CommonEventQueryRequest) (string, []client.EventInfo, int64, error)
  • func (c *Client) CommonQuery(req *client.CommonQueryRequest) (string, []map[string]any, int64, error)
  • func (c *Client) CountEventByKeys(req *client.CountEventByKeysRequest) (string, int64, error)
  • func (c *Client) CountEventHistoryByKeys(req *client.CountEventByKeysRequest) (string, int64, error)
  • func (c *Client) CountWhere(req *client.CountWhereRequest) (string, int64, error)
  • func (c *Client) Delete(req *client.DeleteRequest) (string, error)
  • func (c *Client) DeleteBatch(req *client.DeleteBatchRequest) (string, error)
  • func (c *Client) EventHistoryQueryByKeys(req *client.EventQueryByKeysRequest) (string, []client.EventInfo, int64, error)
  • func (c *Client) EventQueryByKeys(req *client.EventQueryByKeysRequest) (string, []client.EventInfo, int64, error)
  • func (c *Client) Insert(req *client.InsertRequest) (string, error)
  • func (c *Client) InsertBatch(req *client.InsertBatchRequest) (string, error)
  • func (c *Client) QueryByKeys(req *client.QueryByKeysRequest) (string, map[string]any, error)
  • func (c *Client) QueryByWhereAndOrderBy(req *client.QueryByWhereAndOrderByRequest) (string, []map[string]any, int64, error)
  • func (c *Client) Replay(req *client.ReplayRequest) (string, error)
  • func (c *Client) Transaction(txFunc client.TransactionFunc) error
  • func (c *Client) Update(req *client.UpdateRequest) (string, error)
• type Transaction
  • func (tx *Transaction) DeleteBatchTx(req *client.DeleteBatchRequest) (string, error)
  • func (tx *Transaction) DeleteTx(req *client.DeleteRequest) (string, error)
  • func (tx *Transaction) End() error
  • func (tx *Transaction) InsertBatchTx(req *client.InsertBatchRequest) (string, error)
  • func (tx *Transaction) InsertTx(req *client.InsertRequest) (string, error)
  • func (tx *Transaction) UpdateTx(req *client.UpdateRequest) (string, error)

Functions

func DestroyClient

func DestroyClient(client *Client) error

Types

type Client

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

func NewClient

func NewClient(address string, databaseID string) (*Client, error)

func (*Client) AutoMigrate

func (c *Client) AutoMigrate(req *client.AutoMigrateRequest) error

func (*Client) CommonCount

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

func (*Client) CommonCountEvent

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

func (*Client) CommonCountEventHistory

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

func (*Client) CommonEventHistoryQuery

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

func (*Client) CommonEventQuery

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

func (*Client) CommonQuery

func (c *Client) CommonQuery(req *client.CommonQueryRequest) (string, []map[string]any, int64, error)

func (*Client) CountEventByKeys

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

func (*Client) CountEventHistoryByKeys

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

func (*Client) CountWhere

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

func (*Client) Delete

func (c *Client) Delete(req *client.DeleteRequest) (string, error)

func (*Client) DeleteBatch

func (c *Client) DeleteBatch(req *client.DeleteBatchRequest) (string, error)

func (*Client) EventHistoryQueryByKeys

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

func (*Client) EventQueryByKeys

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

func (*Client) Insert

func (c *Client) Insert(req *client.InsertRequest) (string, error)

func (*Client) InsertBatch

func (c *Client) InsertBatch(req *client.InsertBatchRequest) (string, error)

func (*Client) QueryByKeys

func (c *Client) QueryByKeys(req *client.QueryByKeysRequest) (string, map[string]any, error)

func (*Client) QueryByWhereAndOrderBy

func (c *Client) QueryByWhereAndOrderBy(req *client.QueryByWhereAndOrderByRequest) (string, []map[string]any, int64, error)

func (*Client) Replay

func (c *Client) Replay(req *client.ReplayRequest) (string, error)

func (*Client) Transaction

func (c *Client) Transaction(txFunc client.TransactionFunc) error

func (*Client) Update

func (c *Client) Update(req *client.UpdateRequest) (string, error)

type Transaction

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

func (*Transaction) DeleteBatchTx

func (tx *Transaction) DeleteBatchTx(req *client.DeleteBatchRequest) (string, error)

func (*Transaction) DeleteTx

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

func (*Transaction) End

func (tx *Transaction) End() error

func (*Transaction) InsertBatchTx

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

func (*Transaction) InsertTx

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

func (*Transaction) UpdateTx

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