Ποιο ήταν το μεγαλύτερο όγκο αποθηκευμένων δεδομένων;
Golang
Με ποιες βάσεις δεδομένων και άλλα συστήματα αποθήκευσης δεδομένων έχετε εργαστεί;
// κώδικας για τη συνάρτηση best() // με διαχείριση σφαλμάτων όταν δεν υπάρχει διαθέσιμο backend
Σε ποια κατεύθυνση θα ήσασταν ενδιαφερόμενοι να αναπτυχθείτε όσον αφορά τις εργασίες και το διανύσμα καριέρας;
Γιατί εξετάζετε νέες προτάσεις και γιατί αφήσατε την προηγούμενη εταιρεία σας;
// κώδικας για τη συνάρτηση best() // με διαχείριση σφαλμάτων όταν δεν υπάρχει διαθέσιμο backend
Πώς να περιορίσετε τον αριθμό των goroutines ώστε να μην εκτελούνται ταυτόχρονα περισσότερα από 'threads' μεθόδους του Process; Ποιος θα τραβάει τις εργασίες από το κανάλι;
// κώδικας για τη συνάρτηση best() // με διαχείριση σφαλμάτων όταν δεν υπάρχει διαθέσιμο backend
// κώδικας για τη συνάρτηση best() // με διαχείριση σφαλμάτων όταν δεν υπάρχει διαθέσιμο backend
Σε πόσους διακομιστές ή στιγμιότυπα λειτουργούσε η υπηρεσία; Πόσα κοντέινερ ξεκίνησαν;
Ποιος διαβάζει το αποτέλεσμα του καναλιού και πού γράφει το αποτέλεσμα ώστε η μέθοδος Status να μπορεί να το προσπελάσει;
// κώδικας για τη συνάρτηση best() // με διαχείριση σφαλμάτων όταν δεν υπάρχει διαθέσιμο backend
// κώδικας για τη συνάρτηση best() // με διαχείριση σφαλμάτων όταν δεν υπάρχει διαθέσιμο backend
Υλοποιήστε τη μέθοδο Queue
Πώς να υλοποιήσετε τη μέθοδο Status για να λάβετε την κατάσταση της εργασίας με το ID;
// κώδικας για τη συνάρτηση best() // με διαχείριση σφαλμάτων όταν δεν υπάρχει διαθέσιμο backend
type Response interface{} type Backend interface { Invoke(ctx context.Context, req Request) (Response, error) } var _ Backend = &BackendImpl{} // addr contiene ip:port di una istanza specifica func NewBackend(addr string) *BackendImpl type backentry struct { backend Backend inflight int64 } type Balancer struct { backends []*backentry mu *sync.Mutex } var _ Backend = &Balancer{} // addrs contiene gli indirizzi di tutte le istanze bilanciate 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 }
Υλοποιήστε τη μέθοδο Queue
// κώδικας για τη συνάρτηση best() // με διαχείριση σφαλμάτων όταν δεν υπάρχει διαθέσιμο backend
// ψάχνουμε το καλύτερο -- ??? // αν δεν βρεθεί, σύγκρινε inflight