framework

Documentation

Index

• Constants
• Variables
• func FreePorts(count int) ([]int, error)
• func InitCertsDir() error
• type Agent
• type AgentOpts
• type AgentRunner
• type ExternalAgentRunner
  • func (r *ExternalAgentRunner) Start(t testing.TB, opts AgentOpts) (Agent, error)
• type Framework
• type InProcessAgentRunner
  • func (*InProcessAgentRunner) Start(t testing.TB, opts AgentOpts) (Agent, error)
• type InProcessProxyServerRunner
  • func (*InProcessProxyServerRunner) Start(t testing.TB, opts ProxyServerOpts) (ProxyServer, error)
• type ProxyServer
• type ProxyServerOpts
• type ProxyServerRunner

Constants

const (
	TestCAFile         = "anp-test-ca.crt"
	TestServerCertFile = "anp-test-server.crt"
	TestServerKeyFile  = "anp-test-server.key"
	TestAgentCertFile  = "anp-test-agent.crt"
	TestAgentKeyFile   = "anp-test-agent.key"
)

Variables

var CertsDir string // Initialized with InitCertsDir

Functions

func FreePorts

func FreePorts(count int) ([]int, error)

FreePorts finds [count] available ports.

func InitCertsDir

func InitCertsDir() error

InitCertsDir writes the above certificates & keys to a temporary directory.

Types

type Agent

type Agent interface {
	GetConnectedServerCount() (int, error)
	Ready() bool
	Drain()
	Stop()
	Metrics() metricstest.AgentTester
}

type AgentOpts

type AgentOpts struct {
	AgentID    string
	ServerAddr string
}

type AgentRunner

type AgentRunner interface {
	Start(testing.TB, AgentOpts) (Agent, error)
}

type ExternalAgentRunner

type ExternalAgentRunner struct {
	ExecutablePath string
}

func (*ExternalAgentRunner) Start

func (r *ExternalAgentRunner) Start(t testing.TB, opts AgentOpts) (Agent, error)

type Framework

type Framework struct {
	AgentRunner       AgentRunner
	ProxyServerRunner ProxyServerRunner
}

type InProcessAgentRunner

type InProcessAgentRunner struct{}

func (*InProcessAgentRunner) Start

func (*InProcessAgentRunner) Start(t testing.TB, opts AgentOpts) (Agent, error)

type InProcessProxyServerRunner

type InProcessProxyServerRunner struct{}

func (*InProcessProxyServerRunner) Start

func (*InProcessProxyServerRunner) Start(t testing.TB, opts ProxyServerOpts) (ProxyServer, error)

type ProxyServer

type ProxyServer interface {
	ConnectedBackends() (int, error)
	AgentAddr() string
	FrontAddr() string
	Ready() bool
	Stop()
	Metrics() metricstest.ServerTester
}

type ProxyServerOpts

type ProxyServerOpts struct {
	ServerCount int
	Mode        string
	AgentPort   int // Defaults to random port.
}

type ProxyServerRunner

type ProxyServerRunner interface {
	Start(testing.TB, ProxyServerOpts) (ProxyServer, error)
}