etcdserver/api/v3rpc/quota.go
func (qa *quotaAlarmer) check(ctx context.Context, r interface{}) error {
	if qa.q.Available(r) {
		return nil
	}
	req := &pb.AlarmRequest{
		MemberID: uint64(qa.id),
		Action:   pb.AlarmRequest_ACTIVATE,
		Alarm:    pb.AlarmType_NOSPACE,
	}
	qa.a.Alarm(ctx, req)
	return rpctypes.ErrGRPCNoSpace
}
func (qa *quotaAlarmer) check(ctx context.Context, r interface{}) error {
	if qa.q.Available(r) {
		return nil
	}
	req := &pb.AlarmRequest{
		MemberID: uint64(qa.id),
		Action:   pb.AlarmRequest_ACTIVATE,
		Alarm:    pb.AlarmType_NOSPACE,
	}
	qa.a.Alarm(ctx, req)
	return rpctypes.ErrGRPCNoSpace
}
func ( qa * quotaAlarmer ) check ( ctx context . Context , r interface { } ) error { if qa . q . Available ( r ) { return nil } req := & pb . AlarmRequest { MemberID : uint64 ( qa . id ) , Action : pb . AlarmRequest_ACTIVATE , Alarm : pb . AlarmType_NOSPACE , } qa . a . Alarm ( ctx , req ) return rpctypes . ErrGRPCNoSpace }
// check whether request satisfies the quota. If there is not enough space,
// ignore request and raise the free space alarm.
check whether request satisfies the quota . If there is not enough space ignore request and raise the free space alarm .