@@ -13,7 +13,6 @@ import (
13
13
"github.com/openfaas/faas-provider/logs"
14
14
"github.com/openfaas/faas-provider/proxy"
15
15
"github.com/openfaas/faas-provider/types"
16
- "github.com/openfaas/faasd/pkg"
17
16
faasd "github.com/openfaas/faasd/pkg"
18
17
"github.com/openfaas/faasd/pkg/cninetwork"
19
18
faasdlogs "github.com/openfaas/faasd/pkg/logs"
@@ -30,8 +29,6 @@ func makeProviderCmd() *cobra.Command {
30
29
Short : "Run the faasd-provider" ,
31
30
}
32
31
33
- command .Flags ().String ("pull-policy" , "Always" , `Set to "Always" to force a pull of images upon deployment, or "IfNotPresent" to try to use a cached image.` )
34
-
35
32
command .RunE = runProviderE
36
33
command .PreRunE = preRunE
37
34
@@ -40,16 +37,6 @@ func makeProviderCmd() *cobra.Command {
40
37
41
38
func runProviderE (cmd * cobra.Command , _ []string ) error {
42
39
43
- pullPolicy , flagErr := cmd .Flags ().GetString ("pull-policy" )
44
- if flagErr != nil {
45
- return flagErr
46
- }
47
-
48
- alwaysPull := false
49
- if pullPolicy == "Always" {
50
- alwaysPull = true
51
- }
52
-
53
40
config , providerConfig , err := config .ReadFromEnv (types.OsEnv {})
54
41
if err != nil {
55
42
return err
@@ -95,6 +82,7 @@ nameserver 8.8.4.4`), workingDirectoryPermission); err != nil {
95
82
return err
96
83
}
97
84
85
+ alwaysPull := true
98
86
bootstrapHandlers := types.FaaSHandlers {
99
87
FunctionProxy : httpHeaderMiddleware (proxy .NewHandlerFunc (* config , invokeResolver , false )),
100
88
DeleteFunction : httpHeaderMiddleware (handlers .MakeDeleteHandler (client , cni )),
@@ -104,14 +92,14 @@ nameserver 8.8.4.4`), workingDirectoryPermission); err != nil {
104
92
ScaleFunction : httpHeaderMiddleware (handlers .MakeReplicaUpdateHandler (client , cni )),
105
93
UpdateFunction : httpHeaderMiddleware (handlers .MakeUpdateHandler (client , cni , baseUserSecretsPath , alwaysPull )),
106
94
Health : httpHeaderMiddleware (func (w http.ResponseWriter , r * http.Request ) {}),
107
- Info : httpHeaderMiddleware (handlers .MakeInfoHandler (pkg .Version , pkg .GitCommit )),
95
+ Info : httpHeaderMiddleware (handlers .MakeInfoHandler (faasd .Version , faasd .GitCommit )),
108
96
ListNamespaces : httpHeaderMiddleware (handlers .MakeNamespacesLister (client )),
109
97
Secrets : httpHeaderMiddleware (handlers .MakeSecretHandler (client .NamespaceService (), baseUserSecretsPath )),
110
98
Logs : httpHeaderMiddleware (logs .NewLogHandlerFunc (faasdlogs .New (), config .ReadTimeout )),
111
99
MutateNamespace : httpHeaderMiddleware (handlers .MakeMutateNamespace (client )),
112
100
}
113
101
114
- log .Printf ("Listening on: 0.0.0.0:%d\n " , * config .TCPPort )
102
+ log .Printf ("Listening on: 0.0.0.0:%d" , * config .TCPPort )
115
103
bootstrap .Serve (cmd .Context (), & bootstrapHandlers , config )
116
104
return nil
117
105
}
0 commit comments