Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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
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

pkg

package

Go to main page

Versions in this module

v0

v0.0.9

Feb 19, 2025

v0.0.8

Dec 31, 2024

v0.0.7

Dec 26, 2024

Changes in this version

+ const ClickHouse

+ const ElasticSearch6

+ const ElasticSearch7

+ const ElasticSearch8

+ const Mongo

+ const Mysql

+ const Postgres

+ const Redis

v0.0.6

Nov 1, 2024

v0.0.5

Oct 31, 2024

v0.0.4

Oct 31, 2024

Changes in this version

+ type ClientInterface interface

+ EsAddAliases func(ctx context.Context, indexName []string, aliasName string) (res *proto.Response, err error)

+ EsCatAliases func(ctx context.Context, catRequest proto.CatAliasesRequest) (res *proto.Response, err error)

+ EsCatAllocationRequest func(ctx context.Context, catRequest proto.CatAllocationRequest) (res *proto.Response, err error)

+ EsCatCount func(ctx context.Context, catRequest proto.CatCountRequest) (res *proto.Response, err error)

+ EsCatHealth func(ctx context.Context, catRequest proto.CatHealthRequest) (res *proto.Response, err error)

+ EsCatNodes func(ctx context.Context, h []string) (res *proto.Response, err error)

+ EsCatShards func(ctx context.Context, catRequest proto.CatShardsRequest) (res *proto.Response, err error)

+ EsClusterStats func(ctx context.Context, human bool) (res *proto.Response, err error)

+ EsCreate func(ctx context.Context, createRequest proto.CreateRequest, body interface{}) (res *proto.Response, err error)

+ EsCreateIndex func(ctx context.Context, indexCreateRequest proto.IndicesCreateRequest, ...) (res *proto.Response, err error)

+ EsDelete func(ctx context.Context, deleteRequest proto.DeleteRequest) (res *proto.Response, err error)

+ EsDeleteByQuery func(ctx context.Context, indexNames []string, documents []string, body interface{}) (res *proto.Response, err error)

+ EsDeleteIndex func(ctx context.Context, indicesDeleteRequest proto.IndicesDeleteRequest) (res *proto.Response, err error)

+ EsFlush func(ctx context.Context, indexNames []string) (res *proto.Response, err error)

+ EsGetAliases func(ctx context.Context, indexNames []string) (res *proto.Response, err error)

+ EsGetIndices func(ctx context.Context, catIndicesRequest proto.CatIndicesRequest) (res *proto.Response, err error)

+ EsGetMapping func(ctx context.Context, indexNames []string) (res *proto.Response, err error)

+ EsIndicesClearCache func(ctx context.Context, indexNames []string) (res *proto.Response, err error)

+ EsIndicesClose func(ctx context.Context, indexNames []string) (res *proto.Response, err error)

+ EsIndicesForcemerge func(ctx context.Context, indexNames []string, maxNumSegments *int) (res *proto.Response, err error)

+ EsIndicesGetSettingsRequest func(ctx context.Context, indicesGetSettingsRequest proto.IndicesGetSettingsRequest) (res *proto.Response, err error)

+ EsIndicesPutSettingsRequest func(ctx context.Context, indexSettingsRequest proto.IndicesPutSettingsRequest, ...) (res *proto.Response, err error)

+ EsIndicesSegmentsRequest func(ctx context.Context, human bool) (res *proto.Response, err error)

+ EsMoveToAnotherIndexAliases func(ctx context.Context, body proto.AliasAction) (res *proto.Response, err error)

+ EsOpen func(ctx context.Context, indexNames []string) (res *proto.Response, err error)

+ EsPerformRequest func(ctx context.Context, req *http.Request) (res *proto.Response, err error)

+ EsPutMapping func(ctx context.Context, indicesPutMappingRequest proto.IndicesPutMappingRequest, ...) (res *proto.Response, err error)

+ EsRefresh func(ctx context.Context, indexNames []string) (res *proto.Response, err error)

+ EsReindex func(ctx context.Context, reindexRequest proto.ReindexRequest, body interface{}) (res *proto.Response, err error)

+ EsRemoveAliases func(ctx context.Context, indexName []string, aliasName []string) (res *proto.Response, err error)

+ EsRestoreSnapshot func(ctx context.Context, repository string, snapshot string, ...) (res *proto.Response, err error)

+ EsSearch func(ctx context.Context, searchRequest proto.SearchRequest, query interface{}) (res *proto.Response, err error)

+ EsSnapshotCreate func(ctx context.Context, repository string, snapshot string, ...) (res *proto.Response, err error)

+ EsSnapshotCreateRepository func(ctx context.Context, repository string, reqJson proto.Json) (res *proto.Response, err error)

+ EsSnapshotDelete func(ctx context.Context, repository string, snapshot string) (res *proto.Response, err error)

+ EsSnapshotDeleteRepository func(ctx context.Context, repository []string) (res *proto.Response, err error)

+ EsSnapshotGetRepository func(ctx context.Context, repository []string) (res *proto.Response, err error)

+ EsSnapshotStatus func(ctx context.Context, repository string, snapshot []string, ...) (res *proto.Response, err error)

+ EsTaskList func(ctx context.Context) (res *proto.Response, err error)

+ EsTasksCancel func(ctx context.Context, taskId string) (res *proto.Response, err error)

+ EsUpdate func(ctx context.Context, updateRequest proto.UpdateRequest, body interface{}) (res *proto.Response, err error)

+ EsVersion func() (version int, err error)

+ ExecMongoCommand func(ctx context.Context, dbName string, command bson.D, timeout time.Duration) (res bson.M, err error)

+ MysqlExecSql func(ctx context.Context, dbName, sql string, args ...interface{}) (rowsAffected int64, err error)

+ MysqlFirstSql func(ctx context.Context, dbName, sql string, args ...interface{}) (data map[string]interface{}, err error)

+ MysqlSelectSql func(ctx context.Context, dbName, sql string, args ...interface{}) (list []map[string]interface{}, err error)

+ Ping func(ctx context.Context) (res *proto.Response, err error)

+ RedisExecCommand func(ctx context.Context, dbName int, args ...interface{}) (data interface{}, err error)

+ ShowMongoDbs func(ctx context.Context) ([]string, error)

v0.0.3

Oct 24, 2024

v0.0.2

Sep 28, 2024

v0.0.1

Aug 27, 2024