Documentation
¶
Index ¶
- func GetMessages(db_client MySQLClient, reverseSetting string, chat string, cursor int64, ...) (*sql.Rows, error)
- func GetProperties(rows *sql.Rows, limit int32) ([]*rpc.Message, int64, bool, error)
- func InsertMessage(db_client MySQLClient, chat string, sender string, text string, sendTime int64) error
- type MySQLClient
- func (c *MySQLClient) ExecQuery(query string, args ...interface{}) error
- func (c *MySQLClient) InitClient(ctx context.Context, dataSourceName string) error
- func (c *MySQLClient) SelectQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (c *MySQLClient) TestConnection(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetMessages ¶
func GetProperties ¶
func InsertMessage ¶
Types ¶
type MySQLClient ¶
type MySQLClient struct {
// contains filtered or unexported fields
}
func (*MySQLClient) ExecQuery ¶
func (c *MySQLClient) ExecQuery(query string, args ...interface{}) error
func (*MySQLClient) InitClient ¶
func (c *MySQLClient) InitClient(ctx context.Context, dataSourceName string) error
func (*MySQLClient) SelectQuery ¶
func (c *MySQLClient) SelectQuery(query string, args ...interface{}) (*sql.Rows, error)
func (*MySQLClient) TestConnection ¶
func (c *MySQLClient) TestConnection(ctx context.Context) error
Source Files
Click to show internal directories.
Click to hide internal directories.