diff --git a/opengemini/error.go b/opengemini/error.go index f47b6df..6eb64ee 100644 --- a/opengemini/error.go +++ b/opengemini/error.go @@ -17,17 +17,18 @@ package opengemini import "errors" var ( - ErrAllServersDown = errors.New("all servers down") - ErrEmptyAuthToken = errors.New("empty auth token") - ErrEmptyAuthUsername = errors.New("empty auth username") - ErrEmptyAuthPassword = errors.New("empty auth password") - ErrEmptyDatabaseName = errors.New("empty database name") - ErrEmptyMeasurement = errors.New("empty measurement") - ErrEmptyCommand = errors.New("empty command") - ErrEmptyTagOrField = errors.New("empty tag or field") - ErrEmptyTagKey = errors.New("empty tag key") - ErrNoAddress = errors.New("must have at least one address") - ErrRetentionPolicy = errors.New("empty retention policy") + ErrAllServersDown = errors.New("all servers down") + ErrEmptyAuthToken = errors.New("empty auth token") + ErrEmptyAuthUsername = errors.New("empty auth username") + ErrEmptyAuthPassword = errors.New("empty auth password") + ErrEmptyDatabaseName = errors.New("empty database name") + ErrEmptyMeasurement = errors.New("empty measurement") + ErrEmptyCommand = errors.New("empty command") + ErrEmptyTagOrField = errors.New("empty tag or field") + ErrEmptyTagKey = errors.New("empty tag key") + ErrNoAddress = errors.New("must have at least one address") + ErrRetentionPolicy = errors.New("empty retention policy") + ErrUnsupportedFieldValueType = errors.New("unsupported field value type") ) // checkDatabaseName checks if the database name is empty and returns an error if it is. diff --git a/opengemini/point.go b/opengemini/point.go index c0a6144..6430ef8 100644 --- a/opengemini/point.go +++ b/opengemini/point.go @@ -15,7 +15,6 @@ package opengemini import ( - "errors" "io" "strconv" "strings" @@ -189,7 +188,7 @@ func (enc *LineProtocolEncoder) writeFieldValue(v interface{}) error { err = enc.writeByte('F') } default: - err = errors.New("unsupported field value type") + err = ErrUnsupportedFieldValueType } return err