я просто ток осваиваю ELK и пытаюсь разобраться как лучше в него из go писать логи

у нас немного модифицированная версия вот этой реализации https://github.com/bshuster-repo/logrus-logstash-hook/tree/0.4

к input logstash'a и index в kibana в данном кейсе с logrus вопросы не утихают

я как раз эту либу но с мастер бранча тестил

package main import ( "github.com/bshuster-repo/logrus-logstash-hook" log "github.com/sirupsen/logrus" "net" "fmt" ) func main() { //log := logrus.New() log.SetFormatter(&log.JSONFormatter{}) conn, err := net.Dial("tcp", "0.0.0.0:5044") if err != nil { log.Fatal(err) } hook := logrustash.New(conn, logrustash.DefaultFormatter(log.Fields{"type": "myappName"})) fmt.Println(hook) if err != nil { log.Fatal(err) } log.AddHook(hook) ctx := log.WithFields(log.Fields{ "method": "main", }) ctx.Info("Hello World!") }

это допиленная для запуска версия, но в терминале вижу что json ов два отдельных

мастер у них кажется очень старый

лучше взять 0.4 бранч, по идее примеры там рабочие

сейчас протестирую

(а я правильно понимаю, что если тесты запускаются эти, то в логсташ таки лог улетает? )

ну я бы проверил все равно)

как именно?

в логах logstash ошибок нет

порт у него 5044 на вход

какие способы есть для проверки? ъ

ну либо логстеш запустить с записью всего в файл, либо свою заглушку повесить на tcp порт и слушать

или еластик смотреть

я только осваиваю этот стек ELK

глупо жаловаться, что это большие компоненты которые за пару дней не освоишь..

ну по шагам надо, сначала надо убедиться что приложение шлет логи в логстеш, для этого можно повесить свою заглушку на tcp порт и слушать, будут приходить строки заканчивающие на \n

но все же все вместе копаю, пытаюсь все по полкам держать, но в одного не просто

каждая строка одно сообщение

после этого, уже разбираться с настройкой логстеша и эластика, чтобы первый передавал во второй

и последний шаг, настройка кибаны, чтобы она все забирала из эластика

ну по шагам надо, сначала надо убедиться что приложение шлет логи в логстеш, для этого можно повесить свою заглушку на tcp порт и слушать, будут приходить строки заканчивающие на \n

тобишь выключить логсташ с этого порта или просто логи временно слать на другой порт где поставить свой микродемон ожидающий соединения?)

У логстэша есть аутпут stdout и кодек rubydebug. Помогает отлаживать.

можно на другой порт слать, можно выключить логстеш, это вопрос удобства

https://www.elastic.co/guide/en/logstash/current/plugins-outputs-stdout.html

У логстэша есть аутпут stdout и кодек rubydebug. Помогает отлаживать.

как вариант, приэтом rubydebug совсем не обязателен

есть json

можно в файл

в общем это вопрос удобства

как вариант, приэтом rubydebug совсем не обязателен

В консоли красиво форматирует вывод )

В консоли красиво форматирует вывод )

боюсь закапаться с установкой модуля

В консоли красиво форматирует вывод )

это конечно круто, но насколько я понял здесь задача другая, красиво видеть в кибане

это конечно круто, но насколько я понял здесь задача другая, красиво видеть в кибане

да, довести логи до кибаны, потом уж в ней ковырять крутить

ну тогад по шагам, свою заглушку можно заменить на логстеш пишуший либо в стдаут, либо в файл

1) своя заглушка принимающая от логруса строки 2) переключаю на логсташ, чтобы он начал писать в файл 3) переключаю логсташ на еластик, чтобы еластик сохранял. 4) настраиваю кибанку на отражение данных из еластика

а какой индекс в кибане вы использовали?

просто я всю доку перешерстил, не очень прозрачно мне как именно выбирается этот индекс..

logstash-*, filebeat-* ....

станадртынй logstash-*

тобишь когда логсташь таки начнет писать по этой схеме, данные по этому индексу будут идти?) Ясно, спасибо большое. Вы мне очень помогли.

