integration

README

Tilt Integration Tests

Runs the Tilt binary and ensures that services are correctly deployed.

Who You Are: A developer who has kubectl configured to talk to an existing cluster.

What This Framework Does: Compiles the Tilt binary, deploys servers to the tilt-integration namespace, and cleans up when it finishes.

Each subdirectory is a test case driven by the file of the same name (e.g., oneup_.go drives the test driven by the data in oneup). Each Tiltfile should deploy small services to gcr.io/windmill-test-containers. Add new images to purge-test-images.sh so that they get purged periodically.

Run the tests with

go test -tags 'integration' -timeout 300s ./integration

or

make integration

These tests will not run with the normal make test.

On CircleCI, we run these tests against a clean Kubernetes cluster. Follow these instructions if you want to run the same cluster locally: https://github.com/kubernetes-sigs/kind

Documentation

Overview

Integration tests that run the Tilt binary directly. See README.md for more info on how to run and write integration tests.

Index

• func TiltDriverUseRandomFreePort(t testing.TB, td *TiltDriver)
• type Event
  • func (e Event) Duration() time.Duration
  • func (e Event) Name() string
  • func (e Event) Tags() map[string]string
• type MemoryStatsReporter
  • func (sr *MemoryStatsReporter) Close() error
  • func (sr *MemoryStatsReporter) Count(name string, value int64, tags map[string]string, rate float64) error
  • func (sr *MemoryStatsReporter) Incr(name string, tags map[string]string, rate float64) error
  • func (sr *MemoryStatsReporter) Timing(name string, value time.Duration, tags map[string]string, rate float64) error
• type MemoryStatsServer
  • func StartMemoryStatsServer() (mss *MemoryStatsServer, port int, err error)
  • func (mss *MemoryStatsServer) TearDown() error
• type StatsReporter
• type StatsServer
  • func NewStatsServer(stats StatsReporter) StatsServer
  • func (s StatsServer) Index(w http.ResponseWriter, r *http.Request)
  • func (s StatsServer) Report(w http.ResponseWriter, r *http.Request)
  • func (s StatsServer) Router() *mux.Router
• type TiltDriver
  • func NewTiltDriver(t testing.TB, options ...TiltDriverOption) *TiltDriver
  • func (d *TiltDriver) APIResources(ctx context.Context) ([]string, error)
  • func (d *TiltDriver) Args(ctx context.Context, args []string, out io.Writer) error
  • func (d *TiltDriver) CI(ctx context.Context, out io.Writer, args ...string) error
  • func (d *TiltDriver) Down(ctx context.Context, out io.Writer) error
  • func (d *TiltDriver) DumpEngine(ctx context.Context, out io.Writer) error
  • func (d *TiltDriver) Get(ctx context.Context, apiType string, names ...string) ([]byte, error)
  • func (d *TiltDriver) Patch(ctx context.Context, apiType string, patch string, name string) error
  • func (d *TiltDriver) Up(ctx context.Context, command UpCommand, out io.Writer, args ...string) (*TiltUpResponse, error)
• type TiltDriverOption
• type TiltUpResponse
  • func (r *TiltUpResponse) Done() <-chan struct{}
  • func (r *TiltUpResponse) Err() error
  • func (r *TiltUpResponse) KillAndDumpThreads() error
  • func (r *TiltUpResponse) TriggerExit() error
• type UpCommand

Functions

func TiltDriverUseRandomFreePort

func TiltDriverUseRandomFreePort(t testing.TB, td *TiltDriver)

Types

type Event

type Event map[string]interface{}

func (Event) Duration

func (e Event) Duration() time.Duration

func (Event) Name

func (e Event) Name() string

func (Event) Tags

func (e Event) Tags() map[string]string

type MemoryStatsReporter

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

func (*MemoryStatsReporter) Close

func (sr *MemoryStatsReporter) Close() error

func (*MemoryStatsReporter) Count

func (sr *MemoryStatsReporter) Count(name string, value int64, tags map[string]string, rate float64) error

func (*MemoryStatsReporter) Incr

func (sr *MemoryStatsReporter) Incr(name string, tags map[string]string, rate float64) error

func (*MemoryStatsReporter) Timing

func (sr *MemoryStatsReporter) Timing(name string, value time.Duration, tags map[string]string, rate float64) error

type MemoryStatsServer

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

func StartMemoryStatsServer

func StartMemoryStatsServer() (mss *MemoryStatsServer, port int, err error)

func (*MemoryStatsServer) TearDown

func (mss *MemoryStatsServer) TearDown() error

type StatsReporter

type StatsReporter interface {
	io.Closer
	Timing(name string, value time.Duration, tags map[string]string, rate float64) error
	Count(name string, value int64, tags map[string]string, rate float64) error
	Incr(name string, tags map[string]string, rate float64) error
}

type StatsServer

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

A small http server that decodes json and sends it to our metrics services

func NewStatsServer

func NewStatsServer(stats StatsReporter) StatsServer

func (StatsServer) Index

func (s StatsServer) Index(w http.ResponseWriter, r *http.Request)

func (StatsServer) Report

func (s StatsServer) Report(w http.ResponseWriter, r *http.Request)

func (StatsServer) Router

func (s StatsServer) Router() *mux.Router

type TiltDriver

type TiltDriver struct {
	Environ map[string]string
	// contains filtered or unexported fields
}

func NewTiltDriver

func NewTiltDriver(t testing.TB, options ...TiltDriverOption) *TiltDriver

func (*TiltDriver) APIResources

func (d *TiltDriver) APIResources(ctx context.Context) ([]string, error)

func (*TiltDriver) Args

func (d *TiltDriver) Args(ctx context.Context, args []string, out io.Writer) error

func (*TiltDriver) CI

func (d *TiltDriver) CI(ctx context.Context, out io.Writer, args ...string) error

func (*TiltDriver) Down

func (d *TiltDriver) Down(ctx context.Context, out io.Writer) error

func (*TiltDriver) DumpEngine

func (d *TiltDriver) DumpEngine(ctx context.Context, out io.Writer) error

func (*TiltDriver) Get

func (d *TiltDriver) Get(ctx context.Context, apiType string, names ...string) ([]byte, error)

func (*TiltDriver) Patch

func (d *TiltDriver) Patch(ctx context.Context, apiType string, patch string, name string) error

func (*TiltDriver) Up

func (d *TiltDriver) Up(ctx context.Context, command UpCommand, out io.Writer, args ...string) (*TiltUpResponse, error)

type TiltDriverOption

type TiltDriverOption func(t testing.TB, td *TiltDriver)

type TiltUpResponse

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

func (*TiltUpResponse) Done

func (r *TiltUpResponse) Done() <-chan struct{}

func (*TiltUpResponse) Err

func (r *TiltUpResponse) Err() error

func (*TiltUpResponse) KillAndDumpThreads

func (r *TiltUpResponse) KillAndDumpThreads() error

Kill the tilt process and print the goroutine/register state. Useful if you think Tilt is deadlocked but aren't sure why.

func (*TiltUpResponse) TriggerExit

func (r *TiltUpResponse) TriggerExit() error

TriggerExit sends a SIGTERM to the `tilt up` process to give it a chance to exit normally.

If the signal cannot be sent or 2 seconds have elapsed, it will be forcibly killed with SIGKILL.

type UpCommand

type UpCommand string

const (
	UpCommandUp   UpCommand = "up"
	UpCommandDemo UpCommand = "demo"
)