api

Jan 4, 2018

Changes in this version

type Client

+ Endpoint config.Endpoint

+ Namespace string

+ func NewClient(namespace string, endpoint config.Endpoint) *Client

+ func (c *Client) Exec(containerID string, args []string, tty bool, attachIO AttachIO, ...) (err error)

+ func (c *Client) GetInfo() (*device.Info, error)

type Server

+ func (s *Server) Exec(server containers.Containers_ExecServer) error

+ func (s *Server) Info(context context.Context, req *device.InfoRequest) (*device.InfoResponse, error)

Dec 19, 2017

Changes in this version

type Server

+ func (s *Server) Stop()

Dec 8, 2017

Changes in this version

+ type AttachHooks func(endpoint config.Endpoint, done <-chan struct{})

+ type AttachIO struct

+ Stderr io.Writer

+ Stdin io.Reader

+ Stdout io.Writer

+ func NewAttachIO(stdin io.Reader, stdout, stderr io.Writer) AttachIO

+ type Client interface

+ Attach func(containerID string, attachIO AttachIO, hooks ...AttachHooks) (err error)

+ CreatePod func(status chan<- []*progress.ImageFetch, pod *pods.Pod, opts ...PodOpts) error

+ DeletePod func(pod *pods.Pod) (*pods.Pod, error)

+ GetPod func(podName string) (*pods.Pod, error)

+ GetPods func() ([]*pods.Pod, error)

+ Signal func(containerID string, signal syscall.Signal) (err error)

+ StartPod func(name string) (*pods.Pod, error)

+ type DirectClient struct

+ Endpoint config.Endpoint

+ Namespace string

+ func NewDirectClient(namespace string, endpoint config.Endpoint) *DirectClient

+ func (c *DirectClient) Attach(containerID string, attachIO AttachIO, hooks ...AttachHooks) (err error)

+ func (c *DirectClient) CreatePod(status chan<- []*progress.ImageFetch, pod *pods.Pod, opts ...PodOpts) error

+ func (c *DirectClient) DeletePod(pod *pods.Pod) (*pods.Pod, error)

+ func (c *DirectClient) GetPod(podName string) (*pods.Pod, error)

+ func (c *DirectClient) GetPods() ([]*pods.Pod, error)

+ func (c *DirectClient) Signal(containerID string, signal syscall.Signal) (err error)

+ func (c *DirectClient) StartPod(name string) (*pods.Pod, error)

+ type MultiDirectClient struct

+ Namespace string

+ func NewMultiDirectClient(namespace string, endpoints []config.Endpoint) *MultiDirectClient

+ func (c *MultiDirectClient) Attach(containerID string, attachIO AttachIO, hooks ...AttachHooks) (err error)

+ func (c *MultiDirectClient) CreatePod(updates chan<- []*progress.ImageFetch, pod *pods.Pod, opts ...PodOpts) error

+ func (c *MultiDirectClient) DeletePod(pod *pods.Pod) (*pods.Pod, error)

+ func (c *MultiDirectClient) GetPod(podName string) (*pods.Pod, error)

+ func (c *MultiDirectClient) GetPods() (result []*pods.Pod, err error)

+ func (c *MultiDirectClient) Signal(containerID string, signal syscall.Signal) (err error)

+ func (c *MultiDirectClient) StartPod(name string) (*pods.Pod, error)

+ type PodOpts func(pod *pods.Pod) error

+ func WithContainer(container *containers.Container) PodOpts

+ func WithSharedMount(mount *containers.Mount) PodOpts

+ func WithWorkingDir(workDir string) PodOpts

+ type Server struct

+ func NewServer(listen string, client runtime.Client) *Server

+ func (s *Server) Attach(server containers.Containers_AttachServer) error

+ func (s *Server) Create(req *pods.CreatePodRequest, server pods.Pods_CreateServer) error

+ func (s *Server) Delete(context context.Context, req *pods.DeletePodRequest) (*pods.DeletePodResponse, error)

+ func (s *Server) List(context context.Context, req *pods.ListPodsRequest) (*pods.ListPodsResponse, error)

+ func (s *Server) Serve() error

+ func (s *Server) Signal(cxt context.Context, req *containers.SignalRequest) (*containers.SignalResponse, error)

+ func (s *Server) Start(context context.Context, req *pods.StartPodRequest) (*pods.StartPodResponse, error)