package bindings import ( "fmt" "net/http" "strconv" "github.com/containers/libpod/libpod" ) func (c Connection) CreatePod() error { // TODO return ErrNotImplemented } func (c Connection) PodExists(nameOrID string) (bool, error) { response, err := http.Get(c.makeEndpoint(fmt.Sprintf("/pods/%s/exists", nameOrID))) // nolint defer closeResponseBody(response) if err != nil { return false, err } return response.StatusCode == http.StatusOK, err } func (c Connection) InspectPod(nameOrID string) (*libpod.PodInspect, error) { inspect := libpod.PodInspect{} response, err := c.newRequest(http.MethodGet, fmt.Sprintf("/pods/%s/json", nameOrID), nil, nil) if err != nil { return &inspect, err } return &inspect, response.Process(&inspect) } func (c Connection) KillPod(nameOrID string, signal int) error { params := make(map[string]string) params["signal"] = strconv.Itoa(signal) response, err := c.newRequest(http.MethodPost, fmt.Sprintf("/pods/%s/kill", nameOrID), nil, params) if err != nil { return err } return response.Process(nil) } func (c Connection) PausePod(nameOrID string) error { response, err := c.newRequest(http.MethodPost, fmt.Sprintf("/pods/%s/pause", nameOrID), nil, nil) if err != nil { return err } return response.Process(nil) } func (c Connection) PrunePods(force bool) error { params := make(map[string]string) params["force"] = strconv.FormatBool(force) response, err := c.newRequest(http.MethodPost, "/pods/prune", nil, params) if err != nil { return err } return response.Process(nil) } func (c Connection) ListPods(filters []string) (*[]libpod.PodInspect, error) { var ( inspect []libpod.PodInspect ) params := make(map[string]string) // TODO I dont remember how to do this for []string{} // FIXME //params["filters"] = strconv.FormatBool(force) response, err := c.newRequest(http.MethodPost, "/pods/json", nil, params) if err != nil { return &inspect, err } return &inspect, response.Process(&inspect) } func (c Connection) RestartPod(nameOrID string) error { response, err := c.newRequest(http.MethodPost, fmt.Sprintf("/pods/%s/restart", nameOrID), nil, nil) if err != nil { return err } return response.Process(nil) } func (c Connection) RemovePod(nameOrID string, force bool) error { params := make(map[string]string) params["force"] = strconv.FormatBool(force) response, err := c.newRequest(http.MethodDelete, fmt.Sprintf("/pods/%s", nameOrID), nil, params) if err != nil { return err } return response.Process(nil) } func (c Connection) StartPod(nameOrID string) error { response, err := c.newRequest(http.MethodDelete, fmt.Sprintf("/pods/%s/start", nameOrID), nil, nil) if err != nil { return err } return response.Process(nil) } func (c Connection) PodStats() error { // TODO return ErrNotImplemented } func (c Connection) StopPod(nameOrID string, timeout int) error { params := make(map[string]string) params["t"] = strconv.Itoa(timeout) response, err := c.newRequest(http.MethodPost, fmt.Sprintf("/pods/%s/stop", nameOrID), nil, params) if err != nil { return err } return response.Process(nil) } func (c Connection) PodTop() error { // TODO return ErrNotImplemented // nolint:typecheck } func (c Connection) UnpausePod(nameOrID string) error { response, err := c.newRequest(http.MethodPost, fmt.Sprintf("/pods/%s/unpause", nameOrID), nil, nil) if err != nil { return err } return response.Process(nil) }