mirror of
https://github.com/podman-container-tools/podman.git
synced 2026-08-31 20:57:53 +00:00
09dc701097
While this commit was initially meant to fix #5847, it has turned into a bigger refactoring which I did not manage to break into smaller pieces: * Fix #5847 by refactoring the image-removal logic. * Make the api handler for image-removal use the ABI code. This way, both (i.e., ABI and Tunnel) end up using the same code. Achieving this code share required to move some code around to prevent circular dependencies. * Everything in pkg/api (excluding pkg/api/types) must now only be accessed from code using `ABISupport`. * Avoid imports from entities on handlers to prevent circular dependencies. * Move `podman system service` logic into `cmd` to prevent circular dependencies - it depends on pkg/api. * Also remove the build header from infra/abi files. It will otherwise confuse swagger and other tools; errors we cannot fix as go doesn't expose a build-tag env variable. Fixes: #5847 Signed-off-by: Valentin Rothberg <rothberg@redhat.com>
61 lines
1.5 KiB
Go
61 lines
1.5 KiB
Go
package system
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"io"
|
|
"net/http"
|
|
"net/url"
|
|
|
|
"github.com/containers/libpod/pkg/bindings"
|
|
"github.com/containers/libpod/pkg/domain/entities"
|
|
"github.com/pkg/errors"
|
|
"github.com/sirupsen/logrus"
|
|
)
|
|
|
|
// Events allows you to monitor libdpod related events like container creation and
|
|
// removal. The events are then passed to the eventChan provided. The optional cancelChan
|
|
// can be used to cancel the read of events and close down the HTTP connection.
|
|
func Events(ctx context.Context, eventChan chan (entities.Event), cancelChan chan bool, since, until *string, filters map[string][]string) error {
|
|
conn, err := bindings.GetClient(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
params := url.Values{}
|
|
if since != nil {
|
|
params.Set("since", *since)
|
|
}
|
|
if until != nil {
|
|
params.Set("until", *until)
|
|
}
|
|
if filters != nil {
|
|
filterString, err := bindings.FiltersToString(filters)
|
|
if err != nil {
|
|
return errors.Wrap(err, "invalid filters")
|
|
}
|
|
params.Set("filters", filterString)
|
|
}
|
|
response, err := conn.DoRequest(nil, http.MethodGet, "/events", params)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if cancelChan != nil {
|
|
go func() {
|
|
<-cancelChan
|
|
err = response.Body.Close()
|
|
logrus.Error(errors.Wrap(err, "unable to close event response body"))
|
|
}()
|
|
}
|
|
dec := json.NewDecoder(response.Body)
|
|
for {
|
|
e := entities.Event{}
|
|
if err := dec.Decode(&e); err != nil {
|
|
if err == io.EOF {
|
|
break
|
|
}
|
|
return errors.Wrap(err, "unable to decode event response")
|
|
}
|
|
eventChan <- e
|
|
}
|
|
return nil
|
|
}
|