runner

type ContainerRunner ¶

type ContainerRunner interface {
	PullImage(string) error
	RunContainer(string) (string, error)
	ContainerIP(context.Context, string) (string, error)
}

ContainerRunner handles getting the function code, starting it in a container and getting the IP address of the container to interact with it

type DockerClient ¶

type DockerClient interface {
	ImagePull(context.Context, string, types.ImagePullOptions) (io.ReadCloser, error)
	ContainerStart(context.Context, string, types.ContainerStartOptions) error
	ContainerCreate(context.Context, *container.Config, *container.HostConfig, *network.NetworkingConfig, string) (container.ContainerCreateCreatedBody, error)
	ContainerInspect(context.Context, string) (types.ContainerJSON, error)
	ContainerWait(context.Context, string, container.WaitCondition) (<-chan container.ContainerWaitOKBody, <-chan error)
	ContainerLogs(context.Context, string, types.ContainerLogsOptions) (io.ReadCloser, error)
}

type DockerRunner ¶

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

DockerRunner implements ContainerRunner and uses the Docker SDK to pull images and run function code in a Docker container

func NewDockerRunner(registryUsername string, registryPassword string) (*DockerRunner, error)

func (d DockerRunner) ContainerIP(ctx context.Context, id string) (string, error)

func (d DockerRunner) LogOutputToConsole(ctx context.Context, id string) error

func (d DockerRunner) PullImage(name string) error

func (d DockerRunner) RunContainer(image string) (string, error)

type HTTPPoster ¶ added in v0.4.0

type HTTPPoster interface {
	Post(string, string, io.Reader) (*http.Response, error)
}

type Runner ¶ added in v0.4.0

type Runner struct {
	CR     ContainerRunner
	Client HTTPPoster
}

Runner handles starting up the function code in a container, sending an HTTP request to invoke the function, and returning the response of the function back to the caller

func NewRunner(cr ContainerRunner, c HTTPPoster) Runner

func (r Runner) SendRequestToContainer(url string, input []byte) (string, error)

func (r Runner) StartFnContainer(image string) (string, error)

func (r Runner) TriggerContainerFn(ip string, input []byte) (output string, err error)