Skip to content

Commit

Permalink
refactor: extract ErrUnsupportedFieldValueType
Browse files Browse the repository at this point in the history
Signed-off-by: Zhangjian He <[email protected]>
  • Loading branch information
hezhangjian committed Jan 13, 2025
1 parent f4c4f1d commit 10fb28a
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 13 deletions.
23 changes: 12 additions & 11 deletions opengemini/error.go
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
3 changes: 1 addition & 2 deletions opengemini/point.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
package opengemini

import (
"errors"
"io"
"strconv"
"strings"
Expand Down Expand Up @@ -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
Expand Down

0 comments on commit 10fb28a

Please sign in to comment.