feat: implemented container_list
ci/woodpecker/push/lint Pipeline failed
Details
ci/woodpecker/push/lint Pipeline failed
Details
parent
3bda79f7ce
commit
4fe19d8f6a
|
@ -8,7 +8,7 @@ This list was taking from the [API
|
||||||
reference](https://docs.docker.com/engine/api/v1.41/).
|
reference](https://docs.docker.com/engine/api/v1.41/).
|
||||||
|
|
||||||
* Containers
|
* Containers
|
||||||
- [ ] List containers
|
- [x] List containers
|
||||||
- [ ] Create a container
|
- [ ] Create a container
|
||||||
- [ ] Inspect a container
|
- [ ] Inspect a container
|
||||||
- [ ] List processes running inside a container
|
- [ ] List processes running inside a container
|
||||||
|
@ -61,7 +61,7 @@ reference](https://docs.docker.com/engine/api/v1.41/).
|
||||||
- [ ] Delete unused networks
|
- [ ] Delete unused networks
|
||||||
|
|
||||||
* Volumes
|
* Volumes
|
||||||
- [*] List volumes
|
- [x] List volumes
|
||||||
- [ ] Create a volume
|
- [ ] Create a volume
|
||||||
- [ ] Inspect a volume
|
- [ ] Inspect a volume
|
||||||
- [ ] Remove a volume
|
- [ ] Remove a volume
|
||||||
|
|
76
containers.v
76
containers.v
|
@ -4,12 +4,78 @@ import json
|
||||||
import time
|
import time
|
||||||
import net.http { Method }
|
import net.http { Method }
|
||||||
|
|
||||||
|
pub struct Port {
|
||||||
|
ip string [json: IP]
|
||||||
|
private_port u16 [json: PrivatePort]
|
||||||
|
public_port u16 [json: PublicPort]
|
||||||
|
type_ string [json: Type]
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct HostConfig {
|
||||||
|
network_mode string [json: NetworkMode]
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct EndpointIpamConfig {
|
||||||
|
ipv4_address string [json: IPv4Address]
|
||||||
|
ipv6_address string [json: IPv6Address]
|
||||||
|
link_local_ips []string [json: LinkLocalIPs]
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct EndpointSettings {
|
||||||
|
ipam_config EndpointIpamConfig [json: IPAMConfig]
|
||||||
|
links []string [json: Links]
|
||||||
|
aliases []string [json: Aliases]
|
||||||
|
network_id string [json: NetworkID]
|
||||||
|
endpoint_id string [json: EndpointID]
|
||||||
|
gateway string [json: Gateway]
|
||||||
|
ip_address string [json: IPAddress]
|
||||||
|
ip_prefix_len int [json: IPPrefixLen]
|
||||||
|
ipv6_gateway string [json: IPv6Gateway]
|
||||||
|
global_ipv6_address string [json: GlobalIPv6Address]
|
||||||
|
global_ipv6_prefix_len i64 [json: GlobalIPv6PrefixLen]
|
||||||
|
mac_address string [json: MacAddress]
|
||||||
|
driver_opts map[string]string [json: DriverOpts]
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct NetworkSettings {
|
||||||
|
networks map[string]EndpointSettings [json: Networks]
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct MountPoint {
|
||||||
|
type_ string [json: Type]
|
||||||
|
name string [json: Name]
|
||||||
|
source string [json: Source]
|
||||||
|
destination string [json: Destination]
|
||||||
|
driver string [json: Driver]
|
||||||
|
mode string [json: Mode]
|
||||||
|
rw bool [json: RW]
|
||||||
|
propagation string [json: Propagation]
|
||||||
|
}
|
||||||
|
|
||||||
pub struct ContainerListItem {
|
pub struct ContainerListItem {
|
||||||
id string [json: Id]
|
id string [json: Id]
|
||||||
names []string [json: Names]
|
names []string [json: Names]
|
||||||
image string [json: Image]
|
image string [json: Image]
|
||||||
image_id string [json: ImageID]
|
image_id string [json: ImageID]
|
||||||
command string [json: Command]
|
command string [json: Command]
|
||||||
|
created i64 [json: Created]
|
||||||
|
ports []Port [json: Ports]
|
||||||
|
size_rw i64 [json: SizeRw]
|
||||||
|
size_root_fs i64 [json: sizeRootFs]
|
||||||
|
labels map[string]string [json: Labels]
|
||||||
|
state string [json: State]
|
||||||
|
status string [json: Status]
|
||||||
|
host_config HostConfig [json: HostConfig]
|
||||||
|
network_settings NetworkSettings [json: NetworkSettings]
|
||||||
|
mounts []MountPoint [json: Mounts]
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn (mut d DockerConn) container_list() ?[]ContainerListItem {
|
||||||
|
d.send_request(Method.get, '/containers/json')?
|
||||||
|
|
||||||
|
data := d.read_json_response<[]ContainerListItem>()?
|
||||||
|
|
||||||
|
return data
|
||||||
}
|
}
|
||||||
|
|
||||||
pub struct NewContainer {
|
pub struct NewContainer {
|
||||||
|
|
30
docker.v
30
docker.v
|
@ -14,8 +14,8 @@ const (
|
||||||
buf_len = 10 * 1024
|
buf_len = 10 * 1024
|
||||||
http_separator = [u8(`\r`), `\n`, `\r`, `\n`]
|
http_separator = [u8(`\r`), `\n`, `\r`, `\n`]
|
||||||
http_chunk_separator = [u8(`\r`), `\n`]
|
http_chunk_separator = [u8(`\r`), `\n`]
|
||||||
timestamp_attr = 'timestamp'
|
timestamp_attr = 'timestamp'
|
||||||
api_version = 'v1.41'
|
api_version = 'v1.41'
|
||||||
)
|
)
|
||||||
|
|
||||||
pub struct DockerConn {
|
pub struct DockerConn {
|
||||||
|
@ -43,7 +43,7 @@ pub fn (mut d DockerConn) close() ? {
|
||||||
|
|
||||||
// send_request sends an HTTP request without body.
|
// send_request sends an HTTP request without body.
|
||||||
fn (mut d DockerConn) send_request(method http.Method, url_str string) ? {
|
fn (mut d DockerConn) send_request(method http.Method, url_str string) ? {
|
||||||
url := urllib.parse('/$api_version$url_str')?
|
url := urllib.parse('/$vdocker.api_version$url_str')?
|
||||||
req := '$method $url.request_uri() HTTP/1.1\nHost: localhost\n\n'
|
req := '$method $url.request_uri() HTTP/1.1\nHost: localhost\n\n'
|
||||||
|
|
||||||
d.socket.write_string(req)?
|
d.socket.write_string(req)?
|
||||||
|
@ -54,7 +54,7 @@ fn (mut d DockerConn) send_request(method http.Method, url_str string) ? {
|
||||||
|
|
||||||
// send_request_with_body sends an HTTP request with the given body.
|
// send_request_with_body sends an HTTP request with the given body.
|
||||||
fn (mut d DockerConn) send_request_with_body(method http.Method, url_str string, content_type string, body string) ? {
|
fn (mut d DockerConn) send_request_with_body(method http.Method, url_str string, content_type string, body string) ? {
|
||||||
url := urllib.parse('/$api_version$url_str')?
|
url := urllib.parse('/$vdocker.api_version$url_str')?
|
||||||
req := '$method $url.request_uri() HTTP/1.1\nHost: localhost\nContent-Type: $content_type\nContent-Length: $body.len\n\n$body\n\n'
|
req := '$method $url.request_uri() HTTP/1.1\nHost: localhost\nContent-Type: $content_type\nContent-Length: $body.len\n\n$body\n\n'
|
||||||
|
|
||||||
d.socket.write_string(req)?
|
d.socket.write_string(req)?
|
||||||
|
@ -127,21 +127,21 @@ fn (mut d DockerConn) read_response() ?(http.Response, string) {
|
||||||
fn (mut d DockerConn) read_json_response<T>() ?T {
|
fn (mut d DockerConn) read_json_response<T>() ?T {
|
||||||
head, body := d.read_response()?
|
head, body := d.read_response()?
|
||||||
|
|
||||||
if head.status_code < 200 || head.status_code > 300 {
|
if head.status_code < 200 || head.status_code > 300 {
|
||||||
data := json.decode(DockerError, body)?
|
data := json.decode(DockerError, body)?
|
||||||
|
|
||||||
return docker_error(head.status_code, data.message)
|
return docker_error(head.status_code, data.message)
|
||||||
}
|
}
|
||||||
|
|
||||||
mut data := json.decode(T, body)?
|
mut data := json.decode(T, body)?
|
||||||
|
|
||||||
/* $for field in T.fields { */
|
//$for field in T.fields {
|
||||||
/* $if field.typ is time.Time { */
|
//$if field.typ is time.Time {
|
||||||
/* data.$(field.name) = time.parse_rfc3339(data.$(field.name + '_str'))? */
|
// data.$(field.name) = time.parse_rfc3339(data.$(field.name + '_str'))?
|
||||||
/* } */
|
//}
|
||||||
/* } */
|
//}
|
||||||
|
|
||||||
return data
|
return data
|
||||||
}
|
}
|
||||||
|
|
||||||
// get_chunked_response_reader returns a ChunkedResponseReader using the socket
|
// get_chunked_response_reader returns a ChunkedResponseReader using the socket
|
||||||
|
|
14
errors.v
14
errors.v
|
@ -1,21 +1,21 @@
|
||||||
module vdocker
|
module vdocker
|
||||||
|
|
||||||
struct DockerError {
|
struct DockerError {
|
||||||
status int [skip]
|
status int [skip]
|
||||||
message string
|
message string
|
||||||
}
|
}
|
||||||
|
|
||||||
fn (err DockerError) code() int {
|
fn (err DockerError) code() int {
|
||||||
return err.status
|
return err.status
|
||||||
}
|
}
|
||||||
|
|
||||||
fn (err DockerError) msg() string {
|
fn (err DockerError) msg() string {
|
||||||
return err.message
|
return err.message
|
||||||
}
|
}
|
||||||
|
|
||||||
fn docker_error(status int, message string) IError {
|
fn docker_error(status int, message string) IError {
|
||||||
return IError(DockerError{
|
return IError(DockerError{
|
||||||
status: status
|
status: status
|
||||||
message: message
|
message: message
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
10
volumes.v
10
volumes.v
|
@ -22,6 +22,14 @@ pub mut:
|
||||||
usage_data UsageData [json: UsageData]
|
usage_data UsageData [json: UsageData]
|
||||||
}
|
}
|
||||||
|
|
||||||
|
[params]
|
||||||
|
pub struct VolumeListFilter {
|
||||||
|
dangling bool
|
||||||
|
driver string
|
||||||
|
labels []string
|
||||||
|
name string
|
||||||
|
}
|
||||||
|
|
||||||
struct VolumeListResponse {
|
struct VolumeListResponse {
|
||||||
volumes []Volume [json: Volumes]
|
volumes []Volume [json: Volumes]
|
||||||
warnings []string [json: Warnings]
|
warnings []string [json: Warnings]
|
||||||
|
@ -30,7 +38,7 @@ struct VolumeListResponse {
|
||||||
pub fn (mut d DockerConn) volume_list() ?VolumeListResponse {
|
pub fn (mut d DockerConn) volume_list() ?VolumeListResponse {
|
||||||
d.send_request(Method.get, '/volumes')?
|
d.send_request(Method.get, '/volumes')?
|
||||||
|
|
||||||
mut data := d.read_json_response<VolumeListResponse>()?
|
mut data := d.read_json_response<VolumeListResponse>()?
|
||||||
|
|
||||||
for mut vol in data.volumes {
|
for mut vol in data.volumes {
|
||||||
vol.created_at = time.parse_rfc3339(vol.created_at_str)?
|
vol.created_at = time.parse_rfc3339(vol.created_at_str)?
|
||||||
|
|
Loading…
Reference in New Issue