|
|
@@ -109,6 +109,8 @@ func (s *Server) Do(ctx context.Context, r Request) (Response, error) {
|
|
|
|
|
|
// apply interprets r as a call to store.X and returns an Response interpreted from store.Event
|
|
|
func (s *Server) apply(e raft.Entry) (*store.Event, error) {
|
|
|
+ // TODO(bmizerany): apply needs to take a context.Context, but store
|
|
|
+ // doesn't have a mechanism to abort operations yet.
|
|
|
var r Request
|
|
|
if err := r.Unmarshal(e.Data); err != nil {
|
|
|
return nil, err
|