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
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

dgraphtest

package

Go to main page

Versions in this module

v25

v25.3.0

Mar 6, 2026

Changes in this version

type BulkOpts

+ MapShards int

+ ReduceShards int

+ SkipMapPhase bool

+ SkipReducePhase bool

+ TmpDir string

type LocalCluster

+ func (c *LocalCluster) CopyExportToHost(exportDir, hostDir string) (dataFiles, schemaFiles []string, err error)

+ func (c *LocalCluster) HostDgraphBinaryPath() string

v25.3.0-preview-no-maxprocs

Feb 16, 2026

v25.2.0

Jan 29, 2026

v25.1.0

Dec 11, 2025

Changes in this version

+ const DefaultAlphaPDir

+ const DefaultBackupDir

+ const DefaultExportDir

+ func AddData(gc *dgraphapi.GrpcClient, pred string, start, end int) error

+ func IsHigherVersion(higher, lower string) (bool, error)

+ func ShouldSkipTest(t *testing.T, minVersion, clusterVersion string)

+ type BulkOpts struct

+ DataFiles []string

+ GQLSchemaFiles []string

+ OutDir string

+ SchemaFiles []string

+ type ClusterConfig struct

+ func NewClusterConfig() ClusterConfig

+ func (cc ClusterConfig) GetClusterVolume(volume string) string

+ func (cc ClusterConfig) WithACL(aclTTL time.Duration) ClusterConfig

+ func (cc ClusterConfig) WithAclAlg(alg jwt.SigningMethod) ClusterConfig

+ func (cc ClusterConfig) WithAlphaVolume(volname, dir string) ClusterConfig

+ func (cc ClusterConfig) WithBulkLoadOutDir(dir string) ClusterConfig

+ func (cc ClusterConfig) WithCustomPlugins() ClusterConfig

+ func (cc ClusterConfig) WithEncryption() ClusterConfig

+ func (cc ClusterConfig) WithExposedPortOffset(offset uint64) ClusterConfig

+ func (cc ClusterConfig) WithGraphqlLambdaURL(url string) ClusterConfig

+ func (cc ClusterConfig) WithMCP() ClusterConfig

+ func (cc ClusterConfig) WithNormalizeCompatibilityMode(mode string) ClusterConfig

+ func (cc ClusterConfig) WithNumAlphas(n int) ClusterConfig

+ func (cc ClusterConfig) WithNumZeros(n int) ClusterConfig

+ func (cc ClusterConfig) WithRefillInterval(interval time.Duration) ClusterConfig

+ func (cc ClusterConfig) WithReplicas(n int) ClusterConfig

+ func (cc ClusterConfig) WithSnapshotConfig(snapShotAfterEntries uint64, snapshotAfterDuration time.Duration) ClusterConfig

+ func (cc ClusterConfig) WithUidLease(uidLease int) ClusterConfig

+ func (cc ClusterConfig) WithVerbosity(v int) ClusterConfig

+ func (cc ClusterConfig) WithVersion(version string) ClusterConfig

+ type ComposeCluster struct

+ func NewComposeCluster() *ComposeCluster

+ func (c *ComposeCluster) AlphasHealth() ([]string, error)

+ func (c *ComposeCluster) AlphasLogs() ([]string, error)

+ func (c *ComposeCluster) AssignUids(client *dgo.Dgraph, num uint64) error

+ func (c *ComposeCluster) Client() (*dgraphapi.GrpcClient, func(), error)

+ func (c *ComposeCluster) GetEncKeyPath() (string, error)

+ func (c *ComposeCluster) GetRepoDir() (string, error)

+ func (c *ComposeCluster) GetVersion() string

+ func (c *ComposeCluster) HTTPClient() (*dgraphapi.HTTPClient, error)

+ type DCloudCluster struct

+ func NewDCloudCluster() (*DCloudCluster, error)

+ func (c *DCloudCluster) AlphasHealth() ([]string, error)

