Adding readiness, liveness probe for storagesvc.
This commit is contained in:
@@ -559,6 +559,18 @@ spec:
|
|||||||
volumeMounts:
|
volumeMounts:
|
||||||
- name: fission-storage
|
- name: fission-storage
|
||||||
mountPath: /fission
|
mountPath: /fission
|
||||||
|
readinessProbe:
|
||||||
|
httpGet:
|
||||||
|
path: "/healthz"
|
||||||
|
port: 8000
|
||||||
|
initialDelaySeconds: 5
|
||||||
|
periodSeconds: 2
|
||||||
|
livenessProbe:
|
||||||
|
httpGet:
|
||||||
|
path: "/healthz"
|
||||||
|
port: 8000
|
||||||
|
initialDelaySeconds: 16
|
||||||
|
periodSeconds: 5
|
||||||
serviceAccount: fission-svc
|
serviceAccount: fission-svc
|
||||||
volumes:
|
volumes:
|
||||||
- name: fission-storage
|
- name: fission-storage
|
||||||
|
|||||||
@@ -149,6 +149,10 @@ func (ss *StorageService) downloadHandler(w http.ResponseWriter, r *http.Request
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (ss *StorageService) healthHandler(w http.ResponseWriter, r *http.Request) {
|
||||||
|
w.WriteHeader(http.StatusOK)
|
||||||
|
}
|
||||||
|
|
||||||
func MakeStorageService(storageClient *StowClient, port int) *StorageService {
|
func MakeStorageService(storageClient *StowClient, port int) *StorageService {
|
||||||
return &StorageService{
|
return &StorageService{
|
||||||
storageClient: storageClient,
|
storageClient: storageClient,
|
||||||
@@ -161,6 +165,7 @@ func (ss *StorageService) Start(port int) {
|
|||||||
r.HandleFunc("/v1/archive", ss.uploadHandler).Methods("POST")
|
r.HandleFunc("/v1/archive", ss.uploadHandler).Methods("POST")
|
||||||
r.HandleFunc("/v1/archive", ss.downloadHandler).Methods("GET")
|
r.HandleFunc("/v1/archive", ss.downloadHandler).Methods("GET")
|
||||||
r.HandleFunc("/v1/archive", ss.deleteHandler).Methods("DELETE")
|
r.HandleFunc("/v1/archive", ss.deleteHandler).Methods("DELETE")
|
||||||
|
r.HandleFunc("/healthz", ss.healthHandler).Methods("GET")
|
||||||
|
|
||||||
address := fmt.Sprintf(":%v", port)
|
address := fmt.Sprintf(":%v", port)
|
||||||
log.Fatal(http.ListenAndServe(address, handlers.LoggingHandler(os.Stdout, r)))
|
log.Fatal(http.ListenAndServe(address, handlers.LoggingHandler(os.Stdout, r)))
|
||||||
|
|||||||
@@ -379,6 +379,7 @@ dump_logs() {
|
|||||||
dump_fission_logs $ns $fns router
|
dump_fission_logs $ns $fns router
|
||||||
dump_fission_logs $ns $fns buildermgr
|
dump_fission_logs $ns $fns buildermgr
|
||||||
dump_fission_logs $ns $fns executor
|
dump_fission_logs $ns $fns executor
|
||||||
|
dump_fission_logs $ns $fn storagsvc
|
||||||
dump_function_pod_logs $ns $fns
|
dump_function_pod_logs $ns $fns
|
||||||
dump_builder_pod_logs $bns
|
dump_builder_pod_logs $bns
|
||||||
dump_fission_crds
|
dump_fission_crds
|
||||||
|
|||||||
Reference in New Issue
Block a user