lukaf · August 4, 2016 11:15
diff --git a/client b/client
 package main

 import (
 	"flag"
 	"fmt"
 	"os"
 	"time"

 	"golang.org/x/net/context"

 	"github.com/docker/engine-api/client"
 	"github.com/docker/engine-api/types"
 	"github.com/docker/engine-api/types/container"
 )

 func main() {
 	timeout := flag.Int("timeout", 1, "Timeout between creating new container in ms")
 	flag.Parse()

 	defaultHeaders := map[string]string{
 		"User-Agent": "engine-api-cli-1.0",
 	}

 	cli, err := client.NewClient("unix:///var/run/docker.sock", "v1.22", nil, defaultHeaders)
 	if err != nil {
 		fmt.Println(err)
 		os.Exit(1)
 	}

 	hostConfig := &container.HostConfig{
 		ReadonlyRootfs: true,
 		LogConfig: container.LogConfig{
 			Type:   "none",
 			Config: map[string]string{},
 		},
 		Binds:           []string{},
 		CapAdd:          nil,
 		CapDrop:         nil,
 		ContainerIDFile: "",
 		Privileged:      false,
 		PortBindings:    nil,
 		Links:           nil,
 		ExtraHosts:      nil,
 		VolumesFrom:     []string{},
 		NetworkMode:     "",
 		RestartPolicy: container.RestartPolicy{
 			Name: "no",
 		},
 		Resources: container.Resources{
 			CPUQuota:   50000,
 			CPUShares:  512,
 			Memory:     25 * 1024 * 1024,
 			MemorySwap: 25 * 1024 * 1024,
 		},
 	}

 	containerConfig := &container.Config{
 		AttachStdin:     false, //bool
 		AttachStdout:    false, //bool
 		AttachStderr:    false, //bool
 		ExposedPorts:    nil,   //map[Port]struct{}
 		Tty:             false, //bool
 		OpenStdin:       false, //bool
 		StdinOnce:       false, //bool If true, close stdin after the 1 attached client
 		Env:             []string{},
 		Cmd:             []string{"sh", "-c", "exit"}, //[]string
 		Image:           "alpine:latest",
 		Volumes:         nil,
 		WorkingDir:      "",   //string
 		Entrypoint:      nil,  //[]string
 		NetworkDisabled: true, //bool
 	}

 	removeOptions := types.ContainerRemoveOptions{
 		RemoveVolumes: false,
 		Force:         true,
 	}

 	timer := time.NewTicker(time.Millisecond * time.Duration(*timeout))

 	c := make(chan string, 10)

 	go func() {
 		for {
 			select {
 			case id := <-c:
 				go func(id string) {
 					if err := cli.ContainerStart(context.Background(), id, types.ContainerStartOptions{}); err != nil {
 						fmt.Println("failed to start container:", err)
 					}
 					if err := cli.ContainerRemove(context.Background(), id, removeOptions); err != nil {
 						fmt.Println("failed to remove container:", err)
 					}
 				}(id)
 			}
 		}
 	}()

 	for {
 		select {
 		case <-timer.C:
 			resp, err := cli.ContainerCreate(context.Background(), containerConfig, hostConfig, nil, "")
 			if err != nil {
 				fmt.Println("Failed to create container:", err)
 				os.Exit(1)
 			}

 			c <- resp.ID
 		}
 	}
 }
	package main

	import (
	"flag"
	"fmt"
	"os"
	"time"

	"golang.org/x/net/context"

	"github.com/docker/engine-api/client"
	"github.com/docker/engine-api/types"
	"github.com/docker/engine-api/types/container"
	)

	func main() {
	timeout := flag.Int("timeout", 1, "Timeout between creating new container in ms")
	flag.Parse()

	defaultHeaders := map[string]string{
	"User-Agent": "engine-api-cli-1.0",
	}

	cli, err := client.NewClient("unix:///var/run/docker.sock", "v1.22", nil, defaultHeaders)
	if err != nil {
	fmt.Println(err)
	os.Exit(1)
	}

	hostConfig := &container.HostConfig{
	ReadonlyRootfs: true,
	LogConfig: container.LogConfig{
	Type: "none",
	Config: map[string]string{},
	},
	Binds: []string{},
	CapAdd: nil,
	CapDrop: nil,
	ContainerIDFile: "",
	Privileged: false,
	PortBindings: nil,
	Links: nil,
	ExtraHosts: nil,
	VolumesFrom: []string{},
	NetworkMode: "",
	RestartPolicy: container.RestartPolicy{
	Name: "no",
	},
	Resources: container.Resources{
	CPUQuota: 50000,
	CPUShares: 512,
	Memory: 25 * 1024 * 1024,
	MemorySwap: 25 * 1024 * 1024,
	},
	}

	containerConfig := &container.Config{
	AttachStdin: false, //bool
	AttachStdout: false, //bool
	AttachStderr: false, //bool
	ExposedPorts: nil, //map[Port]struct{}
	Tty: false, //bool
	OpenStdin: false, //bool
	StdinOnce: false, //bool If true, close stdin after the 1 attached client
	Env: []string{},
	Cmd: []string{"sh", "-c", "exit"}, //[]string
	Image: "alpine:latest",
	Volumes: nil,
	WorkingDir: "", //string
	Entrypoint: nil, //[]string
	NetworkDisabled: true, //bool
	}

	removeOptions := types.ContainerRemoveOptions{
	RemoveVolumes: false,
	Force: true,
	}

	timer := time.NewTicker(time.Millisecond * time.Duration(*timeout))

	c := make(chan string, 10)

	go func() {
	for {
	select {
	case id := <-c:
	go func(id string) {
	if err := cli.ContainerStart(context.Background(), id, types.ContainerStartOptions{}); err != nil {
	fmt.Println("failed to start container:", err)
	}
	if err := cli.ContainerRemove(context.Background(), id, removeOptions); err != nil {
	fmt.Println("failed to remove container:", err)
	}
	}(id)
	}
	}
	}()

	for {
	select {
	case <-timer.C:
	resp, err := cli.ContainerCreate(context.Background(), containerConfig, hostConfig, nil, "")
	if err != nil {
	fmt.Println("Failed to create container:", err)
	os.Exit(1)
	}

	c <- resp.ID
	}
	}
	}