Skip to content

Commit

Permalink
fix some issue
Browse files Browse the repository at this point in the history
  • Loading branch information
zhaojizhuang committed Jun 24, 2021
1 parent c7f5e44 commit 3f62a7d
Show file tree
Hide file tree
Showing 4 changed files with 15 additions and 20 deletions.
17 changes: 7 additions & 10 deletions cmd/daemon/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,20 +6,17 @@ import (
"net/http"
"os"

"github.com/julz/freeze-proxy/pkg/daemon"
authv1 "k8s.io/api/authentication/v1"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/rest"

"github.com/julz/freeze-proxy/pkg/freezer"
"github.com/julz/freeze-proxy/pkg/daemon"
"github.com/julz/freeze-proxy/pkg/freeze"
)

var runtimeType string

func init() {
runtimeType = os.Getenv("RUNTIME_TYPE")
}
func main() {
runtimeType := os.Getenv("RUNTIME_TYPE")

config, err := rest.InClusterConfig()
if err != nil {
log.Fatal(err)
Expand All @@ -30,18 +27,18 @@ func main() {
log.Fatal(err)
}

fre, err := freezer.GetFreezer(runtimeType)
freezer, err := freeze.GetFreezer(runtimeType)
if err != nil {
log.Fatal(err)
}

thawer, err := freezer.GetThawer(runtimeType)
thawer, err := freeze.GetThawer(runtimeType)
if err != nil {
log.Fatal(err)
}

http.ListenAndServe(":8080", &daemon.Handler{
Freezer: fre,
Freezer: freezer,
Thawer: thawer,
Validator: daemon.TokenValidatorFunc(func(ctx context.Context, token string) (*authv1.TokenReview, error) {
return clientset.AuthenticationV1().TokenReviews().CreateContext(ctx, &authv1.TokenReview{
Expand Down
File renamed without changes.
12 changes: 5 additions & 7 deletions pkg/freezer/docker/pause.go → pkg/freeze/docker/pause.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,22 +10,20 @@ import (
dockerapi "github.com/docker/docker/client"
)

const DefaultDockerUri = "unix:///var/run/docker.sock"
const Version = "1.19"
const defaultDockerUri = "unix:///var/run/docker.sock"
const version = "1.19"

type Docker struct {
client *dockerapi.Client
}

func NewDockerService() (*Docker, error) {
r := &Docker{}
c, err := dockerapi.NewClientWithOpts(dockerapi.WithHost(DefaultDockerUri),
dockerapi.WithVersion(Version))
c, err := dockerapi.NewClientWithOpts(dockerapi.WithHost(defaultDockerUri),
dockerapi.WithVersion(version))
if err != nil {
return nil, err
}
r.client = c
return r, nil
return &Docker{client: c}, nil
}

func (d *Docker) Freeze(ctx context.Context, podUID, containerName string) error {
Expand Down
6 changes: 3 additions & 3 deletions pkg/freezer/factory.go → pkg/freeze/freeze.go
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
package freezer
package freeze

import (
"fmt"

"github.com/julz/freeze-proxy/pkg/daemon"
"github.com/julz/freeze-proxy/pkg/freezer/containerd"
docker "github.com/julz/freeze-proxy/pkg/freezer/docker"
"github.com/julz/freeze-proxy/pkg/freeze/containerd"
docker "github.com/julz/freeze-proxy/pkg/freeze/docker"
)

const (
Expand Down

0 comments on commit 3f62a7d

Please sign in to comment.