update
This commit is contained in:
1 parent
cd4c1a5a3a
commit
333819b2f2
3 files changed
+3
-5
No files matched your search
+1
-1
@@ -8,6 +8,6 @@ RUN CGO_ENABLED=0 go build -o hmq -a -ldflags '-extldflags "-static"' .
|
||||
FROM alpine:3.8
|
||||
WORKDIR /
|
||||
COPY --from=builder /go/src/github.com/fhmq/hmq/hmq .
|
||||
EXPOSE 50010
|
||||
EXPOSE 1883
|
||||
|
||||
CMD ["/hmq"]
|
||||
@@ -33,7 +33,7 @@ type Config struct {
|
||||
|
||||
//Init init kafak client
|
||||
func Init() {
|
||||
content, err := ioutil.ReadFile("./plugins/authhttp/http.json")
|
||||
content, err := ioutil.ReadFile("/plugins/authhttp/http.json")
|
||||
if err != nil {
|
||||
log.Fatal("Read config file error: ", zap.Error(err))
|
||||
}
|
||||
|
||||
@@ -37,14 +37,12 @@ type Config struct {
|
||||
//Init init kafak client
|
||||
func Init() {
|
||||
log.Info("start connect kafka....")
|
||||
content, err := ioutil.ReadFile("./plugins/kafka/kafka.json")
|
||||
content, err := ioutil.ReadFile("/plugins/kafka/kafka.json")
|
||||
if err != nil {
|
||||
log.Fatal("Read config file error: ", zap.Error(err))
|
||||
}
|
||||
// log.Info(string(content))
|
||||
|
||||
log.Info("end connect kafka....")
|
||||
|
||||
err = json.Unmarshal(content, &config)
|
||||
if err != nil {
|
||||
log.Fatal("Unmarshal config file error: ", zap.Error(err))
|
||||
|
||||
Reference in new issue
Block a user