testserver

Documentation

Index

• Constants
• Variables
• func NewTestServer(require *require.Assertions, revisionQuantization time.Duration, ...) (*grpc.ClientConn, func(), datastore.Datastore, datastore.Revision)
• func NewTestServerWithConfig(require *require.Assertions, revisionQuantization time.Duration, ...) (*grpc.ClientConn, func(), datastore.Datastore, datastore.Revision)
• func NewTestServerWithConfigAndDatastore(require *require.Assertions, revisionQuantization time.Duration, ...) (*grpc.ClientConn, func(), datastore.Datastore, datastore.Revision)
• func TestClusterWithDispatch(t testing.TB, size uint, ds datastore.Datastore, ...) ([]*grpc.ClientConn, func())
• func TestClusterWithDispatchAndCacheConfig(t testing.TB, size uint, ds datastore.Datastore, ...) ([]*grpc.ClientConn, func())
• type SafeManualResolver
  • func (r *SafeManualResolver) Close()
  • func (r *SafeManualResolver) ResolveNow(_ resolver.ResolveNowOptions)
• type SafeManualResolverBuilder
  • func (b *SafeManualResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (b *SafeManualResolverBuilder) ResolveNow(prefix string)
  • func (b *SafeManualResolverBuilder) Scheme() string
  • func (b *SafeManualResolverBuilder) SetAddrs(prefix string, addrs []resolver.Address)
• type ServerConfig
• type TempError
  • func (t TempError) Error() string
  • func (t TempError) Temporary() bool

Constants

const TestResolverScheme = "test"

Variables

var DefaultTestServerConfig = ServerConfig{
	MaxUpdatesPerWrite:              1000,
	MaxPreconditionsCount:           1000,
	StreamingAPITimeout:             30 * time.Second,
	MaxRelationshipContextSize:      25000,
	UseExperimentalLookupResources2: false,
}

Functions

func NewTestServer

func NewTestServer(require *require.Assertions,
	revisionQuantization time.Duration,
	gcWindow time.Duration,
	schemaPrefixRequired bool,
	dsInitFunc func(datastore.Datastore, *require.Assertions) (datastore.Datastore, datastore.Revision),
) (*grpc.ClientConn, func(), datastore.Datastore, datastore.Revision)

NewTestServer creates a new test server, using defaults for the config.

func NewTestServerWithConfig

func NewTestServerWithConfig(require *require.Assertions,
	revisionQuantization time.Duration,
	gcWindow time.Duration,
	schemaPrefixRequired bool,
	config ServerConfig,
	dsInitFunc func(datastore.Datastore, *require.Assertions) (datastore.Datastore, datastore.Revision),
) (*grpc.ClientConn, func(), datastore.Datastore, datastore.Revision)

NewTestServerWithConfig creates as new test server with the specified config.

func NewTestServerWithConfigAndDatastore

func NewTestServerWithConfigAndDatastore(require *require.Assertions,
	revisionQuantization time.Duration,
	gcWindow time.Duration,
	schemaPrefixRequired bool,
	config ServerConfig,
	emptyDS datastore.Datastore,
	dsInitFunc func(datastore.Datastore, *require.Assertions) (datastore.Datastore, datastore.Revision),
) (*grpc.ClientConn, func(), datastore.Datastore, datastore.Revision)

func TestClusterWithDispatch

func TestClusterWithDispatch(t testing.TB, size uint, ds datastore.Datastore, additionalServerOptions ...server.ConfigOption) ([]*grpc.ClientConn, func())

TestClusterWithDispatch creates a cluster with `size` nodes The cluster has a real dispatch stack that uses bufconn grpc connections

func TestClusterWithDispatchAndCacheConfig

func TestClusterWithDispatchAndCacheConfig(t testing.TB, size uint, ds datastore.Datastore, additionalServerOptions ...server.ConfigOption) ([]*grpc.ClientConn, func())

TestClusterWithDispatchAndCacheConfig creates a cluster with `size` nodes and with cache toggled.

Types

type SafeManualResolver

type SafeManualResolver struct {
	// contains filtered or unexported fields
}

SafeManualResolver is the resolver type that SafeManualResolverBuilder builds it returns a static list of addresses

func (*SafeManualResolver) Close

func (r *SafeManualResolver) Close()

Close implements the resolver.Resolver interface

func (*SafeManualResolver) ResolveNow

func (r *SafeManualResolver) ResolveNow(_ resolver.ResolveNowOptions)

ResolveNow implements the resolver.Resolver interface It sends the static list of addresses to the underlying resolver.ClientConn

type SafeManualResolverBuilder

type SafeManualResolverBuilder struct {
	// contains filtered or unexported fields
}

SafeManualResolverBuilder is a resolver builder that builds SafeManualResolvers it is similar to manual.Resolver in grpc, but is thread safe

func (*SafeManualResolverBuilder) Build

func (b *SafeManualResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*SafeManualResolverBuilder) ResolveNow

func (b *SafeManualResolverBuilder) ResolveNow(prefix string)

func (*SafeManualResolverBuilder) Scheme

func (b *SafeManualResolverBuilder) Scheme() string

func (*SafeManualResolverBuilder) SetAddrs

func (b *SafeManualResolverBuilder) SetAddrs(prefix string, addrs []resolver.Address)

type ServerConfig

type ServerConfig struct {
	MaxUpdatesPerWrite              uint16
	MaxPreconditionsCount           uint16
	MaxRelationshipContextSize      int
	StreamingAPITimeout             time.Duration
	UseExperimentalLookupResources2 bool
}

ServerConfig is configuration for the test server.

type TempError

type TempError struct{}

func (TempError) Error

func (t TempError) Error() string

func (TempError) Temporary

func (t TempError) Temporary() bool