Golang

/* Морамо пренети податке из извора у неку врсту потрошача. Извор даје податке у малим пакетићима (~десет записа), док потрошач ради ефикасније са већим пакетићима (~хиљаду записа). Прави пример је пренос података из Kafka типа редова у базу података Clickhouse. Извор: - Практично бесконачан. - Извор никада не враћа више од MaxItems записа у једном позиву Next. - У оквиру једне "сесије" (једног позива функције Pipe), извор сваки пут враћа нове податке на сваки позив Next. - Међутим, након поновног покретања, извор почиње од претходне "потврђене" позиције, дефинисане cookie-јем. Због тога, *свака* вредност cookie-ја коју врати Next, након што се подаци сачувају у примаоцу, мора бити потврђена позивом Commit, у истом редоследу у коме су враћени од стране Next. Прималац: - Не може обрадити више од MaxItems одједном. Потребно је имплементирати функцију func Pipe(p Producer, c Consumer) error која чита податке из извора, групише их у буфер величине не већој од MaxItems и чува у примаоцу, након чега потврђује напредак у извору. */ const MaxItems = 9999 type Producer interface { // Next враћа: // - пакет ставки за обраду // - cookie за потврду када је обрада завршена // - грешка Next() (items []any, cookie int, err error) // Commit се користи за означавање пакета података као обрађеног Commit(cookie int) error } type Consumer interface { Process(items []any) error } func Pipe(p Producer, c Consumer) error { // TODO }

Middle+

Яндекс

137

4 - брзо прихватање улазних задатака, 5 - враћање резултата задатка по захтеву 6 - ако резултат нема, враћа одговарајући статус /* Процесор - услуга која извршава дуготрајну, ресурсно-интензивну операцију. Већ је реализована Грешке које враћа су искључиво повезане са некоректним улазним подацима, стабилне су и поновно захтевање је безсмислено */ type Processor interface { Process([]byte) ([]byte, error) } /* Претпостављамо да имамо генератор јединствених идентификатора (нпр. UUID). Генератор гарантује да неће бити судара */ type ID string // func NewID() ID /* Планер прихвата задатке од клијената, ставља их у ред и покреће у обраду. Обезбеђује да не више од 'threads' метода обраде ради истовремено Омогућава проверу статуса задатка и добијање резултата не блокира своје јавне методе за обраду */ type Scheduler struct { processor Processor } func NewScheduler( prc Processor, threads int, ) *Scheduler { // логика иницијализације return &Scheduler{ processor: prc, } } func (s *Scheduler) Queue(request []byte) ID { // имплементација return "" }

Middle+

Яндекс

136

Опишите алгоритам за решавање задатка maxSegment

Senior

Яндекс

136

Ispričaj šta se na kraju dešava — kako skupljamo bafer?

Middle+

Яндекс

135

Које су ваши очекивања у погледу плате?