С какви бази данни или други хранилища на данни сте работили? Колко заявки в секунда (RPS) за запис и четене?
Golang
Имали ли сте опит в разработването и поддръжката на разпределени системи?
Какъв е максималният товар в заявки на секунда, който е обработвал най-натовареният сервиз? Правилно ли е, че е до 5–8 хиляди заявки на секунда?
С кои бази данни и други системи за съхранение на данни сте работили?
Какъв беше най-големият обем на съхраняваните данни?
В кое направление бихте се интересували да се развивате по отношение на задачи и кариера?
// код за функцията best() // с обработка на грешки при липса на наличен бекенд
Защо разглеждате нови предложения и защо напуснахте предишната си компания?
// код за функцията best() // с обработка на грешки при липса на наличен бекенд
// код за функцията best() // с обработка на грешки при липса на наличен бекенд
// код за функцията best() // с обработка на грешки при липса на наличен бекенд
Кой чете резултатния канал и къде пише резултата, за да може методът Status да има достъп до него?
type Response interface{} type Backend interface { Invoke(ctx context.Context, req Request) (Response, error) } var _ Backend = &BackendImpl{} // addr съдържа ip:port на конкретен екземпляр func NewBackend(addr string) *BackendImpl type backentry struct { backend Backend inflight int64 } type Balancer struct { backends []*backentry mu *sync.Mutex } var _ Backend = &Balancer{} // addrs съдържат адресите на всички балансиращи екземпляри func NewBalancer(addrs []string) *Balancer { data := make([]*backentry,len(addrs)) for i,addr := range addrs{ data[i] = &backentry{ backend: NewBackend(addr), inflight: 0, } } return &Balancer{backends:data} } func(b *Balancer)Invoke(ctx context.Context, req Request) (Response, error){ b.mu.Lock() entry := b.best() atomic.AddInt64(&entry.inflight,1) b.mu.Unlock() defer atomic.AddInt64(&entry.inflight,-1) return entry.backend.Invoke(ctx,req) } func(b *Balancer) best() *backentry{ var best *backentry for _,entry := b.backends{ if best == nil || atomic.LoadInt64(&entry.inflight) < atomic.LoadInt64(&best.inflight){ best = entry } } return best }
На колко хоста или инстанции работеше услугата? Колко контейнера бяха стартирани?
// код за функцията best() // с обработка на грешки при липса на наличен бекенд
Реализирайте метода Queue
Как да реализирате метода Status, за да получите състоянието на задачата по ID?
// код за функцията best() // с обработка на грешки при липса на наличен бекенд
Реализирайте метода Queue
// търсим най-доброто -- ??? // ако не намерите, сравнете inflight