+ func (c *DCloudCluster) AlphasLogs() ([]string, error)

+ func (c *DCloudCluster) Client() (*dgraphapi.GrpcClient, func(), error)

+ func (c *DCloudCluster) GetEncKeyPath() (string, error)

+ func (c *DCloudCluster) GetRepoDir() (string, error)

+ func (c *DCloudCluster) GetVersion() string

+ func (c *DCloudCluster) HTTPClient() (*dgraphapi.HTTPClient, error)

+ func (c1 *DCloudCluster) AssignUids(client *dgo.Dgraph, num uint64) error

+ type Dataset struct

+ func GetDataset(d DatasetType) *Dataset

+ func (d *Dataset) DataFilePath() string

+ func (d *Dataset) GqlSchemaPath() string

+ func (d *Dataset) SchemaPath() string

+ type DatasetType int

+ const OneMillionDataset

+ const TwentyOneMillionDataset

+ type LiveOpts struct

+ DataFiles []string

+ GqlSchemaFiles []string

+ SchemaFiles []string

+ type LocalCluster struct

+ func NewLocalCluster(conf ClusterConfig) (*LocalCluster, error)

+ func (c *LocalCluster) AlphaClient(id int) (*dgraphapi.GrpcClient, func(), error)

+ func (c *LocalCluster) AlphasHealth() ([]string, error)

+ func (c *LocalCluster) AlphasLogs() ([]string, error)

+ func (c *LocalCluster) AssignUids(_ *dgo.Dgraph, num uint64) error

+ func (c *LocalCluster) BulkLoad(opts BulkOpts) error

+ func (c *LocalCluster) Cleanup(verbose bool)

+ func (c *LocalCluster) Client() (*dgraphapi.GrpcClient, func(), error)

+ func (c *LocalCluster) GeneratePlugins(raceEnabled bool) error

+ func (c *LocalCluster) GetAlphaGrpcEndpoint(id int) (string, error)

+ func (c *LocalCluster) GetAlphaGrpcPublicPort(id int) (string, error)

+ func (c *LocalCluster) GetAlphaHttpClient(alphaID int) (*dgraphapi.HTTPClient, error)

+ func (c *LocalCluster) GetAlphaHttpPublicPort(id int) (string, error)

+ func (c *LocalCluster) GetEncKeyPath() (string, error)

+ func (c *LocalCluster) GetRepoDir() (string, error)

+ func (c *LocalCluster) GetTempDir() string

+ func (c *LocalCluster) GetVersion() string

+ func (c *LocalCluster) GetZeroGrpcPublicPort(id int) (string, error)

+ func (c *LocalCluster) HTTPClient() (*dgraphapi.HTTPClient, error)

+ func (c *LocalCluster) HealthCheck(zeroOnly bool) error

+ func (c *LocalCluster) KillAlpha(id int) error

+ func (c *LocalCluster) LiveLoad(opts LiveOpts) error

+ func (c *LocalCluster) LiveLoadFromExport(exportDir string) error

+ func (c *LocalCluster) Start() error

+ func (c *LocalCluster) StartAlpha(id int) error

+ func (c *LocalCluster) StartZero(id int) error

+ func (c *LocalCluster) Stop() error

+ func (c *LocalCluster) StopAlpha(id int) error

+ func (c *LocalCluster) StopZero(id int) error

+ func (c *LocalCluster) Upgrade(version string, strategy UpgradeStrategy) error

+ type UpgradeCombo struct

+ After string

+ Before string

+ Strategy UpgradeStrategy

+ func AllUpgradeCombos(v20 bool) []UpgradeCombo

+ type UpgradeStrategy int

+ const BackupRestore

+ const ExportImport

+ const InPlace

+ func (u UpgradeStrategy) String() string

v25.1.0-preview1

Dec 4, 2025

Other modules containing this package

github.com/dgraph-io/dgraph/v24