Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

data

package

Go to main page

Versions in this module

v2

v2.0.3

Jul 9, 2026

v2.0.2

Jul 2, 2026

Changes in this version

+ func SearchFunc[T any](ctx context.Context, dbConnection *gorm.DB, query *SearchQuery, ...) ([]T, error)

v2.0.1

Jun 29, 2026

Changes in this version

+ const MemScheme

+ const MysqlScheme

+ const NatsScheme

+ const PostgresScheme

+ const RedisScheme

+ func ErrorConvertToAPI(err error) *connect.Error

+ func ErrorIsDuplicateKey(err error) bool

+ func ErrorIsNoRows(err error) bool

+ func StableSearch[T any](ctx context.Context, workMan workerpool.Manager, query *SearchQuery, ...) (workerpool.JobResultPipe[[]T], error)

+ type BaseModel struct

+ AccessID string

+ CreatedAt time.Time

+ CreatedBy string

+ DeletedAt gorm.DeletedAt

+ ID string

+ ModifiedAt time.Time

+ ModifiedBy string

+ PartitionID string

+ TenantID string

+ Version uint

+ func (model *BaseModel) BeforeCreate(db *gorm.DB) error

+ func (model *BaseModel) BeforeSave(db *gorm.DB) error

+ func (model *BaseModel) BeforeUpdate(db *gorm.DB) error

+ func (model *BaseModel) CopyPartitionInfo(parent *BaseModel)

+ func (model *BaseModel) GenID(ctx context.Context)

+ func (model *BaseModel) GetAccessID() string

+ func (model *BaseModel) GetID() string

+ func (model *BaseModel) GetPartitionID() string

+ func (model *BaseModel) GetTenantID() string

+ func (model *BaseModel) GetVersion() uint

+ func (model *BaseModel) SetAccessID(v string)

+ func (model *BaseModel) SetPartitionID(v string)

+ func (model *BaseModel) SetTenantID(v string)

+ func (model *BaseModel) ValidXID(id string) bool

+ type BaseModelI interface

+ GetID func() string

+ GetVersion func() uint

+ type DSN string

+ func (d DSN) ChangePort(newPort string) (DSN, error)

+ func (d DSN) DelPath() DSN

+ func (d DSN) ExtendPath(epath ...string) DSN

+ func (d DSN) ExtendQuery(key, value string) DSN

+ func (d DSN) GetQuery(key string) string

+ func (d DSN) IsCache() bool

+ func (d DSN) IsDB() bool

+ func (d DSN) IsMem() bool

+ func (d DSN) IsMySQL() bool

+ func (d DSN) IsNats() bool

+ func (d DSN) IsPostgres() bool

+ func (d DSN) IsQueue() bool

+ func (d DSN) IsRedis() bool

+ func (d DSN) PrefixPath(prefix string) DSN

+ func (d DSN) RemoveQuery(key ...string) DSN

+ func (d DSN) String() string

+ func (d DSN) SuffixPath(suffix string) DSN

+ func (d DSN) ToArray() []DSN

+ func (d DSN) ToURI() (*url.URL, error)

+ func (d DSN) Valid() bool

+ func (d DSN) WithPassword(password string) (DSN, error)

+ func (d DSN) WithPath(path string) (DSN, error)

+ func (d DSN) WithPathSuffix(suffix string) (DSN, error)

+ func (d DSN) WithQuery(query string) (DSN, error)

+ func (d DSN) WithUser(user string) (DSN, error)

+ func (d DSN) WithUserAndPassword(userName, password string) (DSN, error)

+ type JSONMap map[string]any

+ func (m *JSONMap) Copy() JSONMap

+ func (m *JSONMap) FromProtoStruct(s *structpb.Struct) JSONMap

+ func (m *JSONMap) GetFloat(key string) float64

+ func (m *JSONMap) GetString(key string) string

+ func (m *JSONMap) GormDBDataType(db *gorm.DB, _ *schema.Field) string

+ func (m *JSONMap) GormDataType() string

+ func (m *JSONMap) GormValue(_ context.Context, db *gorm.DB) clause.Expr

+ func (m *JSONMap) MarshalJSON() ([]byte, error)

+ func (m *JSONMap) Scan(value any) error

+ func (m *JSONMap) ToProtoStruct() *structpb.Struct

+ func (m *JSONMap) UnmarshalJSON(data []byte) error

+ func (m *JSONMap) Update(update JSONMap) JSONMap

+ func (m *JSONMap) Value() (driver.Value, error)

+ type Paginator struct

+ BatchSize int

+ Limit int

+ Offset int

+ func (p *Paginator) CanLoad() bool

+ func (p *Paginator) SetBatchSize(batchSize int)

+ func (p *Paginator) Stop(loadedCount int) bool

+ type SearchOption func(*SearchQuery)

+ func WithSearchBatchSize(batchSize int) SearchOption

+ func WithSearchByTimePeriod(period *TimePeriod) SearchOption

+ func WithSearchFiltersAndByValue(filters map[string]any) SearchOption

+ func WithSearchFiltersOrByValue(filters map[string]any) SearchOption

+ func WithSearchLimit(limit int) SearchOption

+ func WithSearchOffset(offset int) SearchOption

+ type SearchQuery struct

+ FiltersAndByValue map[string]any

+ FiltersOrByValue map[string]any

+ OrderBy string

+ Pagination *Paginator

+ TimePeriod *TimePeriod

+ func NewSearchQuery(opts ...SearchOption) *SearchQuery

+ type TimePeriod struct

+ Field string

+ StartDate *time.Time

+ StopDate *time.Time

+ type UnitMeasure int64

+ func (d *UnitMeasure) UnmarshalText(text []byte) error

Other modules containing this package

github.com/pitabwire/frame