Да

Буду действовать по плану)

и может кинуть клич на ту либу, чтобы main ветке в readme написали, мол "устаревший пример" или вроде того

ну или nonstable

Как правильнее: var list []stringили list := []string{}?

это как?

и если слайс не используется, го выдает же ошибку

эй парень, ты куда сообщение удалил?

Как правильнее: var list []stringили list := []string{}?

разница в том, что в первом мы явно показываем компилятору какой тип, а во втором он сам определяет(соответственно тратит ресурсы)

а?! ресурсы?!

ну по факту

Как правильнее: var list []stringили list := []string{}?

эти строки значат разное вторая делает то же, что первая, плюс создает пустой слайс

ну по факту

по факту все будет ровно одинаковое

и там и там выведет пустой слайс

вообще-то нет

https://play.golang.org/p/QQyEkVD6d9

или я не в том смысле понял вопрос

во-общето, https://play.golang.org/p/QwtKAUHE8G

грубо говоря, в первом случаи просто определятся слайс, а во втором мы уже создаем указатель на область памяти?

Ага

Мы выделяем память и складываем указатель на нее в переменную слайса, точнее

во-общето, https://play.golang.org/p/QwtKAUHE8G

Да, все так. Как-то загонялся по этому вопросу, "объявление" и "инициализация". Только с практической точки зрения не понял разницы

и там и там можно сразу юзать, append например

что-то где-то недопонял

ок, а в структурах https://play.golang.org/p/5xHLWR4S8U можно считать var man1 man и man2 := man{} идентичным действием?

если я правильно понимаю тут var инициализирует структуру заполняя поля дефолтными нулями для типов

ок, а в структурах https://play.golang.org/p/5xHLWR4S8U можно считать var man1 man и man2 := man{} идентичным действием?

да, в этом случае - можно

вопрос: а сделать сервер нечувствительным к прямым и обратным слешам это везде работать с unix путями, а где требуется дергать filepath.FromSlash(...)?

если я правильно понимаю тут var инициализирует структуру заполняя поля дефолтными нулями для типов

для структур - идентичное, да. разница есть только для ссылосных типов

А можно, скажем, в одной горутине писать в stdin, а во второй читать оттуда? Я имею в виду нечто похожее на https://play.golang.org/p/luN4gc2ufS .

а это... зачем?

да

только писать нужно в Stdout

Или это эмуляция ввода пользователя?

Да, эмуляция. Пишу воркер, общение с которым происходит через stdin/stdout/stderr. Для облегчённого дебагинга хочу писать в stdin.

тогда скорее всего нет, stdin должен быть readonly

Stdin = NewFile(uintptr(syscall.Stdin), "/dev/stdin")

МОжет завернуть всё в итерфейсы io.Reader, io.Writer и ничего не знатьь про Stdin в самой функцит

а при старте функции просто передавать stdin как параметр

это сильно облегчит написание тестов и прочего

Если у меня есть структура. В ней несколько полей. Я меняю одно поле. Мютекс можно ставить только на это поле? Или нужно на всю структуру?

Если у меня есть структура. В ней несколько полей. Я меняю одно поле. Мютекс можно ставить только на это поле? Или нужно на всю структуру?

Как это - на поле?

Как это - на поле?

Если у меня есть структура. Она содержит две мапы. Если я пишу в первую мапу, мне достаточно блокировать доступ с других потоков только к ней? Или нужно блокировать доступ ко всей структуре, включая вторую мапу?

у тебя мьютекс принадлежит структуре, как ты будешь лочить одну мапу?

делаешь две структуры с одной мапой в каждой

и лочишь только структуру которую нужно

stuct lockedMap { sync.RWMutex map[...]... }

и посмотри на sync.Map

или сразу sync.Map использовать

Я в одну структуру вставил две мапы. И для каждой из них просто добавил мютекс

т.е. ты добавил два мьютекса в одну структуру, ага )))

Я в одну структуру вставил две мапы. И для каждой из них просто добавил мютекс

это семантически старнно