собрать в слайс, и отсортировать его

наверняка есть какие-то готовые решения под это.

будет сильно быстрее списка

собрать в слайс, и отсортировать его

ага. я думал об этом. проблема в том что это по сути добавляет дополнительную задержку размером с буфер. тоесть если мы буферизуем последние три секунды, то часть данных у нас попадёт на вход функции через 6 секунд

а хотелось бы таки 3

этого я не понял

почему лишние 3 секунды?

хм. счас подумаю. может я неправ

я так понимаю, что потребитель данных проглатывает их мгновенно

да. проглатывает мгновенно или типа того

ну вот

все, что есть, добавили в слайс (попутно отбросив старое)

отсортировали, скормили на вход потребителю, запомнив максимальное

ждем нового

а. всё правильно. вот смотри. у нас данные же поступают не равномерно. отклонение может достигать 3 секунд. тоесть если мы кормим порциями по три секунды, то у нас в конце этих трех секунд может быть что-то что не пришло и мы ждём его еще три секунды складывая условно в другой буфер то новее и идёт уже в следующие три секунды

так это, надо не ждать, а по приходу последнего делать все, что надо

чё-то я туплю

допустим счас 00:00 мы создаём буфер. нам летят значения за промежуток 59:57-00:00. мы их выкидываем потому что только стартанули. секунды тикают и у нас начинают появляться значения с промежутками 00:00-00:03. счас 00:03. мы не можем счас отсортировать буфер и скормить его весь в функцию. потому что возможно через 2.55 секунды нам прилетит значение для времени 00:02.99 значит нам надо подождать 00:06, отсортировать буфер условно первую половину (по ширине делить нельзя - придётся ручками найти границу, пробежав) скормить функции, а вторую половину использовать для добавления новых значений

по ходу можно например сортировать раз в секунду и кормить секундными порциями

@onokonem @mr_tron почему бы просто не сделать это с каналом или двумя каналами?

потому что данные поступают неравномерно и их надо как-то упорядочить по времени

канал тут как-то не очень полезен

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

такая схема

эээээ.

так упорядочить можно только порцию

а порцию надо где-то накопить

и это не канал

а порцию надо где-то накопить

между каналами буффер

ну можно резать на секундные чанки в принципе и сортировать потом секунды внутри и кормить так

можно

но тут уже нужно подробное описание задачи

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

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

есть проблемы с тем, что данные буферизуются на девайсах на 2 секунды. ну и туда-сюда ещё доставка, запас на многозадачность - 99% пакетов данных укладываются в 3 секунды.

число девайсов известно?

6

ну так это

ну они ещё и разнородны. тоесть 2 шлют один тип данных. 4 - другой. при этом из этих 4 два не кэшируют и срут как есть

в чем проблема-то определить, что они все все заслали, или 3 секунды вышли?

ну короче я понял. режем чанками и пихаем в буферы размером в секунду или пол секунды. потом сортируем буфер и скармливаем его

у кого есть желание рев'ювнуть код, пишите в личку

https://github.com/nazaron1995/psychic-chainsaw

Ребят, где найти колабораторов для open source проекта? Пришёл момент когда мне нужна помощь комьюнити с github.com/qbeon/webwire-go поскольку milestone v1.0.0 почти достигнут - подходит момент оптимизации и отладки и тут я к сожалению не очень силён да и во времени немного ограничен, поэтому нуждаюсь в помощи не подскажете?

подскажите плз, чем лучше делать хттп запросы?

а?!

стандартным клиентом

подскажите плз, чем лучше делать хттп запросы?

gorequests глянь

чем можно быстро паковать структуры кроме json?

чем можно быстро паковать структуры кроме json?

Cap'n'proto

Быстрее некуда

кейс такой, я закидываю чувствительные данные в сторонную систему типа аналитики закидываю как пережатый кусок байт с aes и base64 сверху надо теперь пропихнуть целую структуру ее предварительно надо чем-то запаковать. Очень простым. Json не нравится то что там много лишнего и все строками

очень желательно без лишних зависимостей и генераторов структур =)

yaml?

так тоже строки же

msgpack

protocol buffers

если не строки - то формат данных идет отдельно от данных

так что protobuf и иже с ним

протобуф смотрел, раздражает необходимость кодогенерации за msgpack спасибо

тяжело будет на го писать, если кодогенерация раздражает

если go - go, то можно gob

там компактно и быстро

а можно ли как то присвоить эелменыты через запятую, если функция возвращает массив? например a, b, c := strings.Split(str, ",")

нет

массив - это массив

Питонист в треде)

а можно ли как то присвоить эелменыты через запятую, если функция возвращает массив? например a, b, c := strings.Split(str, ",")

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

Concurrency это когда на одном ядре выполняется несколько процессов как бы чередуясь?

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

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

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

Ты не сможешь вернуть ...interface

Красивого решения нет, кодеген разве что

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

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

return s[0], s[1], s[2]

return s[0], s[1], s[2]

а если неизвестно какая длинна массива?

return s[0], s[1], s[2]

Ну и соответственно: func flat(s []int) (int, int, int) {}

а если неизвестно какая длинна массива?

Никак

а если неизвестно какая длинна массива?

тогда возвращайте массив

Сахара такого нет

Да и чет, если честно, никогда такой необходимости не было, это на какую-то функциональщину похоже

это обычное дело для perl/python

да, я как будто обратно на 10 лет назад вернулся.

Concurrency это когда на одном ядре выполняется несколько процессов как бы чередуясь?

Concurrency это выполнение нескольких задачь одновременно, но не обязательно параллельно!

да, я как будто обратно на 10 лет назад вернулся.

Потенциально опасные места в го сделаны так чтоб ты 100 раз подумал хочешь ли ты этого или нет

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

а какой есть аналог fmt.Printf, только чтобы он не в косоль выводил, а переменную возвращал?

Sprinf

спасибо

Питонист в треде)

Почему сразу питонист?

если go - go, то можно gob

Благодарю, прикрутил) прямо в точку то что надо

Благодарю, прикрутил) прямо в точку то что надо

Всегда рад ромочь

а что в го вместо наследования/полиморфизма? допустим у меня есть абстрактный класс животное с методом move() и параметром mass. от него унаследованы 2 класса human, dog. и у этих двух классов должен быть такой же метод и параметр. это как то интерфейсами решается? или структуры как то объеденять надо?

а что в го вместо наследования/полиморфизма? допустим у меня есть абстрактный класс животное с методом move() и параметром mass. от него унаследованы 2 класса human, dog. и у этих двух классов должен быть такой же метод и параметр. это как то интерфейсами решается? или структуры как то объеденять надо?

композиция

Кто писал кодогенераторы? поделитесь ссылочками на примеры, буду благодарен

Go swagger?

Хммм

stringer где-то внутри стандартной библы