test

Documentation

Overview

Copyright 2021 Molecula Corp. All rights reserved.

Index

• func DefaultConfig() *server.Config
• type ManagedCommand
  • func MustRunManagedCommand(tb testing.TB, opts ...server.CommandOption) *ManagedCommand
  • func NewManagedCommand(tb fbtest.DirCleaner, opts ...server.CommandOption) *ManagedCommand
  • func (mc *ManagedCommand) Address() dax.Address
  • func (mc *ManagedCommand) Close() error
  • func (mc *ManagedCommand) Healthy(key dax.ServiceKey) bool
  • func (mc *ManagedCommand) Manage() *dax.ServiceManager
  • func (mc *ManagedCommand) NewComputer() dax.ServiceKey
  • func (mc *ManagedCommand) NewController(cfg controller.Config) dax.ServiceKey
  • func (mc *ManagedCommand) NewQueryer(cfg queryer.Config) dax.ServiceKey
  • func (mc *ManagedCommand) Start() error
  • func (mc *ManagedCommand) WaitForApplied(t *testing.T, key dax.ServiceKey, n int, sleep time.Duration)

Functions

func DefaultConfig

func DefaultConfig() *server.Config

DefaultConfig includes a single instance of each service type.

Types

type ManagedCommand

type ManagedCommand struct {
	*server.Command
	// contains filtered or unexported fields
}

ManagedCommand represents a test wrapper for server.Command.

func MustRunManagedCommand

func MustRunManagedCommand(tb testing.TB, opts ...server.CommandOption) *ManagedCommand

MustRunManagedCommand starts an in-process set of Services based on the provided configuration. If no configuration is provided, it will use the DefaultConfig which consists of one instance of each service type.

func NewManagedCommand

func NewManagedCommand(tb fbtest.DirCleaner, opts ...server.CommandOption) *ManagedCommand

NewManagedCommand returns a new instance of Command.

func (*ManagedCommand) Address

func (mc *ManagedCommand) Address() dax.Address

Address returns the advertise address at which the command can be reached.

func (*ManagedCommand) Close

func (mc *ManagedCommand) Close() error

Close closes the embedded command.

func (*ManagedCommand) Healthy

func (mc *ManagedCommand) Healthy(key dax.ServiceKey) bool

Healthy returns true if the provided service's /health endpoint returns 200 OK. This means that the service has been added to the ServiceManager and started, and that its http handler has been dynamically added.

func (*ManagedCommand) Manage

func (mc *ManagedCommand) Manage() *dax.ServiceManager

Manage returns the ServiceManager for the ManagedCommand.

func (*ManagedCommand) NewComputer

func (mc *ManagedCommand) NewComputer() dax.ServiceKey

NewComputer adds a new ComputerService to the ManagedCommands ServiceManager.

func (*ManagedCommand) NewController

func (mc *ManagedCommand) NewController(cfg controller.Config) dax.ServiceKey

NewController adds a new ControllerService to the ManagedCommands ServiceManager.

func (*ManagedCommand) NewQueryer

func (mc *ManagedCommand) NewQueryer(cfg queryer.Config) dax.ServiceKey

NewQueryer adds a new QueryerService to the ManagedCommands ServiceManager.

func (*ManagedCommand) Start

func (mc *ManagedCommand) Start() error

Start starts the embedded command.

func (*ManagedCommand) WaitForApplied

func (mc *ManagedCommand) WaitForApplied(t *testing.T, key dax.ServiceKey, n int, sleep time.Duration)

WaitForApplied is a test helper function which retries a computer's /directive endpoint a specified number of times, along with a sleep time in between tries, until the computer returns applied=true.