philipp/uncloud
1
0
Fork 0
mirror of https://github.com/psviderski/uncloud.git synced 2026-08-26 19:13:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: internal Docker client PushImage

Browse Source
This commit is contained in:
Pasha Sviderski
2025-09-30 13:58:34 +10:00
parent 782f4cb20b
commit bcc504b8cc
2 changed files with 64 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/machine/docker/client.go
+5 -5
View File
@@ -206,7 +206,7 @@ type PullOptions struct {
Platform string
}
func (c *Client) PullImage(ctx context.Context, image string, opts PullOptions) (<-chan docker.PullImageMessage, error) {
func (c *Client) PullImage(ctx context.Context, image string, opts PullOptions) (<-chan docker.PullPushImageMessage, error) {
optsBytes, err := json.Marshal(opts)
if err != nil {
return nil, fmt.Errorf("marshal options: %w", err)
@@ -217,7 +217,7 @@ func (c *Client) PullImage(ctx context.Context, image string, opts PullOptions)
return nil, err
}
ch := make(chan docker.PullImageMessage)
ch := make(chan docker.PullPushImageMessage)
go func() {
defer close(ch)
@@ -228,16 +228,16 @@ func (c *Client) PullImage(ctx context.Context, image string, opts PullOptions)
return
}
if err != nil {
ch <- docker.PullImageMessage{Err: err}
ch <- docker.PullPushImageMessage{Err: err}
return
}
var jm jsonmessage.JSONMessage
if err = json.Unmarshal(msg.Message, &jm); err != nil {
ch <- docker.PullImageMessage{Err: fmt.Errorf("unmarshal JSON message: %w", err)}
ch <- docker.PullPushImageMessage{Err: fmt.Errorf("unmarshal JSON message: %w", err)}
return
}
ch <- docker.PullImageMessage{Message: jm}
ch <- docker.PullPushImageMessage{Message: jm}
}
}()