basic functions of the container is pushed

server/container.go

@@ -0,0 +1,84 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"io"
+	"os"
+
+	"github.com/docker/docker/api/types"
+	"github.com/docker/docker/api/types/container"
+	"github.com/docker/docker/client"
+	// "reflect" (use to check variable type: command [fmt.Println(reflect.TypeOf(<variable>))])
+)
+
+
+/* creates continer 
+TODO: Function inputs , outputs to be modified
+*/
+func create_container() (error, string){
+	ctx := context.Background()
+	cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
+	if err != nil {
+		return err, ""
+	}
+
+	imageName := "bfirsh/reticulate-splines"
+
+	out, err := cli.ImagePull(ctx, imageName, types.ImagePullOptions{})
+	if err != nil {
+		return err, ""
+	}
+	io.Copy(os.Stdout, out)
+
+	resp, err := cli.ContainerCreate(ctx, &container.Config{
+		Image: imageName,
+	}, nil, nil, nil, "")
+
+	if err != nil {
+		return err, ""
+	}
+
+	if err := cli.ContainerStart(ctx, resp.ID, types.ContainerStartOptions{}); err != nil {
+		return err, ""
+	}
+
+	return nil, string(resp.ID)
+}
+
+/* returns all containers running */
+func containers_running()(error, []types.Container){
+	ctx := context.Background()
+	cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
+	if err != nil {
+		return err ,nil
+	}
+
+	containers, err := cli.ContainerList(ctx, types.ContainerListOptions{})
+	if err != nil {
+		return err, nil
+	}
+
+	return nil ,containers
+}
+
+/* function to remove container from running */
+func delete_container(container_id string) (error, string){
+	ctx := context.Background()
+	cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
+	if err != nil {
+		return err ,""
+	}
+	if err := cli.ContainerStop(ctx, container_id, nil); err != nil {
+		return err ,""
+	}
+	return nil ,"Success"
+}
+
+func main(){
+	_, containers :=  containers_running()
+	fmt.Println(containers)
+	_, container_id := create_container()
+	_, status := delete_container(container_id)
+	fmt.Println(status)
+}

server/server.go

@@ -1,24 +1,7 @@
 package server
 
 import (
-    "context"
-    "fmt"
-
-    "github.com/libp2p/go-libp2p"
-    lssh "github.com/wanyvic/go-libp2p-ssh"
 )
 
 func server() {
-    listenAddrs := libp2p.ListenAddrStrings(
-        "/ip4/0.0.0.0/tcp/9001",
-    )
-    host, err := libp2p.New(context.Background(), listenAddrs)
-    if err != nil {
-        fmt.Println(err)
-    }
-    fmt.Printf("Your PeerID is :%s\nListen:%s\n", host.ID().String(), host.Addrs())
-    /*Your PeerID is :QmZ8zzzFhZAxWHzWecrj6x1r4UH9TnD35f6hBom3TbRGpu
-Listen:[/ip4/127.0.0.1/tcp/9000 /ip4/192.168.3.131/tcp/9000 /ip4/192.168.0.133/tcp/9000 /ip4/172.17.0.1/tcp/9000]*/
-    lssh.NewSSHService(host)
-    select {}   //hold on
 }