dgraphtest

package

Go to main page

Versions in this module

v25

v25.4.0-preview1

May 26, 2026

v25.3.7

Jun 25, 2026

v25.3.6

Jun 19, 2026

Changes in this version

type ClusterConfig

+ func (cc ClusterConfig) WithStartupArg(arg, value string) ClusterConfig

v25.3.5

Jun 11, 2026

Changes in this version

+ var ApplyContainerUser = defaultApplyContainerUser

+ var GeneratePlugins = defaultGeneratePlugins

+ var HostBinaryName = defaultHostBinaryName

+ var SetupLinuxBinaries = defaultSetupLinuxBinaries

+ var WidenSecretFilePerms = defaultWidenSecretFilePerms

+ var WidenTempDirPerms = defaultWidenTempDirPerms

type ClusterConfig

+ func (cc ClusterConfig) WithSecurityToken(token string) ClusterConfig

v25.3.4

May 11, 2026

Changes in this version

type LocalCluster

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

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

+ func (c *LocalCluster) GetZeroFollower(queryIdx int) (*ZeroLocator, error)

+ func (c *LocalCluster) GetZeroFollowers(queryIdx int) ([]ZeroLocator, error)

+ func (c *LocalCluster) GetZeroLeader(queryIdx int) (*ZeroLocator, error)

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

+ func (c *LocalCluster) GetZeroState(id int) (*ZeroState, error)

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

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

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

+ func (c *LocalCluster) WaitForAnyZeroLog(substr string, timeout, poll time.Duration) error

+ func (c *LocalCluster) WaitForZeroAddress(queryIdx int, raftID, wantAddr string, timeout, poll time.Duration) (string, error)

+ func (c *LocalCluster) WaitForZeroLog(id int, substr string, timeout, poll time.Duration) error

+ func (c *LocalCluster) ZeroLogContains(id int, substr string) (bool, error)

+ type ZeroLocator struct

+ Addr string

+ ContainerIdx int

+ RaftID string

+ type ZeroMember struct

+ Addr string

+ Leader bool

+ type ZeroState struct

+ Zeros map[string]ZeroMember

v25.3.3

Apr 21, 2026

v25.3.2

Apr 13, 2026 GO-2026-5749

GO-2026-5749: Dgraph: Pre-Auth Full Database Exfiltration via DQL Injection in NQuad Lang Field in github.com/dgraph-io/dgraph

Changes in this version

type LocalCluster

+ func (c *LocalCluster) ReadFileFromContainer(containerPath string) ([]byte, error)

v25.3.1

Apr 1, 2026 GO-2026-5749

GO-2026-5749: Dgraph: Pre-Auth Full Database Exfiltration via DQL Injection in NQuad Lang Field in github.com/dgraph-io/dgraph

v25.3.1-preview-federation-changes

Mar 20, 2026 GO-2026-5749

GO-2026-5749: Dgraph: Pre-Auth Full Database Exfiltration via DQL Injection in NQuad Lang Field in github.com/dgraph-io/dgraph

v25.3.0

Mar 6, 2026 GO-2026-5749

GO-2026-5749: Dgraph: Pre-Auth Full Database Exfiltration via DQL Injection in NQuad Lang Field in github.com/dgraph-io/dgraph

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 GO-2026-5749

GO-2026-5749: Dgraph: Pre-Auth Full Database Exfiltration via DQL Injection in NQuad Lang Field in github.com/dgraph-io/dgraph

v25.2.0

Jan 29, 2026 GO-2026-5749

GO-2026-5749: Dgraph: Pre-Auth Full Database Exfiltration via DQL Injection in NQuad Lang Field in github.com/dgraph-io/dgraph

v25.1.0

Dec 11, 2025 GO-2026-5749

GO-2026-5749: Dgraph: Pre-Auth Full Database Exfiltration via DQL Injection in NQuad Lang Field in github.com/dgraph-io/dgraph

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 GO-2026-5749

GO-2026-5749: Dgraph: Pre-Auth Full Database Exfiltration via DQL Injection in NQuad Lang Field in github.com/dgraph-io/dgraph

Other modules containing this package

github.com/dgraph-io/dgraph/v24

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL