nktest

May 22, 2023

Changes in this version

+ func PodmanStopAndRemove(ctx context.Context, id, containerId string)

+ func PodmanWaitService(ctx context.Context, id, svc string, ...) error

May 2, 2023

Changes in this version

type Option

+ func WithRunEnv(runEnv map[string]string) Option

Jan 25, 2023

Changes in this version

+ var DefaultBackoffConfig = BackoffConfig

+ func WithBackoff(parent context.Context, min, max, timeout time.Duration, factor float64) context.Context

+ func WithBackoffConfig(parent context.Context, backoffConfig BackoffConfig) context.Context

+ type BackoffConfig struct

+ Factor float64

+ Max time.Duration

+ Min time.Duration

+ Timeout time.Duration

+ func (bc BackoffConfig) Next(d time.Duration) time.Duration

Jan 20, 2023

Changes in this version

+ var DefaultBuildTimeout = 5 * time.Minute

+ var DefaultUnderCI = false

+ func BuildTimeout(ctx context.Context) time.Duration

+ func UnderCI(ctx context.Context) bool

+ func WithBuildTimeout(parent context.Context, buildTimeout time.Duration) context.Context

+ func WithUnderCIFromEnv(parent context.Context, name string) context.Context

type BuildConfigOption

+ func WithGoBuildOptions(buildOpts ...string) BuildConfigOption

Jan 16, 2023

Changes in this version

type BuildConfigOption

+ func WithFixProtoEnvVar() BuildConfigOption

Jan 8, 2023

Changes in this version

+ var NakamaBuilderContainerShortName = "bd"

+ var NakamaContainerShortName = "nk"

+ var NktestRunnerShortName = "xx"

+ var PostgresContainerShortName = "pg"

+ func SetLevel(level zerolog.Level)

+ func Trace(ctx context.Context) *zerolog.Event

Dec 2, 2022

Changes in this version

type PodmanConnInfo

+ Insecure bool

Sep 27, 2022

Changes in this version

+ var ReplaceCallerField = true

Sep 27, 2022

Changes in this version

+ var NakamaCallerValue = "nk"

+ var NktestCallerValue = "nktest"

Sep 27, 2022

Changes in this version

+ func NewConsoleWriter(w, cw io.Writer, field, value string) io.Writer

+ func WithConsoleWriter(parent context.Context, consoleWriter io.Writer) context.Context

Sep 27, 2022

Changes in this version

+ var ContainerEmptyValue = "--------"

+ var ContainerIdFieldName = "container_id"

+ var TimeFormatValue = "2006-01-02 15:04:05"

+ func ConsoleWriter(w, cw io.Writer, field, value string) io.Writer

+ func Cout(ctx context.Context) io.Writer

+ func Debug(ctx context.Context) *zerolog.Event

+ func Err(ctx context.Context, err error) *zerolog.Event

+ func Info(ctx context.Context) *zerolog.Event

+ func WithCout(parent context.Context, cout io.Writer) context.Context

Sep 25, 2022

Changes in this version

+ var DefaultPodRemoveTimeout = 200 * time.Millisecond

+ func PodRemoveTimeout(ctx context.Context) time.Duration

+ func PodmanPodKill(ctx context.Context, name string) error

+ func WithPodRemoveTimeout(parent context.Context, podRemoveTimeout time.Duration) context.Context

Sep 24, 2022

Changes in this version

+ func Run() error

type Runner

+ func (r *Runner) PodContainerId() string

Sep 22, 2022

Changes in this version

+ func RunProxy(ctx context.Context, opts ...ProxyOption) (string, error)

Sep 22, 2022

Changes in this version

+ var DefaultAlwaysPull = false

+ var DefaultBackoffMaxElapsedTime = 30 * time.Second

+ var DefaultBackoffMaxInterval = 2 * time.Second

+ var DefaultCancelDelay = 2200 * time.Millisecond

+ var DefaultConfigFilename = "config.yml"

+ var DefaultConfigTemplate string

+ var DefaultContainerRemoveDelay = 500 * time.Millisecond

+ var DefaultDockerAuthName = "registry.docker.io"

+ var DefaultDockerAuthScope = "repository:%s:pull"

+ var DefaultDockerRegistryURL = "https://registry-1.docker.io"

+ var DefaultDockerTokenURL = "https://auth.docker.io/token"

+ var DefaultNakamaImageId = "docker.io/heroiclabs/nakama"

+ var DefaultNetworkRemoveDelay = 1500 * time.Millisecond

+ var DefaultPluginbuilderImageId = "docker.io/heroiclabs/nakama-pluginbuilder"

+ var DefaultPostgresImageId = "docker.io/library/postgres"

+ var DefaultPostgresVersion = "latest"

+ var DefaultPrefixIn = "<- "

+ var DefaultPrefixOut = "-> "

+ var DefaultVersionCacheTTL = 96 * time.Hour

+ func AlwaysPull(ctx context.Context) bool

+ func Backoff(ctx context.Context, f func() error) error

+ func Cancel()

+ func CancelDelay(ctx context.Context) time.Duration

+ func ConfigFilename(ctx context.Context) string

+ func ConfigTemplate(ctx context.Context) string

+ func ContainerRemoveDelay(ctx context.Context) time.Duration

+ func Context() context.Context

+ func DockerAuthName(ctx context.Context) string

+ func DockerAuthScope(ctx context.Context, id string) string

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

+ func DockerRegistryURL(ctx context.Context) string

+ func DockerToken(ctx context.Context, id string) (string, error)

+ func DockerTokenURL(ctx context.Context) string

+ func Errf(ctx context.Context, s string, v ...interface{})

+ func HostPortMap(ctx context.Context, id, svc string, containerPort, hostPort uint16) uint16

+ func HttpClient(ctx context.Context) *http.Client

+ func Logf(ctx context.Context, s string, v ...interface{})

+ func Main(parent context.Context, m TestRunner, opts ...Option)

+ func NakamaImageId(ctx context.Context) string

+ func NakamaVersion(ctx context.Context) (string, error)

+ func NetworkRemoveDelay(ctx context.Context) time.Duration

+ func NoopWriter() io.Writer

+ func PluginbuilderImageId(ctx context.Context) string

+ func PodmanConn(ctx context.Context) context.Context

+ func PortMap(ctx context.Context) map[string]uint16

+ func PostgresImageId(ctx context.Context) string

+ func PostgresVersion(ctx context.Context) string

+ func SetVerbose(verbose bool)

+ func Stderr(ctx context.Context) io.Writer

+ func Stdout(ctx context.Context) io.Writer

+ func VersionCacheTTL(ctx context.Context) time.Duration

+ func WithAlwaysPullFromEnv(parent context.Context, name string) context.Context

+ func WithCancelDelay(parent context.Context, cancelDelay time.Duration) context.Context

+ func WithPodmanConn(parent, conn context.Context) context.Context

+ type RoundTripper struct

+ func NewRoundTripper(req, res io.Writer, transport http.RoundTripper) *RoundTripper

+ func (t *RoundTripper) DisableReqBody()

+ func (t *RoundTripper) DisableResBody()

+ func (t *RoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type Runner

+ func NewRunner(opts ...Option) *Runner

+ func WithCancel(parent context.Context, t TestLogger) (context.Context, context.CancelFunc, *Runner)

+ type TestLogger interface

+ Logf func(string, ...interface{})

+ type TestRunner interface

+ Run func() int

Sep 16, 2022

Changes in this version

+ func NewNoopWriter() io.Writer

Aug 20, 2022

Changes in this version

+ func PodmanOpen(ctx context.Context, h Handler) (context.Context, context.Context, error)

+ type PodmanConnInfo struct

+ Default bool

+ Identity string

+ Name string

+ URI string

+ func BuildPodmanConnInfo(ctx context.Context) ([]PodmanConnInfo, error)

+ func PodmanSystemConnectionList(ctx context.Context) ([]PodmanConnInfo, error)

Aug 2, 2022

Changes in this version

type Runner

+ func (t *Runner) ConsoleLocal() string

+ func (t *Runner) ConsoleRemote() string

+ func (t *Runner) HttpKey() string

Aug 2, 2022

Changes in this version

+ func ParsePortMapping(s string) (pntypes.PortMapping, error)

type Handler

+ HostPortMap func(string, string, uint16, uint16) uint16

type Option

+ func WithHostPortMap() Option

+ func WithPortMap(id, svc string, port uint16) Option

type Runner

+ func (t *Runner) HostPortMap(id, svc string, containerPort, hostPort uint16) uint16

Jul 28, 2022

Changes in this version

+ func LocalAddr(l net.Listener) string

type Proxy

+ func (p Proxy) DialError(logger io.Writer, w http.ResponseWriter, req *http.Request, res *http.Response, ...)

+ func (p Proxy) InternalError(res http.ResponseWriter, s string, v ...interface{})

type Runner

+ func (t *Runner) ServerKey() string

Jul 27, 2022

Changes in this version

+ var DefaultInPrefix = "<- "

+ var DefaultOutPrefix = "-> "

+ var DefaultProxyReadSize = 10 * 1024 * 1024

+ var DefaultProxyWriteSize = 10 * 1024 * 1024

+ var DefaultTransport = &http.Transport

+ func GenDockerToken(ctx context.Context, h Handler, id string) (string, error)

+ func GetImageTags(ctx context.Context, h Handler, id string) ([]string, error)

+ func GoEnvVar(goPath, name string) (string, error)

+ func IsSubDir(a, b string) error

+ func NewPortMapping(s string) (pntypes.PortMapping, error)

+ func NewPrefixedWriter(w io.Writer, prefix string) io.Writer

+ func PodmanBuildMounts(mounts ...string) ([]pspec.Mount, error)

+ func PodmanContext(ctx context.Context) (context.Context, context.Context, error)

+ func PodmanCreatePod(ctx, conn context.Context, h Handler, ids ...string) (string, error)

+ func PodmanFollowLogs(ctx context.Context, h Handler, id string) error

+ func PodmanGetAddr(ctx context.Context, h Handler, id, svc string) (string, string, error)

+ func PodmanPullImages(ctx, conn context.Context, h Handler, ids ...string) error

+ func PodmanRun(ctx, conn context.Context, h Handler, id string, env map[string]string, ...) (string, error)

+ func PodmanServiceWait(ctx context.Context, h Handler, id, svc string, f func(string, string) error) error

+ func PodmanWait(ctx context.Context, h Handler, id string) error

+ func QualifiedId(id string) string

+ func ReadCachedFile(name string, ttl time.Duration) ([]byte, error)

+ func ShortId(id string) string

+ type BuildConfig struct

+ type BuildConfigOption func(*BuildConfig) error

+ func WithDefaultGoEnv() BuildConfigOption

+ func WithDefaultGoVolumes() BuildConfigOption

+ func WithEnv(env map[string]string) BuildConfigOption

+ func WithGoEnv(env ...string) BuildConfigOption

+ func WithGoEnvVolumes(volumes ...EnvVolumeInfo) BuildConfigOption

+ func WithMounts(mounts ...string) BuildConfigOption

+ func WithOut(out string) BuildConfigOption

+ type EnvVolumeInfo struct

+ Key string

+ Sub string

+ Target string

+ func NewEnvVolume(key, target, sub string) EnvVolumeInfo

+ type Handler interface

+ AlwaysPull func() bool

+ Backoff func(context.Context, func() error) error

+ ContainerRemoveDelay func() time.Duration

+ DockerAuthName func() string

+ DockerAuthScope func(string) string

+ DockerRegistryURL func() string

+ DockerTokenURL func() string

+ Errf func(string, ...interface{})

+ HttpClient func() *http.Client

+ Logf func(string, ...interface{})

+ Name func() string

+ NetworkRemoveDelay func() time.Duration

+ PodId func() string

+ Stderr func(string) io.Writer

+ Stdout func(string) io.Writer

+ type Logger interface

+ Errf func(string, ...interface{})

+ Logf func(string, ...interface{})

+ Stderr func(string) io.Writer

+ Stdout func(string) io.Writer

+ Transport func(http.RoundTripper) http.RoundTripper

+ func NewLogger(f func(string, ...interface{})) Logger

+ func TruncatedLogger() Logger

+ type Option func(*Runner)

+ func WithAlwaysPull(alwaysPull bool) Option

+ func WithBackoffMaxElapsedTime(backoffMaxElapsedTime time.Duration) Option

+ func WithBackoffMaxInterval(backoffMaxInterval time.Duration) Option

+ func WithBuildConfig(modulePath string, opts ...BuildConfigOption) Option

+ func WithConfigFilename(configFilename string) Option

+ func WithConfigTemplate(configTemplate string) Option

+ func WithContainerRemoveDelay(containerRemoveDelay time.Duration) Option

+ func WithDir(dir string) Option

+ func WithDockerAuthName(dockerAuthName string) Option

+ func WithDockerAuthScope(dockerAuthScope string) Option

+ func WithDockerRegistryURL(dockerRegistryURL string) Option

+ func WithDockerTokenURL(dockerTokenURL string) Option

+ func WithHttpClient(httpClient *http.Client) Option

+ func WithNakamaImageId(nakamaImageId string) Option

+ func WithNakamaVersion(nakamaVersion string) Option

+ func WithName(name string) Option

+ func WithNetworkRemoveDelay(networkRemoveDelay time.Duration) Option

+ func WithPluginbuilderImageId(pluginbuilderImageId string) Option

+ func WithPostgresImageId(postgresImageId string) Option

+ func WithPostgresVersion(postgresVersion string) Option

+ func WithStderr(stderr io.Writer) Option

+ func WithStdout(stdout io.Writer) Option

+ func WithVersionCacheTTL(versionCacheTTL time.Duration) Option

+ func WithVolumeDir(volumeDir string) Option

+ type PrefixedWriter struct

+ func (w *PrefixedWriter) Write(buf []byte) (int, error)

+ type Proxy struct

+ func NewProxy(opts ...ProxyOption) *Proxy

+ func (p *Proxy) Addr() string

+ func (p *Proxy) Run(ctx context.Context, urlstr string) (string, error)

+ type ProxyOption func(*Proxy)

+ func WithAddr(addr string) ProxyOption

+ func WithDialer(dialer websocket.Dialer) ProxyOption

+ func WithLogf(f func(string, ...interface{})) ProxyOption

+ func WithLogger(logger Logger) ProxyOption

+ func WithUpgrader(upgrader websocket.Upgrader) ProxyOption

+ func WithWsPath(wsPath string) ProxyOption

+ type Runner struct

+ func New(opts ...Option) *Runner

+ func (t *Runner) AlwaysPull() bool

+ func (t *Runner) Backoff(ctx context.Context, f func() error) error

+ func (t *Runner) BuildModule(ctx, conn context.Context, bc *BuildConfig) error

+ func (t *Runner) BuildModules(ctx, conn context.Context) error

+ func (t *Runner) ContainerRemoveDelay() time.Duration

+ func (t *Runner) DockerAuthName() string

+ func (t *Runner) DockerAuthScope(id string) string

+ func (t *Runner) DockerRegistryURL() string

+ func (t *Runner) DockerTokenURL() string

+ func (t *Runner) Errf(s string, v ...interface{})

+ func (t *Runner) GetNakamaVersion(ctx context.Context) error

+ func (t *Runner) GrpcLocal() string

+ func (t *Runner) GrpcRemote() string

+ func (t *Runner) HttpClient() *http.Client

+ func (t *Runner) HttpLocal() string

+ func (t *Runner) HttpRemote() string

+ func (t *Runner) Init() error

+ func (t *Runner) Logf(s string, v ...interface{})

+ func (t *Runner) Name() string

+ func (t *Runner) NetworkRemoveDelay() time.Duration

+ func (t *Runner) PodId() string

+ func (t *Runner) PostgresLocal() string

+ func (t *Runner) PostgresRemote() string

+ func (t *Runner) Run(ctx context.Context) error

+ func (t *Runner) RunNakama(ctx, conn context.Context) error

+ func (t *Runner) RunPostgres(ctx, conn context.Context) error

+ func (t *Runner) RunProxy(ctx context.Context, opts ...ProxyOption) (string, error)

+ func (t *Runner) Stderr(prefix string) io.Writer

+ func (t *Runner) Stdout(prefix string) io.Writer

+ func (t *Runner) Transport(transport http.RoundTripper) http.RoundTripper

+ func (t *Runner) Write(buf []byte) (int, error)

+ type Transport struct

+ func NewTransport(req, res io.Writer, transport http.RoundTripper) *Transport

+ func (t *Transport) DisableReqBody()

+ func (t *Transport) DisableResBody()

+ func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)