github.com/emqx/kuiper/tools/kubernetes v0.0.0-20260723062429-90ec05a56780
Basename is uppercase README.mdMarkdown-style heading precedes a code fence
SHA-256adc0c63af390aee7929f3a8a3ae6ec6fade35e4ba88ebc2b69a634a41eab18f0
MaleculeH₂(Cm₃F)
Evidence
11:48… , either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15package util
16
17import (
18 "encoding/json"
19 "fmt"
20 "net"
21 "net/http"
22 "os"
23 "path"
24 "strconv"
25 "strings"
26 "time"
27
28 kconf "github.com/lf-edge/ekuiper/tools/kubernetes/conf"
29)
30
⋯5 lines
44:36…
45 return c.strLog
46}
47
48func (c *command) call(host string) bool {
49 var resp []byte
50 var err error
51 head := host + c.Url
52 body, _ := json.Marshal(c.Data)
53 switch strings.ToUpper(c.Method) {
54 case http.MethodPost:
55 resp, err = kconf.Post(head, string(body))
56 case http.MethodGet:
57 resp, err = kconf.Get(head)
58 case http.MethodDelete:
59 resp, err = kconf.Delete(head) …
121:33… r()
122 s.dirCommand = dirCommand
123 s.fileHistory = path.Join(path.Dir(dirCommand), ".history")
124 if _, err := os.Stat(s.fileHistory); os.IsNotExist(err) {
125 if _, err = os.Create(s.fileHistory); nil != err {
126 kconf.Log.Info(err)
⋯5 lines
161:11… lse
162}
163
164func (s *server) processDir() bool {
165 dirEntries, err := os.ReadDir(s.dirCommand)
166 if nil != err {
167 s.logs = append(s.logs, fmt.Sprintf("read command dir:%v", err))
168 return false
169 }
170 conf := kc …
73:28… s(path); err != nil {
74 return "", nil
75 } else {
76 if _, err := os.Stat(abs); os.IsNotExist(err) {
77 return "", err
78 }
⋯13 lines
92 return false
93 }
94 err = yaml.Unmarshal(sliByte, c)
95 if nil != err {
96 fmt.Println("unmashal conf err : ", err)
⋯4 lines
No evidence locations were recorded for this file. Raw result